物联网开发tcp协议之—

物联网开发tcp协议之——netty拆包问题

本文主要是介绍物联网开发tcp协议之——netty拆包问题，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1.前言

tcp协议是物联网开发中比较常见的一种通信协议，而netty则是一tcp通信协议中一个比较优秀的框架。tcp协议是一种长连接的协议，是流式传输的，开发过程中最长遇见的问题就是拆包粘包问题。我目前对接过的物联网系列有智能家居设备，433酒店智控设备，充电桩设备，安防设备，传感器（温度，噪声等等类的），对接设备的过程中有的是和厂家对接，这种需要完全根据厂家的协议走，有的是公司自研的这和设备端嵌入式工程师商议协议即可。对接过程中遇到的一个最大问题就是拆包粘包的过程。下面就目前我遇到的协议中做一个总结：

1.常规协议，netty常规编解码器

使用Netty实现的tcp服务端，由于tcp是流式传输的，故需要选用一个解码器对流式消息进行解码和包分隔，以防收到不正确的包。例如LineBasedFrameDecoder，LengthFieldBasedFrameDecoder，DelimiterBasedFrameDecoder等常用解码器。

比如对接的智能家居设备是公司自研的设备，嵌入式工程师也是我们自己公司的，定义协议的时候,以固定报文结尾，假如固定报文为：0D0ABBBB,那么可使用netty编解码器ByteArrayDecoder，ByteArrayEncoder，附上代码：

public class HwServerInitializer extends ChannelInitializer<SocketChannel> {
//@Overrideprotected void initChannel(SocketChannel ch) {ChannelPipeline pipeline = ch.pipeline();ByteBuf delimiter = Unpooled.copiedBuffer(new byte[]{0x0D, 0x0A, (byte)0xBB, (byte)0xBB});// 以("\n")为结尾分割的 解码器pipeline.addLast("framer", new DelimiterBasedFrameDecoder(10000, delimiter));// 字符串解码 和 编码pipeline.addLast("decoder", new ByteArrayDecoder());pipeline.addLast("encoder", new ByteArrayEncoder());// 自己的逻辑Handlerpipeline.addLast("handler", new HwServerHandler());}
}

2.不规则协议

有些协议是用常规的编解码器解决不了的，比如下面这一个安防类的协议，

包很长，常规的编解码器解决不了，一直拆包粘包，那么就需要自定义编解码器了，附上自定义解码器的代码

public class MyMessageDecode extends ByteToMessageDecoder {private static final Logger log = LoggerFactory.getLogger(MyMessageDecode.class);@Overrideprotected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {// 标记一下当前的readIndex的位置byteBuf.markReaderIndex();byte[] magic = new byte[5];byteBuf.readBytes(magic);byte[] len = new byte[4];byteBuf.readBytes(len);int lens=Integer.parseInt(MyStringUtil.byteArrayToASCII(len));if (byteBuf.readableBytes()<lens-10){byteBuf.resetReaderIndex();return;}byte[] data = new byte[lens-9];byteBuf.readBytes(data);byte[] mesages=new byte[lens];System.arraycopy(magic, 0, mesages, 0, 5);System.arraycopy(len, 0, mesages, 5, 4);System.arraycopy(data, 0, mesages, 9, lens-9);// byteBuf.resetReaderIndex();list.add(mesages);}
}

拆包粘包问题解决