用golang做实时聊天应用需确保连接稳定、消息不丢、广播及时，核心是用gorilla/websocket升级协议，配合goroutine与channel实现并发安全的消息分发。
用 Golang 做实时聊天应用，关键不在写多少行代码，而在于连接稳、消息不丢、广播及时。核心是用 gorilla/websocket 升级协议，配合 goroutine + channel 实现并发安全的消息分发。
WebSocket 连接升级与跨域处理
HTTP 请求必须先“升级”为 WebSocket 长连接，这一步靠 Upgrader 完成。开发阶段可临时允许所有来源跨域：
-
CheckOrigin设为func(r *http.Request) bool { return true } - 生产环境务必替换为白名单校验，比如只放行指定域名或携带有效 token 的请求
- 每个成功升级的
*websocket.Conn就是一个在线用户，需立即纳入管理，不能裸露在全局 map 中直接读写
客户端连接的安全管理
多个 goroutine 同时操作 map 会 panic，所以不能把连接存成 map[*websocket.Conn]bool 然后随意增删。正确做法是引入通道协调：
- 定义
register和unregister两个 channel，用于通知中心注册/下线用户 - 启动一个长期运行的
hub.run()goroutine，用 select 监听这些通道 - 连接断开时，主动关闭其发送 channel，并从 clients map 中移除，避免内存泄漏和写 panic
读写分离与消息广播逻辑
单个连接既要收又要发，若混在一个 goroutine 里，一次阻塞就会卡死整个连接。标准解法是拆成两个独立协程：
立即学习“go语言免费学习笔记（深入）”；
-
readPump：循环调用
conn.ReadMessage()，解析后转成结构体（如{Username, Body, Timestamp}），再推入全局broadcastchannel -
writePump：从该连接专属的
sendchannel 取消息，调用conn.WriteMessage()发送；若失败则触发清理流程 - 广播协程监听
broadcast，收到消息后遍历所有活跃 client，逐个写入——对失败连接做delete和close
前端接入与基础健壮性补充
浏览器原生支持 WebSocket，无需额外库。简单几行就能完成双向通信：
- 用
new WebSocket("ws://localhost:8080/ws")建连，监听onmessage渲染消息 - 发送前建议 JSON 序列化，服务端统一解析，便于后续扩展字段（如消息类型、目标房间）
- 加基础心跳机制：服务端定期
conn.WriteMessage(websocket.PingMessage, nil)，客户端自动回Pong；超时未响应则视为断连
