使用net.Listen创建TCP服务并监听连接;2. 通过Accept接收客户端连接,每个连接用goroutine处理;3. 在循环中调用conn.Read读取数据,注意处理TCP流式特性导致的粘包/分包;4. 可结合bufio.Scanner或长度前缀解决消息边界问题;5. 设置SetReadDeadline避免长时间阻塞;6. 正确关闭连接以管理资源。

在Go语言中编写TCP Server时,接收客户端数据是一个核心操作。Golang通过标准库net包提供了简单而强大的网络编程支持。要正确地在TCP Server中接收数据,关键在于理解TCP的流式特性,并合理处理数据读取过程。
建立TCP Server并监听连接
使用net.Listen函数创建一个监听套接字,等待客户端连接。一旦有客户端连接成功,会返回一个*net.TCPConn类型的连接对象,后续的数据收发都基于这个连接。
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer listener.Close()
for {
conn, err := listener.Accept()
if err != nil {
log.Print(err)
continue
}
go handleConnection(conn)
}
从连接中读取数据
TCP是面向字节流的协议,没有消息边界,因此不能假设一次Read调用就能完整读取一条消息。通常的做法是在单独的goroutine中循环读取数据。
func handleConnection(conn net.Conn) {
defer conn.Close()
buffer := make([]byte, 1024) // 定义缓冲区
for {
n, err := conn.Read(buffer)
if err != nil {
log.Print("Connection closed or error:", err)
return
}
// 处理接收到的有效数据(前n个字节)
data := buffer[:n]
process(data)
}}
立即学习“go语言免费学习笔记(深入)”;
注意: conn.Read返回的是实际读取的字节数n,必须使用buffer[:n]来获取有效数据。
处理粘包与分包问题
由于TCP的流特性,多个发送可能被合并成一次接收(粘包),或一个发送被拆分成多次接收(分包)。解决方法包括:
- 固定长度消息: 每条消息固定大小,每次读取指定长度
-
特殊分隔符: 如使用换行符
\n分隔消息,配合bufio.Scanner - 带长度前缀: 消息头部包含数据长度,先读长度再读内容
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
message := scanner.Text()
process([]byte(message))
}设置读取超时避免阻塞
为防止连接长时间空闲导致资源浪费,可设置读取超时:
func handleConnection(conn net.Conn) {
defer conn.Close()
for {
conn.SetReadDeadline(time.Now().Add(30 * time.Second))
buffer := make([]byte, 1024)
n, err := conn.Read(buffer)
if err != nil {
if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
log.Print("Read timeout")
} else {
log.Print("Read error:", err)
}
return
}
process(buffer[:n])
}}
立即学习“go语言免费学习笔记(深入)”;
基本上就这些。Golang的TCP数据接收不复杂但容易忽略细节,重点是正确管理连接生命周期、处理流式数据和异常情况。










