使用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()
<p>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) // 定义缓冲区
<pre class="brush:php;toolbar:false;">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]来获取有效数据。
Golang Uber Dig
下载
使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等
处理粘包与分包问题
由于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()
<pre class="brush:php;toolbar:false;">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数据接收不复杂但容易忽略细节，重点是正确管理连接生命周期、处理流式数据和异常情况。
