SpringBoot整合Netty整合WebSocket-带参认证

文章目录

    • 一. VectorNettyApplication启动类配置
    • 二.WebSocketServerBoot初始化服务端Netty
    • 三. WebsocketServerChannelInitializer初始化服务端Netty读写处理器
    • 四.initParamHandler处理器-去参websocket识别
    • 五.MessageHandler核心业务处理类-采用工厂策略模式
      • 5.1 策略上下文
    • 六.统一响应
    • 七.统一输出处理器


一. VectorNettyApplication启动类配置

初始化SpringBoot线程同时初始化Netty线程

/*** @description: 通知启动类* @Title: VectorNotification* @Package com.vector.notification* @Author YuanJie* @Date 2023/3/2 12:57*/
@EnableDiscoveryClient // 开启服务注册与发现
@SpringBootApplication(scanBasePackages = {"com.vector"},exclude = {DataSourceAutoConfiguration.class}) // 开启组件扫描和自动配置
public class VectorNettyApplication implements CommandLineRunner {@Value("${netty.host}")private String host;@Value("${netty.port}")private Integer port;@Resourceprivate WebSocketServerBoot webSocketServerBoot;public static void main(String[] args) {SpringApplication.run(VectorNettyApplication.class, args);}// springboot启动后执行netty服务端启动@Overridepublic void run(String... args) throws Exception {ChannelFuture channelFuture = webSocketServerBoot.bind(host, port);// 优雅关闭, jvm关闭时将netty服务端关闭Runtime.getRuntime().addShutdownHook(new Thread(() -> webSocketServerBoot.destroy()));// 阻塞 直到channel关闭channelFuture.channel().closeFuture().syncUninterruptibly();}
}

二.WebSocketServerBoot初始化服务端Netty

主要进行netty的基本配置

