在Go中实现TCP通信需处理粘包问题,使用net包建立连接,通过长度头封包(如4字节长度+数据)实现消息边界,发送前写入数据长度,接收时先读长度再读数据体,结合ReadFull确保完整读取,每次收发均封装为sendPacket和readPacket函数,配合json或protobuf序列化,并设置超时防止阻塞,从而实现可靠的TCP通信。

在Go语言中实现TCP数据包的发送与接收,关键在于理解TCP是面向流的协议,不保留消息边界。这意味着你发送的多个数据包可能被合并接收,或一个大包被拆分成多次接收。因此,在实际开发中必须自行处理“粘包”问题。
使用net包建立TCP连接
Go标准库net提供了完整的TCP支持。服务端通过Listen监听端口,客户端用Dial发起连接。
服务端示例:
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer listener.Close()
for {
conn, err := listener.Accept()
if err != nil {
continue
}
go handleConn(conn)
}
客户端示例:
立即学习“go语言免费学习笔记(深入)”;
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
log.Fatal(err)
}
defer conn.Close()
解决粘包:封包与拆包
TCP本身无消息边界,需在应用层定义协议格式。常见方法是在数据前加长度头。
客户端: 1.支持商品新品上架,特价促销,以及推荐商品等图文展示。 2.支持系统公告,商品的快速搜索,以及在线客服实时沟通,联系方式发布等 3.支持多收货地址管理,灵活选择配送方式。 4.提交订单前,可以随时调整订单商品,还支持提交特殊需求留言等功能。 5.支持查询原始订单数据,方便与发货方进行订单核对,以及订单追溯。 6.支持客户留言,随时与网站管理员沟通联系。 管理端: 1.管理端支持实时查询
封包结构: [4字节长度][实际数据]
- 发送前先写入数据长度(如uint32),再写数据体
- 接收时先读4字节长度,再按长度读取完整数据
发送函数示例:
func sendPacket(conn net.Conn, data []byte) error {
var buf [4]byte
binary.BigEndian.PutUint32(buf[:], uint32(len(data)))
_, err := conn.Write(buf[:])
if err != nil {
return err
}
_, err = conn.Write(data)
return err
}
接收函数示例:
func readPacket(conn net.Conn) ([]byte, error) {
var buf [4]byte
_, err := io.ReadFull(conn, buf[:])
if err != nil {
return nil, err
}
length := binary.BigEndian.Uint32(buf[:])
data := make([]byte, length)
_, err = io.ReadFull(conn, data)
return data, err
}
完整通信流程建议
- 连接建立后,所有发送都走sendPacket封装
- 接收循环中持续调用readPacket获取完整消息
- 可结合json或protobuf序列化结构体数据
- 设置合理的超时(SetReadDeadline)防止阻塞
基本上就这些。只要处理好长度头和分次读取,Go的TCP通信稳定可靠,适合做微服务通信、自定义协议传输等场景。关键是不能假设一次Read就拿到完整消息。









