go用Goroutine+channel实现连接级并发:每个连接启一个goroutine处理,监听循环只accept;需限流(如semaphore)、设读写超时、用sync.Pool复用缓冲区;优雅关闭需监听信号、WaitGroup等待活跃连接退出。

用 Goroutine + Channel 实现连接级并发
Go 天然适合高并发 TCP 服务,核心在于每个连接启动一个独立 goroutine 处理,避免阻塞主线程。监听循环只负责 accept 新连接,不参与业务逻辑:
- 调用 listener.Accept() 获取新连接后,立即用 go handleConn(conn) 启动协程
- handleConn 内部使用 bufio.Reader/Writer 或直接 conn.Read/Write,按协议解析请求、处理业务、返回响应
- 务必在协程退出前调用 conn.Close(),防止文件描述符泄漏
控制并发规模:连接数限制与超时管理
无节制启 goroutine 可能压垮内存或系统资源。需主动限流和兜底:
- 用 semaphore(如 golang.org/x/sync/semaphore)限制同时处理的连接数,例如最多 1000 个活跃连接
- 给每个连接设置 SetReadDeadline / SetWriteDeadline,防客户端长时间不发数据导致 goroutine 悬挂
- 在 handleConn 开头启动超时定时器,比如 30 秒无活动自动断连:time.AfterFunc(30*time.Second, func(){ conn.Close() })
高效读写:避免内存拷贝与缓冲区复用
高频小包场景下,频繁分配字节切片会触发 GC 压力。可优化 I/O 层:
- 使用 sync.Pool 管理临时缓冲区,例如预分配 4KB 的 []byte 对象池
- 读取时优先用 conn.SetReadBuffer(size) 提升内核接收缓冲区,减少系统调用次数
- 写入大量数据时,用 io.CopyBuffer 或封装带缓冲的 writer,避免多次小 write 系统调用
优雅关闭与连接平滑退出
服务重启或更新时,不能粗暴 kill 进程,需等待已有连接处理完再退出:
立即学习“go语言免费学习笔记(深入)”;
- 监听 os.Interrupt / syscall.SIGTERM 信号,进入关闭流程
- 调用 listener.Close() 停止 accept,但已建立的 conn 仍可读写
- 维护一个 sync.WaitGroup 记录活跃连接数,每个 handleConn 在退出前 Done();主 goroutine Wait() 后再彻底退出
基本上就这些。golang TCP 高并发不靠复杂框架,而靠清晰的 goroutine 职责划分、及时的资源回收和适度的系统参数调优。