TCP粘包/拆包java
TCP是个"流"协议,所谓流,就是没有界限没有分割的一串数据。TCP会根据缓冲区的实际状况进行包划分,一个完整的包可能会拆分红多个包进行发送,也用可能把多个小包封装成一个大的数据包发送。这就是TCP粘包/拆包。spa
TCP粘包/拆包问题说明code
客户端要给服务端发送数据,假如为两个数据包。ip
可能的状况以下:get
问题产生的缘由:it
1-应用程序write写入的字节大小 大于 套接字发送缓冲区大小pip
2-进行MSS大小的TCP分段ast
3-以太网帧的payload大于MTU进行IP分片class
TCP粘包/拆包解决办法sed
1-定长消息,例如每一个报文长度固定,不够补空格
2-使用回车换行符分割,在包尾加上分割符,例如Ftp协议
3-消息分割,头为长度(消息总长度或消息体长度),一般头用一个int32表示
4-复杂的应用层协议
Netty对于读写半包的的处理
提供多种解码器用于处理半包,如 LineBasedFrameDecoder、DelimiterBasedFrameDecoder、FixedLengthFrameDecoder、ProtobufVarint32FrameDecoder、ByteToMessageDecoder以及LengthFileldBasedFrameDecoder等等。
下面的例子为 我在 ProtoBuf中的使用
//decoder //1-读半包的解码器 ch.pipeline().addLast(new LengthFieldBasedFrameDecoder(1024, 0, 4, 0, 4)); //2-进行消息解码 ch.pipeline().addLast(new ProtobufDecoder(BoxAuthReqProto.AuthRequest.getDefaultInstance())); //encoder ch.pipeline().addLast(new LengthFieldPrepender(4)); ch.pipeline().addLast(new ProtobufEncoder());