go语言集成websocket实现全双工推送需用gorilla/websocket库，因其封装握手、帧解析、心跳等底层逻辑，支持连接管理、多客户端广播及按主题订阅，远超标准库能力。
Go语言集成WebSocket实现全双工数据推送，核心在于用好gorilla/websocket库完成连接升级、消息收发与连接管理。它不是简单“一连一发”，而是要支撑多客户端在线、按需订阅、服务端主动广播——关键在结构设计，不在单次通信。
为什么选gorilla/websocket而不是原生net/http
Go标准库不直接支持WebSocket，gorilla/websocket是事实标准：稳定、文档全、社区活跃、生产环境验证多年。它封装了握手细节（如Sec-WebSocket-Key校验）、帧解析、ping/pong心跳、缓冲区控制等底层逻辑。你只需关注业务——谁连上了、订阅了什么、该推给谁。
- 自动处理HTTP升级请求（
Upgrade头、101响应） - 内置
ReadMessage/WriteMessage方法，屏蔽二进制帧操作 - 提供
SetReadDeadline/SetWriteDeadline防长连接僵死 - 支持自定义
CheckOrigin，生产环境可限制合法域名
基础服务端：连接升级+回显
这是所有功能的起点。先确保能建立连接、收发文本消息，再扩展广播和订阅逻辑。
- 定义全局
Upgrader，设置CheckOrigin为return true仅用于开发；上线必须改为校验r.Header.Get("Origin") - 在HTTP handler中调用
upgrader.Upgrade，成功后得到*websocket.Conn对象 - 用
for循环持续ReadMessage，收到即WriteMessage回传——这就是最简全双工 - 务必
defer conn.Close()，并在读写出错时break退出循环，避免goroutine泄漏
支持多客户端实时广播
单点回显没实用价值。真实场景需要“一个数据源，多个接收者”。推荐引入Hub中心管理器模式：
-
Hub结构体维护map[*Client]bool记录所有活跃连接 - 每个
Client含*websocket.Conn和专属send通道（chan []byte） - 客户端连接时注册到
Hub，断开时注销并关闭send通道 - 推送数据时，
Hub遍历所有注册Client，向其send通道写入数据；每个Client另起goroutine从通道读取并WriteMessage - 这样读写分离，避免
WriteMessage阻塞整个循环，也防止某个慢客户端拖垮全体
按主题订阅与精准推送
广播太粗放。比如K线服务中，用户只关心BTC/USDT 1m数据，不该收到ETH行情。
- 用
map[string]map[*Client]bool存储订阅关系，key为“品种_周期”（如"btc_usdt_1m"） - 客户端发
{"action":"subscribe","symbol":"btc_usdt","period":"1m"}，服务端解析后加入对应map - 当新K线生成，拼出topic =
symbol + "_" + period，查map获取所有订阅者，仅向他们推送 - 退订同理：从对应topic map中删除client指针；若map为空，可删掉该topic键节省内存
不复杂但容易忽略：连接保活靠ping/pong帧，建议每30秒由服务端conn.WriteMessage(websocket.PingMessage, nil)，客户端自动响应pong；超时未响应的连接应主动关闭。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
