Netty (7)-半包和粘包

由于网络传输等原因,原始发出的消息和收到的消息可能不一致。可能多条消息粘在一起变成一条,也可能一条消息分了几条。本篇介绍几种解决方案。

Netty (7)-半包和粘包

LineBasedFrameDecoder换行符分隔

netty预设了一个解码器LineBasedFrameDecoder,参数为消息最大长度。收到消息时,会检查其中的换行符,将每个换行符之间的内容作为一条消息,交给MyHandler处理,客户端发过来的消息中必须包含换行符。

							ch.pipeline().addLast(new LineBasedFrameDecoder(1024));
							ch.pipeline().addLast(new MyHandler());

DelimiterBasedFrameDecoder自定义分隔符

可以配置自定义的分隔符,比如这里使用 | 竖线来作分隔符。

                            ByteBuf delimiter = Unpooled.copiedBuffer("|".getBytes());
							ch.pipeline().addLast(new DelimiterBasedFrameDecoder(1024,delimiter));
							ch.pipeline().addLast(new MyHandler());

FixedLengthFrameDecoder固定长度

强制每条消息长度,这里设6,每6个字符认定为一条消息。

							ch.pipeline().addLast(new FixedLengthFrameDecoder(6));
							ch.pipeline().addLast(new MyHandler());

LengthFieldBasedFrameDecoder自定义长度

通常消息长度不会是固定的,可以将每条消息长度放到消息内容中,由服务器动态识别长度。如下

							ch.pipeline().addLast(new LengthFieldBasedFrameDecoder(1024,0,1));
							ch.pipeline().addLast(new MyHandler());
  • 参数1:1024是消息最大长度
  • 参数2:0是指长度参数的位置,即消息中第一个字节开始,用来表示消息的长度
  • 参数3:1是指长度参数的自身的长度,即1个字节。

一个字节用2个16进制表示,假如有16进制消息 03 aa bb cc,那么第一个字节03表示消息长度有3个字节,消息内容即aa bb cc。

自定义解码解决半包粘包

可以用自定义的解码器去判断消息的完整性,如果已经读到完整消息,就加入out中进行业务处理,否则就return继续读取。

public class MyDecoder extends ByteToMessageDecoder{
	
	@Override
	protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
		if("自定义判断,读取到了完整消息") {
			out.add("完整消息对象");
		}else {
			return ;    //继续读取
		}

 

 

上一篇:.NET中的SqlBulkCopy类用法


下一篇:threejs学习(十五)glb/gltf格式模型文件压缩--gltf-pipeline