应避免用 gin 处理 websocket 升级,因其 writer 和中间件会篡改必需的 upgrade 响应头,导致浏览器静默拒绝;且 *websocket.conn 非线程安全,需为每个连接配专属 writepump goroutine 和缓冲 channel 以避免写冲突。

用 gorilla/websocket 搭配裸 net/http 就够了,Gin 等框架反而增加无谓开销;真正影响性能的不是路由层,而是连接管理、读写并发模型和心跳策略。
为什么别用 Gin 处理 WebSocket 升级
Gin 的 c.Writer 和中间件机制会干扰 WebSocket 协议升级流程。标准升级必须在响应头中精确写入 Upgrade: websocket、Connection: Upgrade、Sec-WebSocket-Accept 三组字段,而 Gin 默认会添加 Content-Length 或修改 Connection 头,导致浏览器静默拒绝连接(控制台只显示 WebSocket connection to 'ws://...' failed,无具体错误)。
实操建议:
- WebSocket 路由直接走
http.HandleFunc("/ws", socketHandler),绕过所有框架中间件 - 若项目已重度依赖 Gin,可用
c.Writer.WriteHeaderNow()强制刷出响应头,再手动调用upgrader.Upgrade(c.Writer, c.Request, nil),但需确保此前未写入任何 body - 不要在 Gin 中间件里调
c.Next()后再升级——此时 header 已被锁定,Upgrade必然 panic
conn.WriteMessage 并发调用必崩
*websocket.Conn 不是线程安全的。多个 goroutine 同时调 conn.WriteMessage(),大概率触发 write tcp: use of closed network connection 或消息错乱(A 用户的消息被发到 B 的连接上)。
常见错误现象:用户数一过 50,断连率陡增,日志里反复出现 websocket: write deadline exceeded,其实根本不是超时问题,而是写冲突导致连接被底层强制关闭。
实操建议:
- 为每个连接绑定一个带缓冲的
chan []byte(缓冲大小设为 64–128,防写 goroutine 阻塞) - 启动唯一
writePumpgoroutine,循环从 channel 读消息并调conn.WriteMessage() - 发送前先检查
select { case ,避免往已关闭连接发数据 panic - 绝对不用
sync.Mutex包裹WriteMessage——锁竞争在高并发下会成为明显瓶颈
Nginx 反向代理下 WebSocket 连接 60 秒后静默断开
Nginx 默认 proxy_read_timeout 60,只要服务端 60 秒内没向客户端发任何数据(包括 ping),它就直接 kill 连接,且不通知客户端。浏览器仍认为连接有效,导致后续发消息失败却无感知。
使用场景:用户切到其他标签页、手机锁屏、Wi-Fi 切换瞬间重连失败,八成是这个原因。
实操建议:
- 服务端必须主动发
conn.WriteMessage(websocket.PingMessage, nil),不能只靠客户端 ping - 用
time.Ticker在writePump内部驱动,间隔设为 45 秒(比 Nginx timeout 小即可) - Nginx 配置必须显式开启 WebSocket 支持:
proxy_set_header Upgrade $http_upgrade;和proxy_set_header Connection "upgrade"; - 前端监听
onclose时,若event.code === 1006(abnormal closure),立即触发重连,不要等心跳超时
子协议不匹配导致连接秒关且无提示
前端调 new WebSocket("ws://...", ["json"]) 时,服务端 upgrader.Subprotocols 必须严格等于 []string{"json"}。哪怕顺序颠倒(如 []string{"JSON"})、多空格或大小写不符,连接都会在握手完成后立刻关闭,浏览器控制台不报错,onopen 都不会触发。
实操建议:
- 服务端初始化
upgrader时显式设置:Subprotocols: []string{"json"} - 若需支持多种格式,前端传
["json", "binary"],服务端则按相同顺序声明,不可动态排序 - 调试时抓包看响应头
Sec-WebSocket-Protocol值是否与前端请求头完全一致
最易被忽略的是:每个连接的 readPump 必须设 conn.SetReadDeadline(),否则客户端异常断网后,服务端连接会永远卡在 ReadMessage() 阻塞,goroutine 泄漏,内存缓慢爬升——这问题在压测时才暴露,但线上可能已持续数天。
golang免费学习笔记(深入):立即使用
在学习笔记中,你将探索golang的核心概念和高级技巧!











