如何在Gorilla中用Redis存储WebSocket ID以跨进程访问连接

核心逻辑很简单：你不需要广播功能，重点就是能快速通过客户端的唯一标识，找到对应的WebSocket连接。注意：Redis没法直接存WebSocket连接对象（这玩意儿是内存里的资源，序列化不了），所以我们存的是「能定位到连接的关键信息」。

1. 单服务实例场景 #

如果你的服务只部署一个实例，用Redis的String结构存映射最直接：

• 键：用客户端的唯一标识（比如用户ID、设备ID，格式可以是user:12345）
• 值：服务内存中WebSocket连接的本地唯一ID（比如UUID生成的conn:abcdef123456）
• 示例Redis命令：

  SET user:12345 conn:abcdef123456
  EXPIRE user:12345 3600  # 设置过期时间，防止连接断开后残留垃圾数据
  

• 服务内部维护一个内存Map（比如Java的ConcurrentHashMap、Node.js的Map），键是本地connId，值是实际的WebSocket连接对象。收到定向消息请求时，先从Redis拿connId，再从内存Map取连接发消息就行。

2. 多服务实例集群场景 #

如果服务是集群部署（多个实例），因为每个实例的内存Map是独立的，需要在Redis里额外记录连接所在的服务实例：

方案一：用Hash结构统一管理 #

• 键：ws:connections（固定前缀，方便管理）
• 字段：客户端唯一标识（比如user:12345）
• 值：实例ID:本地connId（比如instance-01:conn:abcdef123456）
• 示例Redis命令：

  HSET ws:connections user:12345 instance-01:conn:abcdef123456
  # Redis 7.0+支持给单个Hash字段设过期
  HSET ws:connections user:12345 instance-01:conn:abcdef123456 EX 3600
  

方案二：用String结构带实例信息 #

• 键：客户端唯一标识（比如user:12345）
• 值：实例ID:本地connId（和上面一样）
• 示例Redis命令：

  SET user:12345 instance-01:conn:abcdef123456 EX 3600
  

• 发消息时：先从Redis拿到实例ID和connId，然后通过服务间通信（比如内部HTTP接口、消息队列）通知对应的实例，实例再从本地内存Map取连接发消息。

关键操作流程 #

• 连接建立时：生成本地唯一connId，内存Map存connId→连接，Redis存客户端标识→(实例ID+)connId，同时设置过期时间（可以和WebSocket心跳联动，心跳刷新时更新Redis的过期时间）
• 连接断开时：从内存Map删除connId，同时删除Redis中对应的键/字段
• 发送定向消息时：根据客户端标识查Redis拿到连接关联信息，找到对应的服务实例和本地connId，获取连接后发送消息

注意事项 #

• 绝对别存WebSocket连接对象到Redis：连接是内存资源，没法序列化存储，强行存只会报错或产生无效数据
• 过期时间要合理：建议设得比心跳间隔长，比如心跳30秒一次，过期设300秒，避免网络波动误删有效连接
• 用原子性操作：更新过期时间时用EXPIRE或带EX参数的SET/HSET，确保操作不会中断
• 定期清理无效数据：可以定期扫描Redis中的键，结合服务实例的存活状态，清理已经下线实例的连接映射

内容的提问来源于stack exchange，提问作者wandermonk