Go语言通过net包实现TCP通信，首先创建服务器监听端口并用goroutine处理连接，客户端使用Dial建立连接发送数据。为解决TCP粘包问题，推荐消息头携带长度信息的方式。同时需设置读写超时防止资源泄漏，并加入异常重连机制提升稳定性。示例展示了基础通信流程与关键处理技巧。
在Go语言中实现TCP客户端与服务器通信非常直观，得益于标准库net包的强大支持。通过简单的API调用即可建立稳定的长连接，适用于即时通讯、数据同步等场景。本文将带你一步步实现一个基础但完整的TCP通信示例，并介绍常见问题的处理方式。
建立TCP服务器
使用net.Listen函数监听指定地址和端口，等待客户端连接。每个新连接通过goroutine独立处理，保证并发性能。
示例代码：
func startServer() {
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal("监听失败:", err)
}
defer listener.Close()
log.Println("服务器启动，监听 :8080")
for {
conn, err := listener.Accept()
if err != nil {
log.Println("接受连接错误:", err)
continue
}
go handleClient(conn)
}
}
func handleClient(conn net.Conn) {
defer conn.Close()
buffer := make([]byte, 1024)
for {
n, err := conn.Read(buffer)
if err != nil {
log.Println("读取数据出错:", err)
return
}
message := string(buffer[:n])
log.Printf("收到: %s", message)
// 回显消息
conn.Write([]byte("echo: " + message))
}
}
实现TCP客户端
客户端使用net.Dial连接服务器，发送请求并接收响应。同样可以持续读取服务端返回的数据。
立即学习“go语言免费学习笔记（深入）”；
示例代码：
func startClient() {
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
log.Fatal("连接失败:", err)
}
defer conn.Close()
// 发送消息
conn.Write([]byte("Hello, Server!"))
// 接收回响
buffer := make([]byte, 1024)
n, err := conn.Read(buffer)
if err != nil {
log.Println("接收数据失败:", err)
return
}
log.Printf("服务器回复: %s", string(buffer[:n]))
}
处理粘包与分包问题
TCP是流式协议，多次发送的数据可能被合并或拆分，导致“粘包”问题。解决方法包括：
- 固定消息长度：每次发送定长数据，接收时按长度截取
- 特殊分隔符：如换行符\n，接收端按分隔符切分
- 头部携带长度：前几个字节表示后续数据长度，先读头再读体
推荐使用第三种方式，灵活性高且适合复杂场景。例如，前4字节为uint32表示body长度，之后才是实际内容。
连接超时与异常处理
生产环境中必须考虑网络不稳定情况。可设置读写超时防止goroutine泄漏：
conn.SetReadDeadline(time.Now().Add(10 * time.Second))
当超时或连接中断时，Read会返回error，需及时退出循环并关闭连接。同时建议加入重连机制提升客户端健壮性。
基本上就这些。Golang的TCP编程简洁高效，配合goroutine轻松应对高并发。只要注意数据边界处理和连接管理，就能构建稳定可靠的网络服务。
