当前位置：首页 > 文章列表 > Golang > Go教程 > Golang如何在TCP Server中接收数据_Golang TCP Server数据接收方法

Golang如何在TCP Server中接收数据_Golang TCP Server数据接收方法

2025-12-21 10:54:15 0浏览收藏

推广推荐

支持 PC / 移动端，安全直达

有志者，事竟成！如果你在学习Golang，那么本文《Golang如何在TCP Server中接收数据_Golang TCP Server数据接收方法》，就很适合你！文章讲解的知识点主要包括，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

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

Golang如何在TCP Server中接收数据_Golang TCP Server数据接收方法

在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)
}</p>

从连接中读取数据

TCP是面向字节流的协议，没有消息边界，因此不能假设一次Read调用就能完整读取一条消息。通常的做法是在单独的goroutine中循环读取数据。

func handleConnection(conn net.Conn) {
    defer conn.Close()
    buffer := make([]byte, 1024) // 定义缓冲区
<pre class="brush:php;toolbar:false"><code>for {
    n, err := conn.Read(buffer)
    if err != nil {
        log.Print("Connection closed or error:", err)
        return
    }

    // 处理接收到的有效数据（前n个字节）
    data := buffer[:n]
    process(data)
}</code>

}

注意： 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()
<pre class="brush:php;toolbar:false"><code>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])
}</code>

}

基本上就这些。Golang的TCP数据接收不复杂但容易忽略细节，重点是正确管理连接生命周期、处理流式数据和异常情况。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~