/*** @author YuanJie* @projectName vector-server* @package com.vector.netty.accept* @className com.vector.netty.accept.ServerBootstrap* @copyright Copyright 2020 vector, Inc All rights reserved.* @date 2023/6/9 18:34*/
@Component
@Slf4j
public class WebSocketServerBoot {private final EventLoopGroup parentGroup = new NioEventLoopGroup();private final EventLoopGroup childGroup = new NioEventLoopGroup(2);private Channel channel;@Resourceprivate WebsocketServerChannelInitializer websocketServerChannelInitializer;/*** 初始化服务端* sync():等待Future直到其完成,如果这个Future失败,则抛出失败原因;* syncUninterruptibly():不会被中断的sync();*/public ChannelFuture bind(String host, Integer port) {ChannelFuture channelFuture = null;try {channelFuture = new ServerBootstrap().group(parentGroup, childGroup) // 指定线程模型 一个用于接收客户端连接,一个用于处理客户端读写操作.channel(NioServerSocketChannel.class) // 指定服务端的IO模型.option(ChannelOption.SO_BACKLOG, 1024) // 设置TCP缓冲区.childOption(ChannelOption.SO_KEEPALIVE, true) // 保持连接 tcp底层心跳机制.childHandler(websocketServerChannelInitializer) // 指定处理新连接数据的读写处理逻辑.bind(host, port).addListener(new GenericFutureListener<Future<? super Void>>() {@Overridepublic void operationComplete(Future<? super Void> future) throws Exception {if (future.isSuccess()) {log.info("服务端启动成功,监听端口:{}", port);} else {log.error("服务端启动失败,监听端口:{}", port);bind(host, port + 1);}}}).syncUninterruptibly();// 绑定端口channel = channelFuture.channel(); // 获取channel} finally {if (null == channelFuture) {channel.close();parentGroup.shutdownGracefully();childGroup.shutdownGracefully();}}return channelFuture;}/*** 销毁*/public void destroy() {if (null == channel) return;channel.close();parentGroup.shutdownGracefully();childGroup.shutdownGracefully();}/*** 获取通道** @return*/public Channel getChannel() {return channel;}
}

三. WebsocketServerChannelInitializer初始化服务端Netty读写处理器

主要规划netty的读写处理器

/*** @author YuanJie* @projectName vector-server* @package com.vector.netty.config* @className com.vector.netty.server.ServerChannelInitializer* @copyright Copyright 2020 vector, Inc All rights reserved.* @date 2023/6/9 19:13*/
@Component
public class WebsocketServerChannelInitializer extends ChannelInitializer<SocketChannel> {// @Sharableprivate final LoggingHandler loggingHandler = new LoggingHandler(LogLevel.INFO);public final static String WEBSOCKET_PATH = "/ws";@Resourceprivate InitParamHandler initParamHandler;@Resourceprivate MessageHandler messageHandler;@Resourceprivate OutBoundHandler outBoundHandler;@Overrideprotected void initChannel(SocketChannel socketChannel) throws Exception {ChannelPipeline pipeline = socketChannel.pipeline();// 日志打印pipeline.addLast(loggingHandler);// http报文解析器 线程不安全不能被共享pipeline.addLast(new HttpServerCodec());
//        // 添加对大数据流的支持pipeline.addLast(new ChunkedWriteHandler());
//        // 消息聚合器 8192 8Mpipeline.addLast(new HttpObjectAggregator(1 << 13));// 进行设置心跳检测pipeline.addLast(new IdleStateHandler(60, 30, 60 * 30, TimeUnit.SECONDS));// ================= 上述是用于支持http协议的 ==============//websocket 服务器处理的协议,用于给指定的客户端进行连接访问的路由地址// 处理uri参数 WebSocketServerProtocolHandler不允许带参数 顺序不可调换pipeline.addLast(initParamHandler);pipeline.addLast(new WebSocketServerProtocolHandler(WEBSOCKET_PATH,null, true, 1<<16,true,true,5000));pipeline.addLast(messageHandler);// 自定义出栈处理器pipeline.addLast(outBoundHandler);}
}

四.initParamHandler处理器-去参websocket识别

主要为了去参,WebSocketServerProtocolHandler不允许带参数,同时初始化一些信道用户数据

/*** URL参数处理程序,这时候连接还是个http请求,没有升级成webSocket协议,此处SimpleChannelInboundHandler泛型使用FullHttpRequest** @author YuanJie* @date 2023/5/7 15:07*/
@Slf4j
@ChannelHandler.Sharable
@Component
public class InitParamHandler extends SimpleChannelInboundHandler<FullHttpRequest> {/*** 存储已经登录用户的channel对象*/public static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);/*** 存储用户id和用户的channelId绑定*/public static final Map<Long, ChannelId> userMap = new ConcurrentHashMap<>();/*** 用于存储群聊房间号和群聊成员的channel信息*/public static final Map<Long, ChannelGroup> groupMap = new ConcurrentHashMap<>();@DubboReferenceprivate MemberRemote memberRemote;/*** 此处进行url参数提取,重定向URL,访问webSocket的url不支持带参数的,带参数会抛异常,这里先提取参数,将参数放入通道中传递下去,重新设置一个不带参数的url** @param ctx     the {@link ChannelHandlerContext} which this {@link SimpleChannelInboundHandler}*                belongs to* @param request the message to handle* @throws Exception*/@Overrideprotected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest request) throws Exception {if (!this.acceptInboundMessage(request)) {ctx.fireChannelRead(request.retain());}String uri = request.uri();log.info("NettyWebSocketParamHandler.channelRead0 --> : 格式化URL... {}", uri);Map<CharSequence, CharSequence> queryMap = UrlBuilder.ofHttp(uri).getQuery().getQueryMap();//将参数放入通道中传递下去String senderId = "senderId";if (StringUtils.isBlank(queryMap.get(senderId))) {log.info("NettyWebSocketParamHandler.channelRead0 --> : 参数缺失 senderId");ctx.close();}// 验证token
//        verifyToken(ctx,senderId);// 初始化数据
//        initData(ctx, Long.valueOf(queryMap.get(senderId).toString()));// 获取?之前的路径request.setUri(WebsocketServerChannelInitializer.WEBSOCKET_PATH);ctx.fireChannelRead(request.retain());}@Overridepublic void channelActive(ChannelHandlerContext ctx) {//添加到channelGroup通道组channelGroup.add(ctx.channel());ctx.channel().id();}@Overridepublic void channelInactive(ChannelHandlerContext ctx) {// 移除channelGroup 通道组channelGroup.remove(ctx.channel());}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {cause.printStackTrace();log.error("NettyWebSocketParamHandler.exceptionCaught --> cause: ", cause);ctx.close();}private void verifyToken(ChannelHandlerContext ctx, Long senderId) {String userKey = CacheConstants.LOGIN_TOKEN_KEY + senderId;RedissonCache redissonCache = SpringContextUtil.getBean(RedissonCache.class);Boolean hasKey = redissonCache.hasKey(userKey);if (!hasKey) {log.info("NettyWebSocketParamHandler.channelRead0 --> : 用户未登录... {}", senderId);ctx.close();}// token续期redissonCache.expire(userKey, SystemConstants.TOKEN_EXPIRE_TIME, TimeUnit.MILLISECONDS);}/*** 加入聊天室** @param ctx* @param senderId* @throws ExecutionException* @throws InterruptedException*/private void joinGroup(ChannelHandlerContext ctx, Long senderId) {R r = null;try {CompletableFuture<R> result = memberRemote.getGroupListById(senderId);r = result.get(3, TimeUnit.SECONDS);} catch (Exception e) {log.error("messageHandler.joinGroup查询群聊列表失败 ===> {}", e.getMessage());ctx.channel().write(WSMessageDTO.error("查询群聊列表失败"));return;}if (r == null || r.getCode() != 200) {log.error("查询群聊列表失败 ====> {}", r.getMsg());ctx.channel().write(WSMessageDTO.error("查询群聊列表失败"));return;}//查询成功//获取群聊列表String json = JacksonInstance.toJson(r.getData());List<Long> groupIds = JacksonInstance.toObjectList(json, new TypeReference<List<Long>>() {});ChannelGroup group;for (Long groupId : groupIds) {group = groupMap.get(groupId);if (group == null) {//如果群聊信道不存在,则创建一个群聊信道group = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);groupMap.put(groupId, group);}//将当前用户加入到群聊信道中group.add(ctx.channel());}}/*** 加入聊天信道*/private void joinChat(ChannelHandlerContext ctx, Long senderId) {//将当前用户的channelId放入map中userMap.put(senderId, ctx.channel().id());}private void initData(ChannelHandlerContext ctx, Long senderId) {joinChat(ctx, senderId);joinGroup(ctx, senderId);}
}

五.MessageHandler核心业务处理类-采用工厂策略模式

使得业务和通信协议无关,无感知。具体业务可以增加策略

/*** @author YuanJie* @projectName vector-server* @package com.vector.netty.handler* @className com.vector.netty.handler.MessageTypeHandler* @copyright Copyright 2020 vector, Inc All rights reserved.* @date 2023/6/15 16:23*/
@Slf4j
@Component
@ChannelHandler.Sharable
public class MessageHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {@Resourceprivate MessageStrategyContext messageStrategyContext;@Overridepublic void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) {// 获取客户端发送的数据WSMessageDTO wsMessageDTO = JacksonInstance.toObject(msg.text(), new TypeReference<WSMessageDTO>() {});wsMessageDTO.setMessageId(SnowFlakeUtil.getNextId());log.info("客户端收到服务器数据:{}", wsMessageDTO.getMessage());verifyParams(ctx, wsMessageDTO);// 根据消息类型获取对应的处理器 核心处理方法messageStrategyContext.messageType(ctx, wsMessageDTO);}private void verifyParams(ChannelHandlerContext ctx, WSMessageDTO wsMessageDTO) {StringBuilder sb = new StringBuilder();if (wsMessageDTO.getSenderId() == null) {sb.append("senderId不能为空");}if (!EnumBusiness.containsBusiness(wsMessageDTO.getBusinessType())) {sb.append("businessType不能为空");}if (!EnumMessage.containsMessage(wsMessageDTO.getMessageType())) {sb.append("messageType不能为空");}if (wsMessageDTO.getMessage() == null) {sb.append("message不能为空");}if (sb.length() > 0) {log.error("参数校验失败:{}", sb.toString());ctx.channel().write(WSMessageDTO.error("参数校验失败:" + sb.toString()));ctx.close();}}@Overridepublic void channelReadComplete(ChannelHandlerContext ctx) throws Exception {ctx.flush();}
}

5.1 策略上下文

具体工厂策略可以详看我的策略模式文章
枚举维护前端参数和bean对象名

/*** @author YuanJie* @projectName vector-server* @package com.vector.netty.enums* @className com.vector.netty.enums.BusinessEnums* @copyright Copyright 2020 vector, Inc All rights reserved.* @date 2023/6/14 16:13*/
public enum EnumBusiness {/*** 单聊*/chatMessage("chat", ChatMessageStrategy.class.getSimpleName()),/*** 群聊*/groupMessage("group", GroupMessageStrategy.class.getSimpleName()),/*** 在线人数*/onlineCount("onlineCount", OnlineCountStrategy.class.getSimpleName()),TEST("test",TestStrategy.class.getSimpleName());private final String businessType;private final String beanName;EnumBusiness(String businessType, String beanName) {this.businessType = businessType;this.beanName = StringUtils.isNotEmpty(beanName)?beanName.toLowerCase():null;}/*** 根据code获取对应的枚举对象*/public static EnumBusiness getEnum(String businessType) {EnumBusiness[] values = EnumBusiness.values(); // 获取枚举列表if (null != businessType && values.length > 0) {for (EnumBusiness value : values) {if (value.businessType.equals(businessType)) {return value;  // 返回枚举对象}}}return null;}/*** 该code在枚举列表code属性是否存在*/public static boolean containsBusiness(String businessType) {EnumBusiness anEnum = getEnum(businessType); // 获取枚举对象return anEnum != null;}/*** 判断code与枚举中的code是否相同*/public static boolean equals(String businessType, EnumBusiness calendarSourceEnum) {return calendarSourceEnum.businessType.equals(businessType);}public String getBusinessType() {return businessType;}public String getBeanName() {return beanName;}
}

策略根据bean名获取实例对象

/*** @author YuanJie* @projectName vector-server* @package com.vector.netty.service* @className com.vector.netty.service.MessageContext* @copyright Copyright 2020 vector, Inc All rights reserved.* @date 2023/6/14 17:02*/
@Component
@Slf4j
public class MessageStrategyContext {/** 策略实例集合 */private final ConcurrentHashMap<String, MessageStrategy> strategyConcurrentHashMap =new ConcurrentHashMap<>(20);/*** 注入策略实例* 如果使用的是构造器注入,可能会有多个参数注入进来。** 如果使用的是field反射注入** 如果使用的是setter方法注入,那么你将不能将属性设置为final。** @param strategyMap*         注意注入类型要是Map基础类型*         注入接口,spring会自动注入他的所有被spring托管的实现类*/@Autowiredpublic MessageStrategyContext(Map<String, MessageStrategy> strategyMap) {//清空集合数据this.strategyConcurrentHashMap.clear();if (!CollectionUtils.isEmpty(strategyMap)) {strategyMap.forEach((beanName, messageStrategy) -> {if (StringUtils.isEmpty(beanName) || messageStrategy == null) {return;}this.strategyConcurrentHashMap.put(beanName.toLowerCase(), messageStrategy);});}}/*** 选择业务方式* 单聊,群聊,统计在线人数...** @param msg 信息*/public void messageType(ChannelHandlerContext ctx, WSMessageDTO msg){EnumBusiness enumerateInstances = EnumBusiness.getEnum(msg.getBusinessType());if (CollectionUtils.isEmpty(strategyConcurrentHashMap)) {log.info("策略实例集合初始化失败,请检查是否正确注入!");}MessageStrategy messageStrategy = strategyConcurrentHashMap.get(enumerateInstances.getBeanName());messageStrategy.messageType(ctx, msg);}}

六.统一响应

注意使用该统一响应对象,所有入栈处理器必须使用即调用方必须是SimpleChannelInboundHandler,详细原因在下文 七.统一输出处理器中

/*** @author YuanJie* @projectName vector-server* @package com.vector.netty.entity* @className com.vector.netty.entity.SocketMessage* @copyright Copyright 2020 vector, Inc All rights reserved.* @date 2023/6/14 19:35*/
@Data
public class WSMessageDTO {/*** 消息发送者*/private Long senderId;/*** 消息接收者/群聊id*/private Long chatId;/*** 消息类型 0文本 1图片 2文件 3视频 4语音 5位置 6名片 7链接 8系统消息* @see com.vector.netty.enums.EnumMessage*/private byte messageType;/*** 业务类型 chat单聊 group群聊 onlineCount在线人数* @see com.vector.netty.enums.EnumBusiness*/private String businessType;/*** 记录每条消息的id*/private Long messageId;/*** 消息内容*/private String message;/*** 消息发送时间*/private LocalDateTime sendTime;/*** 消息接收时间*/private LocalDateTime receiveTime;/*** 最后一条消息内容*/private String lastMessage;/*** 消息状态 0失败 1成功*/private byte code;/*** 封装统一返回格式* @return*/public static TextWebSocketFrame ok(){WSMessageDTO data = new WSMessageDTO();data.setCode((byte) 1);return new TextWebSocketFrame(JacksonInstance.toJson(data)).retain();}public static TextWebSocketFrame ok(WSMessageDTO data){data.setCode((byte) 1);return new TextWebSocketFrame(JacksonInstance.toJson(data)).retain();}public static TextWebSocketFrame error(String message){WSMessageDTO data = new WSMessageDTO();data.setCode((byte) 0);data.setMessage(message);return new TextWebSocketFrame(JacksonInstance.toJson(data)).retain();}
}

七.统一输出处理器

