核心用法
websocket-hub-patterns 是一套面向生产环境的 WebSocket 水平扩展架构模式，通过 Redis 协调实现多实例网关的无状态化部署。核心组件包括：Hub（连接管理中枢）、ConnectionRegistry（分布式连接注册表）以及 Lazy Redis Subscriptions（按需订阅机制）。
典型使用场景：
- 构建需要水平扩展的实时双向通信服务
- 开发聊天应用、协同编辑、交互式仪表盘
- 部署在负载均衡器后的多实例 WebSocket 网关
关键实现模式
1. 懒加载 Redis 订阅
仅在本地首个订阅者加入时才向 Redis 订阅频道，避免无意义的跨实例消息转发。当最后一个本地订阅者离开后自动取消订阅，显著降低 Redis 连接数和带宽消耗。
2. 双通道消息路由
- 本地广播：直接遍历内存中的
subscriptions[channel] - 跨实例广播：通过 Redis Pub/Sub 接收其他实例消息，再注入本地
broadcast通道
3. 连接注册与心跳ConnectionRegistry 将连接元数据写入 Redis（TTL 2 分钟），实例定期上报心跳（30 秒 TTL），支持故障转移时快速定位连接所属实例。
4. 优雅关闭机制
通过 done 通道触发级联关闭：停止 Hub 主循环 → 关闭所有 Redis 订阅 → 发送 WebSocket Close 帧 → 等待 goroutine 退出。
显著优点
- 水平扩展就绪：无共享状态的 Hub 设计，实例可任意扩缩容
- 资源高效：懒订阅避免空转连接，预估节省 60%+ 的 Redis 资源
- 故障容错：连接注册表支持实例故障时的连接迁移决策
- 背压处理：
select-default模式检测慢客户端，自动断开避免级联阻塞 - 生产 hardened：内置 ping/pong、写超时、批量消息刷写
潜在缺点与局限性
- 最终一致性：跨实例消息通过 Redis 中转，延迟通常 < 1ms 但非零
- Redis 依赖：成为单点瓶颈，需额外 Redis Cluster/Sentinel 保障
- 无内置消息持久化：需配合 Redis Streams 或外部存储实现历史消息
- Go 语言特定：示例代码为 Go，其他语言需参照模式自行实现
- 连接数上限：单实例连接数受限于 goroutine 和内存，需结合注册表做容量规划
适合人群
- 需要为现有 WebSocket 服务添加水平扩展能力的后端工程师
- 构建实时协作产品的技术团队（文档、表格、白板类）
- 运维高并发直播、弹幕、通知推送系统的架构师
- 熟悉 Go 或能快速理解并发模式的多语言开发者
常规风险
| 风险场景 | 缓解措施 |
|---------|---------|
| Redis 连接泄漏 | 严格配对 `subscribeToChannel`/`unsubscribeFromChannel` |
| 消息丢失 | 关键业务需叠加 Redis Streams 持久化 |
| 脑裂连接 | 实例心跳不可少，配合负载均衡健康检查 |
| 内存溢出 | 设置 `c.send` 通道缓冲区上限，配合溢出断连策略 |
| 优雅关闭超时 | 设置 `wg.Wait()` 超时兜底，避免无限阻塞 |