Go集群架构设计：跨服WebSocket单发与群发-Golang-PHP中文网

gorilla/websocket单机广播无法跨实例，必须借助redis pub/sub实现集群消息中继；各节点独立维护本地clients map，同时订阅同一redis频道接收广播消息并推送至本机连接。

go集群架构设计：跨服websocket单发与群发

gorilla/websocket 在多实例间无法共享 client 列表

单机 WebSocket 服务用 map[*Client]bool 管理连接很自然，但一上集群，每个实例的内存完全隔离——A 实例里注册的 client，B 实例根本看不见。直接群发会漏掉 80% 的在线用户，单发目标更无从谈起。

常见错误现象：broadcast chan []byte 只在本机 goroutine 内有效；调用 hub.broadcast 后只有本机在线用户收到；跨实例消息静默丢失，前端无报错也无响应。

必须把“谁在线”这个状态外置，不能依赖进程内内存
“发给某人”需要能按 user_id 或 session_id 定位到具体实例，不能只靠内存地址
广播不是往本地 map 里遍历，而是往所有实例都投一份消息（或由统一调度器分发）

用 Redis Pub/Sub 做跨实例消息中转最轻量

不需要引入 Kafka 或 RabbitMQ 这类重量级中间件。Redis 的 PUBSUB 天然适合做 WebSocket 集群的消息总线：延迟低、命令简单、Go 客户端成熟（github.com/go-redis/redis/v8）。

使用场景：用户 A 发一条消息 → 本实例写入 Redis channel → 其他所有实例订阅该 channel → 各自投递给本地对应的 client。

单发：发消息时带上 target_user_id，各实例收到后比对本地 client 的 user_id 字段，命中才写入 client.send channel
群发：用固定 channel 名如 ws:global:broadcast，所有实例都监听，各自处理本地在线用户
注意不要在 Redis 消息体里塞完整 *Client 对象——只传必要字段，如 {"user_id":"u123","msg":"hi"}

客户端连接需绑定实例标识，否则单发会失败

用户连上来那一刻，就得知道它落在哪个实例上。否则你拿着 user_id 想单发，却不知道该往哪台机器发指令。

WebSocket 8.18.2

WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。

下载

常见错误做法：Nginx 默认轮询，用户刷新页面就跳到另一台实例，上次的连接已断，新连接又没记录归属，user_id → instance 映射始终缺失。

方案一：Nginx 用 ip_hash 或 hash $arg_token consistent，让同一用户稳定落到同一后端
方案二：登录后分配带实例标识的 token（如 tk_abc123@inst-2），WebSocket 握手时透传，服务端解析并记录 user_id → inst-2
方案三（推荐）：用 Redis Hash 存映射，如 HSET ws:user:map u123 inst-2，每次单发前先查，再通过 RPC 或 HTTP 调用目标实例的内部 API