如何在Golang中实现TCP服务器_Golang net TCP服务器方法

18次阅读

go中net.Listen必须显式指定网络类型如”tcp”或”tcp4″,不可传入”8080″;TCP服务器需在goroutine中处理每个连接,设置读写超时,正确处理粘包与优雅关闭。

如何在Golang中实现TCP服务器_Golang net TCP服务器方法

监听地址和端口时必须显式指定 net.Listen 的网络类型

Go 的 net.Listen 不会自动推断协议,传入 "8080" 会直接 panic,必须写成 "tcp""tcp4"。本地开发常用 "tcp"(支持 IPv4/ipv6),生产环境若明确只用 IPv4,建议用 "tcp4" 避免双绑定失败。

  • net.Listen("tcp", ":8080") —— 绑定所有接口的 8080 端口(IPv4 + IPv6)
  • net.Listen("tcp4", "127.0.0.1:8080") —— 仅 IPv4,且只监听本地回环
  • 如果端口被占用,Listen 返回 *net.OpError,错误信息含 "bind: address already in use"

每个连接需在 goroutine 中独立处理,否则阻塞后续连接

TCP 连接是流式、长时的,listener.Accept() 返回一个 net.Conn,但读写操作(如 conn.Read())默认阻塞。若不在新 goroutine 中处理,第二个客户端连接会被卡住,直到第一个连接关闭。

for {     conn, err := listener.Accept()     if err != nil {         log.Println("Accept error:", err)         continue     }     go handleConnection(conn) // 必须 go,不能直接 handleConnection(conn) }
  • handleConnection 内部应 defer conn.Close(),防止连接泄漏
  • 若未设置读写超时,恶意客户端发半包或不发数据,会导致 goroutine 永久阻塞
  • 并发下需配合 sync.WaitGroupcontext 控制生命周期,避免失控创建 goroutine

conn.Read()conn.Write() 是底层字节操作,不带消息边界

TCP 是字节流协议,Read() 可能返回任意长度的数据(包括 0 字节或少于请求长度),Write() 也可能只写出部分字节。不能假设一次 Read() 就收到完整“消息”。

  • 常见错误:用 buf := make([]byte, 1024); n, _ := conn.Read(buf) 后直接按 buf[:n] 解析,却没处理粘包或半包
  • 简单方案:约定每条消息以换行符 n 结尾,用 bufio.Scanner;或固定头长(如 4 字节表示后续内容长度)
  • 不要忽略 n == 0:这通常表示对端关闭连接(EOF),应退出读循环

关闭服务器时需主动关闭 listener 并等待活跃连接结束

调用 listener.Close() 只是停止接受新连接,已建立的 conn 仍存活。若进程立即退出,这些连接可能被强制中断,导致客户端收不到完整响应。

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

  • 优雅关闭需:1)关闭 listener;2)遍历并通知所有活跃连接(例如通过 channel);3)给连接留出写完/清理时间
  • 更实用的做法是用 context.WithTimeout 包裹 Accept() 循环,并在信号捕获后关闭 listener,然后 sleep 短暂时间让 goroutine 自然退出
  • 注意:conn.SetDeadline() 对已阻塞的 Read() 有效,但对正在执行的 Write() 不一定立即中断

TCP 服务器真正难的不是启动,而是边界控制:连接数限制、读写超时、缓冲区大小、错误传播路径、以及关闭时如何不让数据丢在 wire 上。这些细节不写进代码里,压测时才会暴露。

text=ZqhQzanResources