如何使用Golang开发即时通知系统_Golang Web推送通知功能实现

websocket连接不稳定需设心跳与读写超时，nginx配proxy_read_timeout等；广播用sync.map+channel中转；http推送走异步job队列；调ulimit并显式清理资源防fd泄漏。

WebSocket 连接不稳定，客户端频繁断开怎么办

go 的 net/http 原生支持 WebSocket，但直接用 gorilla/websocket 时，若未设置心跳和读写超时，Nginx 或云服务商（如 AWS ALB）会在 60 秒无数据时主动断连。

• 服务端必须调用 conn.SetPingHandler 和 conn.SetPongHandler，并定期发 Ping（建议 30 秒间隔）
• 务必设置 conn.SetReadDeadline 和 conn.SetWriteDeadline，否则阻塞读写会卡死 goroutine
• Nginx 配置里要加 proxy_read_timeout 300; 和 proxy_set_header Upgrade $http_upgrade; 等 WebSocket 必需头

如何安全地广播消息给指定用户或房间

不能靠全局 map 存连接——并发读写会 panic，也不该每次广播都遍历所有连接。推荐用带锁的注册表 + channel 中转。

• 每个连接启动独立 goroutine 监听 conn.ReadMessage，收到消息后投递到用户专属 chan []byte
• 用 sync.Map 存 userID → *client，避免读多写少场景下的锁争用
• 广播前先检查 conn.WriteDeadline 是否过期，跳过已失效连接，防止 write: broken pipe 错误堆积
• 房间广播不要拼接 json 后重复序列化，应预先 encode 一次，再 copy 给多个 conn

HTTP 接口触发推送时，如何避免阻塞请求

如果在 HTTP handler 里直接调用 conn.WriteMessage，遇到慢连接或网络抖动，整个 HTTP 请求会被拖住，拖垮 API 吞吐量。

• HTTP handler 只负责把推送指令（如 {“user_id”: “u123”, “data”: {…}}）发到一个中心 chan PushJob
• 单独起 1–3 个 goroutine 消费该 channel，执行实际的连接查找与写入，实现 IO 解耦
• 为防 channel 堆积，用带缓冲的 make(chan PushJob, 1000)，满时丢弃低优先级通知（如已读回执）

部署后连接数上不去，too many open files 报错频发

linux 默认单进程最多打开 1024 个文件描述符，而每个 WebSocket 连接至少占用 1 个 fd，加上日志、数据库连接等，很容易打满。

立即学习“go语言免费学习笔记（深入）”；

• 启动前运行 ulimit -n 65536，并在 systemd service 文件中加 LimitNOFILE=65536
• Go 程序里用 http.Server{ConnContext: ...} 在连接关闭时显式清理资源，比如从 sync.Map 中 delete
• 别依赖 GC 回收连接：conn.Close() 后立刻释放关联的 buffer、timer、channel

真正难的不是推一条消息，是维持几千个长连接不泄漏、不超时、不误杀。每个连接背后都是 goroutine + channel + timer + fd，少一个环节没关干净，压测时就等着看内存和 fd 持续上涨。