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 ;    //继续读取
		}

 

 

标签：Netty,pipeline,ch,addLast,长度,粘包,消息,new,半包
来源： https://blog.csdn.net/wangb_java/article/details/108381960