  • 若调用WSMessageDTO方法,必须注意内存泄露
  • 即调用方必须是SimpleChannelInboundHandler<>
  • 严禁使用ChannelInboundHandlerAdapter, 否则将造成严重内存泄露
  • 相应地,必须使用此处的写出@param msg ,释放@param msg 引用
/*** @author YuanJie* @projectName vector-server* @package com.vector.netty.handler* @className com.vector.netty.handler.OutBoundHandler* @copyright Copyright 2020 vector, Inc All rights reserved.* @date 2023/7/24 22:38*/
@Slf4j
@Component
@ChannelHandler.Sharable
public class OutBoundHandler extends ChannelOutboundHandlerAdapter {/*** 若调用WSMessageDTO方法,必须注意内存泄露* 即调用方必须是SimpleChannelInboundHandler<>* 严禁使用ChannelInboundHandlerAdapter, 否则将造成严重内存泄露* 相应地,必须使用此处的写出@param msg ,释放@param msg 引用* @param ctx               the {@link ChannelHandlerContext} for which the write operation is made* @param msg               the message to write* @param promise           the {@link ChannelPromise} to notify once the operation completes* @throws Exception*/@Overridepublic void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {if (msg instanceof FullHttpMessage){log.info("webSocket协议升级成功");// 出栈必须得这样写,不能自定义通信消息,可能把websocket反馈的消息覆盖了。  也不能在最后处理器调ctx.fireChannelRead()ctx.writeAndFlush(msg,promise);return;} else if (msg instanceof TextWebSocketFrame) {log.info("我要给客户端发送消息了。。。。");ctx.writeAndFlush(msg, promise);return;}log.error("OutBoundHandler.write: 消息类型错误");ctx.writeAndFlush(WSMessageDTO.error("服务器内部错误: OutBoundHandler.write()"),promise);ctx.close();}
}

在这里插入图片描述
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/797114.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

CSS-属性

&#x1f4da;详见 W3scholl&#xff0c;本篇只做快速思维索引。 CSS 背景 用于定义元素的背景效果。 background-colorbackground-imagebackground-positionbackground-repeatbackground-attachment background-color background-color 属性指定元素的背景色。 h1 {back…

蓝桥杯 十一届C++A组 字符排序 21分(运行超时)

思路&#xff1a; 1. 此题考查的冒泡排序中的交换次数&#xff0c;其实就是考察当前数与后面的逆序对个数问题。而为了最大利用位数&#xff0c;应当使每一位都不小于后面的字符&#xff0c;否则会造成一次逆序对的浪费&#xff08;贪心&#xff0c;为了使总位数最少&#xff…

c++ 指数搜索(Exponential Search)

该搜索算法的名称可能会产生误导&#xff0c;因为它的工作时间为 O(Log n)。该名称来自于它搜索元素的方式。 给定一个已排序的数组和要 搜索的元素 x&#xff0c;找到 x 在数组中的位置。 输入&#xff1a;arr[] {10, 20, 40, 45, 55} x 45 输出&#xff1a;在索…

什么样的数据库才是开发者需要的

什么样的数据库才是开发者需要的 什么是Serverless数据库Serverless数据库应该关注哪些技术要点DBA的工作会被AI取代吗什么样的数据库是你目前最需要的 其实关于数据库的话题&#xff0c;能聊的很多&#xff0c;作为开发者来说&#xff0c;单说自己接触过的或者曾经用过的数据库…

WCH恒沁单片机-CH32V307学习记录2----FreeRTOS移植

RISC-V 单片机 FreeRTOS 移植 前面用了 5 篇博客详细介绍了 FreeRTOS 在 ARM Cortex-M3 MCU 上是如何运行的。 FreeRTOS从代码层面进行原理分析系列 现在我直接用之前的 RISC-V MCU 开发板子&#xff08;CH32V307VCT6&#xff09;再次对 FreeRTOS 进行移植&#xff0c;其实也…

量身定制:选择能够解决企业问题的六西格玛培训机构

现在的培训机构太多了&#xff0c;都在打着六西格玛管理的旗号&#xff0c;甚至有很多培训机构连六西格玛管理都没有学习过&#xff0c;就敢号称自己是六西格玛管理专家。在这个鱼龙混杂的市场上&#xff0c;很多企业对于选择什么样的培训机构&#xff0c;以及如何选择一家靠谱…

C和C++有哪些异同

C和C是两种非常相似但也有一些重要区别的编程语言。以下是它们之间的主要异同点&#xff1a; 相同点&#xff1a; 基本语法&#xff1a;C是C语言的超集&#xff0c;大部分C语言代码可以在C中直接编译运行。 基本数据类型&#xff1a;两者都具有相似的基本数据类型&#xff0c…

AOP实现接口加解密

接口加解密&#xff08;主要实现分为 请求参数解密&#xff0c;返回参数加密 两个操作&#xff09; 玩一下&#xff0c; 开搞&#xff0c;开搞&#xff01;&#xff01;&#xff01; 目录 实现思路引入maven核心代码自定义注解AOP切面测试方法测试结果 实现思路 首先加解密用的…

Vue3(domdiff)最长递归子序列求解简易版(超简单)

Vue3&#xff08;domdiff&#xff09;最长递归子序列求解简易版 ⚠️ 关键词&#xff08;每一个都需要理解&#xff09;js 代码实现写完感想欢迎关注 ⚠️ 关键词&#xff08;每一个都需要理解&#xff09; 动态规划&#xff08;O(N^2)&#xff09;&#xff08;不提倡&#xf…

python接入AI 实现微信自动回复

import numpy as np # 引入numpy库&#xff0c;目的是将读取的数据转换为列表 import pandas as pd # 引入pandas库&#xff0c;用来读取csv数据 from uiautomation import WindowControl # 引入uiautomation库中的WindowControl类&#xff0c;用来进行图像识别和模拟操作 i…

windows组播发不出去解决办法

由于开启了虚拟网卡&#xff0c;安装VMWare虚拟化软件&#xff0c;可能会通过虚拟网卡发送组播&#xff0c;需要禁用虚拟化网卡。

二分法题集1

1 二分查找 分析&#xff1a; 这是一道很简单的二分法题&#xff0c;定义两个指针和中间值middle&#xff0c;判断middle对应数组值与目标值的大小关系&#xff0c;从而对left和right进行修改。由于太过基础&#xff0c;代码简单基础就不多赘述。 目录 1 二分查找 分析&…

干货 | 探索CUTTag:从样本到文库,实验步步为营!

CUT&Tag&#xff08;Cleavage Under Targets and Tagmentation&#xff09;是一种新型DNA-蛋白互作研究技术&#xff0c;主要用于研究转录因子或组蛋白修饰在全基因组上的结合或分布位点。相比于传统的ChIP-seq技术&#xff0c;CUT&Tag反应在细胞内进行&#xff0c;创新…

51单片机入门:LED点阵屏

LED点阵屏介绍 LED点阵屏由若干个独立的LED组成&#xff0c;LED以矩阵的形式排列&#xff0c;以灯珠亮灭来显示文字、图片、视频等。LED点阵屏广泛应用于各种场合&#xff0c;如&#xff1a;广告屏、公告牌等。 分类&#xff1a; 按颜色&#xff1a;单色、双色、全彩&#x…

nuxt3配置打包静态资源在某一路径下

export default defineNuxtConfig({app: {baseURL: "/account-project"} });

ruoyi-nbcio-plus基于vue3的flowable流程设计器组件的升级修改

更多ruoyi-nbcio功能请看演示系统 gitee源代码地址 前后端代码&#xff1a; https://gitee.com/nbacheng/ruoyi-nbcio 演示地址&#xff1a;RuoYi-Nbcio后台管理系统 http://122.227.135.243:9666/ 更多nbcio-boot功能请看演示系统 gitee源代码地址 后端代码&#xff1a…

银行ITSS体系下低代码运维体系实践分享

前言 自2021年中国人民银行发布《金融科技发展规划&#xff08;2022-2025年&#xff09;》以来&#xff0c;商业银行迈入数字化转型的高阶阶段。在此背景下&#xff0c;为了进一步提高金融科技的管理水平&#xff0c;商业银行需要改变传统金融运维模式&#xff0c;对已有运维体…

红黑树插入机制深度剖析与实践指南

红黑树插入机制深度剖析与实践指南 一、红黑树的基本概念二、插入操作的初步2.1 RB-INSERT-FIXUP过程2.2 循环的不变性2.2.1 情况1&#xff1a;叔节点是红色2.2.2情况2和情况3&#xff1a;叔节点是黑色 三、插入操作的复杂性分析四、伪代码4.1 RB-INSERT 过程4.2 RB-INSERT-FIX…

理解PostgreSQL中的postmaster.pid

在PG中&#xff0c;一个简要的体系结构图可以大致画成下边的样子&#xff1a; Server端基本上分成backend process和若干background process。这些process都是一个名为postmaster进程的子进程。而postmaster则是postgres进程的别名。 进程概况 [14:42:08-postgrescentos1:/pg…

2024.4.2-day07-CSS 盒子模型(显示模式、盒子模型)

个人主页&#xff1a;学习前端的小z 个人专栏&#xff1a;HTML5和CSS3悦读 本专栏旨在分享记录每日学习的前端知识和学习笔记的归纳总结&#xff0c;欢迎大家在评论区交流讨论&#xff01; 文章目录 作业 2024.4.2 学习笔记CSS标签元素显示模式1 块元素2 行内元素3 行内块元素4…