由于网络传输等原因,原始发出的消息和收到的消息可能不一致。可能多条消息粘在一起变成一条,也可能一条消息分了几条。本篇介绍几种解决方案。
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 ; //继续读取
}