如何使用Golang实现TCP服务器_监听端口并接收客户端数据

P粉602998670 2025-12-22 00:00:00 次阅读

Go基础TCP服务器需用net.Listen监听端口，Accept阻塞等待连接，每个conn交由goroutine处理；Read需循环读取至io.EOF，注意TCP无消息边界。

用 Go 实现一个基础 TCP 服务器非常简单，核心是 net.Listen 监听端口，再用 conn.Read 接收客户端发来的数据。

监听指定端口并接受连接

使用 net.Listen("tcp", ":8080") 可在本地 8080 端口启动监听。注意地址格式为 "host:port"，若 host 省略（即 ":8080"），表示监听所有可用网卡的该端口。

监听失败会返回 error，需检查是否端口被占用或权限不足（如 Linux 下 1024 以下端口需 root）
listener.Accept() 是阻塞调用，等待客户端建立连接，成功后返回一个 net.Conn 实例

读取客户端发送的数据

每个连接对应一个独立的 conn，可通过 conn.Read([]byte) 读取数据。Go 的 Read 不保证一次读完全部内容，它返回实际读到的字节数和 error。

建议用固定大小缓冲区（如 1024 字节），循环读直到 err == io.EOF（表示对端关闭连接）
收到的数据是原始字节，可转成 string 打印或进一步解析
注意：TCP 是流式协议，无消息边界，如果客户端发了多次 Write，服务端可能一次 Read 就拿到拼接后的数据

处理多个客户端连接

单个连接处理完就结束了，要支持并发连接，必须把每个 conn 交给 goroutine 处理。

在 for 循环中对每个 Accept() 到的 conn 启动 goroutine：go handleConnection(conn)
避免在主 goroutine 中直接处理 conn，否则后续连接会被阻塞
可在 handleConnection 内部实现读、写、超时控制或协议解析逻辑

完整示例代码片段

以下是最简可用的 TCP 服务器骨架：

package main

import (
    "fmt"
    "io"
    "log"
    "net"
)

func main() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()

    fmt.Println("Server listening on :8080")

    for {
        conn, err := listener.Accept()
        if err != nil {
            log.Printf("Accept error: %v", err)
            continue
        }

        go func(c net.Conn) {
            defer c.Close()
            buf := make([]byte, 1024)
            for {
                n, err := c.Read(buf)
                if n > 0 {
                    fmt.Printf("Received: %s", string(buf[:n]))
                    // 可选：回传响应
                    c.Write([]byte("OK\n"))
                }
                if err == io.EOF {
                    fmt.Println("Client disconnected")
                    break
                }
                if err != nil {
                    log.Printf("Read error: %v", err)
                    break
                }
            }
        }(conn)
    }
}