17370845950

Go net包原生支持TCP，需正确处理地址格式、超时控制、读写边界、goroutine并发及连接生命周期；常见错误包括非法地址、忽略error、阻塞读写、未并发处理连接等。

Go 的 net 包原生支持 TCP，无需第三方库就能写出稳定、高并发的客户端和服务器。关键在于理解连接生命周期、阻塞/非阻塞行为，以及如何正确处理读写边界。

用 net.Listen 启动 TCP 服务器时必须指定地址格式

常见错误是传入不合法的地址字符串，比如漏掉端口、用错协议前缀或绑定到不可用地址：

• "localhost:8080" 合法，但只接受本机回环连接
• ":8080" 合法，监听所有网卡（0.0.0.0:8080），适合外部访问
• "127.0.0.1:8080" 合法，等价于 "localhost:8080"
• "8080" 非法：缺少冒号和主机部分，net.Listen 会返回 "address 8080: missing port in address"
• "tcp://:8080" 非法：协议前缀应为 "tcp"，不是 "tcp://"；正确写法是 net.Listen("tcp", ":8080")

启动后务必检查 error，否则监听失败却无感知：

ln, err := net.Listen("tcp", ":8080")
if err != nil {
    log.Fatal(err) // 不要忽略
}
defer ln.Close()

客户端用 net.Dial 连接时超时控制不能靠 time.Sleep

net.Dial 默认阻塞，直到连接建立或系统级超时（可能长达数分钟）。生产环境必须显式设置超时，否则一个卡住的连接会让 goroutine 永久挂起。

• 用 net.DialTimeout 最简单，但仅支持固定超时
• 更推荐用 net.Dialer 配合 Context，便于取消和复用
• 注意：DNS 解析也计入超时，若域名解析慢，DialContext 会一并等待

示例（带 5 秒连接超时）：

dialer := &net.Dialer{
    Timeout:   5 * time.Second,
    KeepAlive: 30 * time.Second,
}
conn, err := dialer.Dial("tcp", "localhost:8080")
if err != nil {
    log.Printf("connect failed: %v", err)
    return
}
defer conn.Close()

读写数据必须处理 io.EOF 和部分读写

TCP 是流式协议，conn.Read 和 conn.Write 都可能只完成一部分。常见误操作包括：

• 把 Read 返回的 n, err 中的 n == 0 当成错误，其实 n == 0 && err == nil 是合法空读，需继续等待
• 忽略 err == io.EOF —— 这表示对端已关闭连接，不是异常，应正常退出读循环
• 直接用 ReadString('\n') 而不设缓冲或超时，容易因对方不发换行而永久阻塞
• 写大数据时没检查 Write 返回的 n，导致只发了一半就认为成功

安全读一行的最小实践：

reader := bufio.NewReader(conn)
for {
    line, err := reader.ReadString('\n')
    if err != nil {
        if err == io.EOF {
            break // 对端关闭
        }
        log.Printf("read error: %v", err)
        break
    }
    fmt.Printf("received: %s", line)
}

服务器用 Accept 后必须为每个连接启新 goroutine

ln.Accept() 返回的是一个 net.Conn，它本身不并发 —— 如果你在主 goroutine 里同步处理，后续连接会被排队阻塞。必须立刻用 go handleConn(conn) 转移处理权。

• 不加 go 就等于单线程服务器，吞吐量极低
• 记得在 handleConn 内部 defer conn.Close()，避免连接泄漏
• 如果需要限制并发数，用带缓冲的 channel 控制 goroutine 数量，而不是在 Accept 外加锁

典型结构：

for {
    conn, err := ln.Accept()
    if err != nil {
        log.Printf("accept error: %v", err)
        continue // 不要 break，否则服务器退出
    }
    go func(c net.Conn) {
        defer c.Close()
        handleConn(c)
    }(conn)
}

真正难的不是写通通信，而是处理粘包、半连接、连接闪断、buffer 边界和资源回收。这些细节不会报错，但会在高负载或弱网下突然暴露。写完先用 nc 手动连，再用 kill -9 模拟客户端崩溃，最后压测看 fd 是否泄漏。