Golang实现TCP客户端与服务端通信_技术教程

net.Listen("tcp", ":8080") 创建 TCP 服务端监听器，需指定网络类型和地址格式，配合 listener.Accept() 和 goroutine 处理并发连接，并注意错误处理、资源释放与协议分包。

怎么用 net.Listen 创建 TCP 服务端

Go 的 net.Listen 是启动 TCP 服务端的第一步，它返回一个 net.Listener 接口，后续靠它接收连接。注意必须指定完整的网络类型和地址格式，常见错误是写成 "localhost:8080" 或漏掉 "tcp"。

正确写法是 "tcp" + ":端口号"（监听所有网卡）或 "127.0.0.1:端口号"（仅本地）。绑定已占用端口会 panic，建议加错误检查。

listener, err := net.Listen("tcp", ":8080")
if err != nil {
    log.Fatal("无法启动服务端：", err)
}
defer listener.Close()

net.Listen("tcp4", ...) 和 net.Listen("tcp6", ...) 可分别强制 IPv4/IPv6，避免双栈行为不一致
Windows 上某些端口（如 1–1023）需要管理员权限
如果程序要支持快速重启，可设置 SO_REUSEADDR：用 net.ListenConfig{Control: controlFunc} 配合 syscall.SetsockoptInt

如何安全地 accept 并处理多个 TCP 连接

listener.Accept() 是阻塞调用，每次返回一个 net.Conn。不加 goroutine 直接处理会导致新连接被卡住——这是新手最常踩的坑。必须为每个连接启一个 goroutine，但要注意连接生命周期管理，防止 goroutine 泄漏。

for {
    conn, err := listener.Accept()
    if err != nil {
        log.Println("接受连接失败：", err)
        continue // 不要 break，否则服务停止
    }
    go handleConnection(conn) // 每个连接独立协程
}

handleConnection 函数里务必用 defer conn.Close()，否则连接资源不释放
若需限制并发连接数，可在 accept 前加计数器 + channel 控制，或用 semaphore 库
客户端断开时 conn.Read 会返回 io.EOF，不是错误，应正常退出该 goroutine

TCP 客户端怎么 dial 并可靠收发数据

net.Dial 是客户端建立连接的入口，和服务端一样，参数是 "tcp" + "host:port"。常见错误是传入未解析的域名（如 "example.com:80"）且 DNS 不通，导致超时久；或没设超时，卡死在 dial 阶段。

conn, err := net.Dial("tcp", "127.0.0.1:8080")
if err != nil {
    log.Fatal("连接失败：", err)
}
defer conn.Close()
,  = conn.Write([]byte("Hello Server\n"))
buf := make([]byte, 1024)
n, _ := conn.Read(buf)
log.Printf("收到：%s", string(buf[:n]))

生产环境强烈建议用 net.DialTimeout 或 &net.Dialer{Timeout: 5 * time.Second} 显式控制连接超时
TCP 是字节流，Read 不保证一次读完所有数据，也不保证一次只读一条消息；需自行按协议分包（比如加长度头、换行符分隔）
不要混用 fmt.Fprintln(conn, ...) 和 conn.Write，底层缓冲行为可能不一致

为什么 Read/Write 经常卡住或丢数据

根本原因在于 TCP 没有“消息边界”概念。你调用一次 Write，对方可能分多次 Read 到；也可能一次 Read 拿到多条消息。没有应用层协议约定，通信必然错乱。

简单场景可用换行符分隔（\n），复杂场景推荐固定头长+内容长度方式。Go 标准库的 bufio.Scanner 默认按行扫描，适合文本协议；bufio.Reader.ReadString('\n') 更可控。

scanner := bufio.NewScanner(conn)
for scanner.Scan() {
    line := scanner.Text()
    if line == "quit" {
        break
    }
    conn.Write([]byte("Echo: " + line + "\n"))
}

scanner.Scan() 内部会自动处理缓冲和换行，但单次读取上限默认 64KB，超长行会报 scanner.Err()；可通过 scanner.Buffer(make([]byte, 64), 1 调大
二进制协议必须自己解析 header：先读 4 字节长度，再按该长度读 payload
别依赖 conn.SetReadDeadline 后就不管了——每次 Read 前都得重设，否则第二次就超时