go 从1.22起net/http原生支持upgrade,但需用gorilla/websocket等库处理websocket握手;须手动校验sec-websocket-key、返回101状态码并劫持连接;广播消息应异步且加锁管理连接,及时清理关闭连接以防泄漏。

Go 本身不内置 WebSocket 支持,但 net/http 从 1.22 起原生支持 Upgrade,配合 gorilla/websocket(更稳定)或 golang.org/x/net/websocket(已弃用)可快速实现可靠聊天;别直接用 http.ServeMux 处理 WebSocket 连接,它不处理协议升级细节。
WebSocket 连接必须手动处理 Upgrade 请求
浏览器发起的 ws:// 请求本质是 HTTP GET 带 Upgrade: websocket 头,net/http 默认不识别该协议切换。你得显式检查头、校验 Sec-WebSocket-Key、写响应并接管连接。
- 用
gorilla/websocket的Upgrader.Upgrade()最省事,它自动完成握手和错误响应 - 自己手写需调用
w.WriteHeader(101)+w.Header().Set()设置Connection和Upgrade,再调hijack获取底层net.Conn—— 容易漏头、错状态码,不推荐 - 常见错误:返回 200 而非 101;未清除响应缓冲区导致握手失败;并发读写同一连接未加锁(
websocket连接不是线程安全的)
消息广播需避免阻塞主线程和连接泄漏
每个 *websocket.Conn 是独立长连接,不能在 ReadMessage 循环里直接遍历所有连接发消息 —— 一旦某个连接慢或断开,整个广播卡住,新消息积压。
DirCMS内容管理系统,是国内自主研发的一款功能强大而又不失小巧简洁的由PHP+Mysql架构的内容管理系统。DirCMS代码全部开源,便于使用者二次开发或定制;并采用简洁的模板标签技术,使制作模板更加容易,一般情况下,用DirCMS架构一个企业站只需半天时间即可,真正实现功能的简洁,实用,强大,灵活。可广泛应用于架构各类门户站,下载站,企业站,工作室等站点。
- 用中心化
map[uint64]*websocket.Conn+sync.RWMutex管理在线用户,ID 建议用atomic.AddUint64生成 - 广播走 goroutine:
go func() { for _, c := range conns { c.WriteMessage(...) } }(),但要确保c不被并发读写 - 务必监听
conn.ReadMessage返回的io.EOF或websocket.CloseMessage,及时从 map 中删除连接,否则内存泄漏 - 生产环境建议加心跳(
SetPingHandler+SetPongHandler),超时未响应则主动关闭
前端连接 URL 和后端路由必须严格匹配
前端 new WebSocket("ws://localhost:8080/ws") 的路径必须与 Go HTTP 路由完全一致,且不能被其他中间件拦截(如 CORS、gzip、日志中间件)。
立即学习“go语言免费学习笔记(深入)”;
- WebSocket 路由要注册在
http.HandleFunc("/ws", wsHandler),别用http.Handle("/ws", ...)包装 handler —— 某些封装会提前写 header - CORS 对 WebSocket 无效(浏览器不发送 Origin 检查),但若服务同时提供 API,别让 CORS 中间件误吞
/ws请求 - 本地开发用
http.Server即可,部署到 Nginx 需显式配置:proxy_http_version 1.1; proxy_set_header Upgrade $http_upgrade; proxy_set_header Connection "upgrade"; - Chrome 控制台报
net::ERR_CONNECTION_REFUSED?先确认端口监听(lsof -i :8080)、防火墙、以及是否启用了 HTTPS 但前端仍用ws://
真实场景里,连接管理比消息格式复杂得多:用户离线重连策略、消息去重、历史消息拉取、房间隔离(而非全局广播)——这些都得在连接生命周期里埋钩子,而不是堆在 for 循环里硬编码。









