Go语言网络编程实战指南（详解TCP粘包与拆包问题及解决方案）

为什么会出现粘包/拆包？

原因主要有两个：

1. 发送方缓冲区合并：TCP 为了提高效率，可能会将多个小数据包合并成一个大的 TCP 段发送；
2. 接收方读取不及时：接收方没有及时从缓冲区读取数据，导致后续数据追加到已有数据末尾。

解决方案：自定义协议格式

最常用且可靠的方法是：在应用层设计自己的协议格式。通常采用“长度 + 数据”的方式，即每条消息前附加一个固定长度的头部，用于表示后续数据的字节数。

方案示例：4 字节长度头 + JSON 消息体

我们约定每条消息结构如下：

// [4字节大端整数][JSON字符串]// 例如：00 00 00 1A {"name":"Alice","msg":"Hi"}

服务端代码（处理粘包）

package mainimport (	"encoding/binary"	"encoding/json"	"fmt"	"io"	"net")type Message struct {	Name string `json:"name"`	Msg  string `json:"msg"`}func handleConn(conn net.Conn) {	defer conn.Close()	buffer := make([]byte, 1024)	var msgBuffer []byte // 用于缓存未处理完的数据	for {		n, err := conn.Read(buffer)		if err != nil {			if err == io.EOF {				fmt.Println("Client disconnected")			} else {				fmt.Println("Read error:", err)			}			return		}		// 将新读取的数据追加到缓存		msgBuffer = append(msgBuffer, buffer[:n]...)		// 循环解析完整消息		for len(msgBuffer) >= 4 {			// 读取消息长度（大端）			msgLen := binary.BigEndian.Uint32(msgBuffer[:4])			// 如果缓存中数据不足一条完整消息，跳出等待下次读取			if uint32(len(msgBuffer)) < 4+msgLen {				break			}			// 提取完整消息体			data := msgBuffer[4 : 4+msgLen]			var msg Message			if err := json.Unmarshal(data, &msg); err != nil {				fmt.Println("Unmarshal error:", err)				continue			}			fmt.Printf("Received: %+v\n", msg)			// 更新缓存：移除已处理的消息			msgBuffer = msgBuffer[4+msgLen:]		}	}}func main() {	listener, err := net.Listen("tcp", ":8080")	if err != nil {		panic(err)	}	defer listener.Close()	fmt.Println("Server listening on :8080")	for {		conn, err := listener.Accept()		if err != nil {			fmt.Println("Accept error:", err)			continue		}		go handleConn(conn)	}}

客户端代码（发送带长度头的消息）

package mainimport (	"encoding/binary"	"encoding/json"	"net")type Message struct {	Name string `json:"name"`	Msg  string `json:"msg"`}func main() {	conn, err := net.Dial("tcp", "localhost:8080")	if err != nil {		panic(err)	}	defer conn.Close()	msgs := []Message{		{"Alice", "Hello!"},		{"Bob", "How are you?"},		{"Charlie", "I'm fine, thanks!"},	}	for _, m := range msgs {		data, _ := json.Marshal(m)		msgLen := uint32(len(data))		// 先写4字节长度（大端）		lenBuf := make([]byte, 4)		binary.BigEndian.PutUint32(lenBuf, msgLen)		conn.Write(lenBuf)		// 再写消息体		conn.Write(data)	}}

关键点总结

- 使用 Go语言 TCP粘包处理 技术，核心在于自定义协议；
- 长度字段建议使用 大端序（Big Endian），便于跨平台兼容；
- 接收端必须使用 缓冲区缓存未完成消息，不能假设一次 read 就能读完一条完整消息；
- 此方法适用于所有需要可靠传输的 Go语言网络通信 场景。

结语

掌握 Go TCP拆包 与粘包处理，是构建高性能、高可靠网络服务的基础。通过本文的示例，即使是初学者也能快速上手。建议你动手运行上述代码，观察输出结果，加深理解。

关键词回顾：Go语言 TCP粘包处理、Go网络编程、Go TCP拆包、Go语言网络通信。