如何使用Golang net包进行TCP通信_Golang net TCP客户端与服务器示例

15次阅读

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

如何使用Golang net包进行TCP通信_Golang net TCP客户端与服务器示例

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 永久挂起。

立即学习go语言免费学习笔记(深入)”;

  • 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.Readconn.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 是否泄漏。

text=ZqhQzanResources