短轮询适合小规模通知,需用Redis缓存消息并清空已读;SSE需严格设置响应头和flush;WebSocket须处理心跳、超时与重连;微信推送需自动刷新Token并重试。

用 http.HandleFunc 做短轮询,够用但别硬扛高并发
多数内部系统或小规模后台通知(比如运营后台给审核员弹个“新工单来了”),直接用短轮询最省事。它不依赖长连接、不操心重连、浏览器兼容性拉满——IE11 都能跑。
但要注意:messages 用内存 map 存只是演示,真实场景必须换成 Redis 或带过期的本地缓存(如 freecache),否则进程重启消息就丢了;另外别忘了在返回后清空或标记已读,否则用户每次请求都拿到同一堆消息。
- 客户端 JS 可用
setInterval(() => fetch("/poll?user_id=123"), 30000)控制频率 - 服务端要加
w.Header().Set("Cache-Control", "no-cache"),防止代理缓存响应 - 如果用户量上万,每 30 秒一次全量拉取,QPS 就是
用户数 / 30,很容易打爆 API 网关
handleEvents 实现 SSE 推送时,响应头和流式写入缺一不可
SSE 是 Web 场景下最轻量的单向推送方案,比 WebSocket 少一堆连接管理逻辑,适合日志流、状态广播、实时告警等场景。但它不是“发个 response 就完事”,必须严格满足协议要求。
常见失败现象:浏览器控制台报 Failed to load resource: net::ERR_INCOMPLETE_CHUNKED_ENCODING,基本就是响应头漏了、没 flush、或者中途 panic 导致连接中断。
立即学习“go语言免费学习笔记(深入)”;
- 必须设置三类响应头:
w.Header().Set("Content-Type", "text/event-stream")、w.Header().Set("Cache-Control", "no-cache")、w.Header().Set("Connection", "keep-alive") - 每次写入后必须调用
w.(http.Flusher).Flush(),否则数据卡在缓冲区不下发 - 不要用
json.NewEncoder(w).Encode()直接写,得手动拼data: {...}\n\n格式,否则浏览器解析不了
WebSocket 不是“装上 gorilla/websocket 就行”,心跳和连接生命周期得自己兜底
WebSocket 适合需要双向通信的场景(比如客服聊天、协同编辑),但 Go 里用 github.com/gorilla/websocket 时,很多人只写了 upgrader.Upgrade 和 conn.ReadMessage,结果压测半小时连接全掉——因为没处理网络抖动、NAT 超时、客户端休眠等问题。
核心不是“连上”,而是“连得久、断得明、重连快”。微信小程序、iOS Safari 对空闲连接尤其敏感,60 秒没数据就可能静默关闭。
- 必须启动独立 goroutine 调用
conn.SetPingHandler+ 定期conn.WriteMessage(websocket.PingMessage, nil) -
conn.SetReadDeadline和conn.SetWriteDeadline必须设,且pongWait要大于 ping 周期(官方建议pingPeriod = (pongWait * 9) / 10) - 所有
conn.WriteMessage调用都要包在defer conn.Close()的保护范围内,避免 goroutine 泄漏
微信服务号/企业微信推送别自己拼 URL,Token 刷新和错误重试必须自动化
微信系推送表面是 HTTP 请求,实际水很深:Access Token 2 小时过期、每日调用量有限、42001 错误要主动刷新、45009 是限流得退避重试……手写一个 http.Post 发文本消息,上线三天准出问题。
关键不是“能不能发”,而是“发失败了有没有记录、有没有告警、有没有自动补发”。企业级系统里,一次推送失败往往意味着业务流程卡死。
- Token 必须存在可刷新的全局单例(如用
sync.Once+time.AfterFunc提前 5 分钟刷新) - 所有微信 API 调用都要封装
DoWithRetry,对 40001/42001/45009 等错误码做指数退避(time.Sleep(time.Second ) - 发送成功后,至少记录
msgid和接收方userid到数据库,便于后续查证是否送达
真正难的从来不是“怎么推”,而是“推没推成功”“谁没收到”“失败要不要重试”“重试几次合适”——这些逻辑不会出现在 hello world 示例里,但线上出问题时,它们才是第一现场。










