关键在于结构分层:Client封装连接与发送通道,ClientManager统管注册、注销与广播,读写协程分离,sync.RWMutex保护客户端映射,实现不乱、不卡、不漏、不崩。

用Golang处理WebSocket多客户端,关键不是“怎么连上”,而是“怎么不乱、不卡、不漏、不崩”。核心在于结构分层:连接归连接管,消息归消息转,广播归中心统一分发。
用Client结构体封装每个连接
每个WebSocket连接不能只存个*websocket.Conn就完事。得包装成结构体,带上专属发送通道和元信息:
- Conn字段保存原始连接,用于底层读写
-
Send是带缓冲的
chan []byte,避免写操作阻塞读协程 - 可选加
ID、JoinedAt、GroupID等字段,方便后续路由或限流
用ClientManager做中心调度器
它不干具体收发,只管三件事:谁来了、谁走了、消息往哪播。典型设计包含三个输入通道:
-
register:新连接进来时,由HTTP handler推一个
*Client进去 - unregister:连接断开或出错时触发清理,删map条目、关send channel
- broadcast:所有入站消息(比如用户发的文本)都进这里,由Manager统一转发
Manager内部用sync.RWMutex保护clients map[*Client]bool,读多写少场景下比全互斥更高效。
立即学习“go语言免费学习笔记(深入)”;
读写分离+非阻塞发送
每个Client启动两个goroutine,彻底解耦IO方向:
-
readPump:循环调
conn.ReadMessage(),收到消息就丢进Manager.broadcast -
writePump:监听
client.Send,有数据就conn.WriteMessage();发送时用select { case client.Send 防止卡死
这样即使某个客户端网络慢或掉线,也不会拖垮其他人的收发。
广播时加超时与兜底清理
向所有在线Client发消息时,别直接client.Send 了事。要防堆积、防泄漏:
- 给
client.Send设合理缓冲(如16或32),不盲目拉高 - 发送前加
select+default,失败立即走Manager.unregister - 搭配心跳检测(如
SetReadDeadline)或ping/pong机制,5秒没响应就主动关连接
每次关闭连接前,确保close(client.Send)、从map删除、释放引用——内存泄漏往往就差这一句。
基本上就这些。不复杂但容易忽略细节。










