Go 处理粘包拆包

作者: 太阳上的雨天 分类: Go 发布时间: 2022-11-05 11:07

1. 什么是粘包?

发送方发送的若干数据到接受放接受时粘成了一个包。接受方有一个缓冲区,在缓冲区中多条数据连在了一起。

2. 粘包发生在哪个协议中?

只有TCP有粘包现象,UDP没有

3. 为什么UDP没有粘包想象?

因为UDP无连接的不可靠的传输协议(适合频繁发送较小的数据包),他不会对数据包进行合并发送(也就没有Nagle算法之说了) ,他直接是一端发送什么数据,直接就发出去了 ,既然他不会对数据合并,每一个数据包都是完整的(数据+UDP头+IP头等等发一次数据封装一次)也就没有粘包一说

4. TCP为什么会出现粘包想象

TCP(transport control protocol,传输控制协议)是面向连接的,面向流的,提供高可靠性服务。
收发两端(客户端和服务器端)都要有一一成对的socket,因此,发送端为了将多个发往接收端的包,更有效的发到对方,使用了优化方法(Nagle算法),将多次间隔较小且数据量小的数据,合并成一个大的数据块,然后进行封包。这样,接收端,就难于分辨出来了,必须提供科学的拆包机制。 即面向流的通信是无消息保护边界的

5. TCP出现粘包、拆包的几种情况?

  • 发送端写入的数据大于接收端套接字(socket)缓冲区的大小,会发生拆包
  • 发送端写入的数据小于接收端套接字(socket)缓冲区的大小,网络会将多次写入的数据同时发送出去,会发生粘包
  • 进行MSS(最大报文长度)大小的TCP分段,当TCP报文长度-TCP头部长度>MSS的时候将发生拆包
  • 接收端未能及时读取套接字(socket)缓冲区中的数据,也会发生粘包

6. 如何处理粘包、拆包

  • 使用带消息头的协议,头部写入包长度,然后再读取包内容
  • 设置定长消息,每次读取定长的消息内容,长度不够时空位补全(固定字段)
  • 设置消息边界,服务端从网络流中按消息边界分离出消息内容。比如\n
  • Json、protobuf协议框架

7. 使用自定义消息格式处理粘包和拆包的问题

  1. 首先会写入一个自定义的消息头
binary.Write(bytesBuffer, binary.BigEndian, []byte(MsgHeader))
  1. 写入消息内容的长度
clen := int32(len([]byte(content)))
binary.Write(bytesBuffer, binary.BigEndian, clen)
  1. 写入消息
binary.Write(bytesBuffer, binary.BigEndian, []byte(content))
  1. 拆包 先读自定义的消息头,
io.ReadFull(bytesBuffer, headBuf)
  1. 在读指定长度的消息
io.ReadFull(bytesBuffer, lbuf)
io.ReadFull(bytesBuffer, body)

完整代码地址: https://github.com/jeffcail/tcp-unpack

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注