WebSocket 集群 session 共享方案

!! 本文聊天室基于 websocket 进行实现,同时也为解决websocket session在集群部署服务时的无法共享导致的收发消息问题。

问题引入

当我们使用 websocket 实现聊天时,后端服务会将所有的 websocket session缓存起来,之后根据收到的消息,遍历或者找到某个session进行消息的发送。 但是在我们进行后端集群部署时,这里假设存在2台后端服务器A和B,用户u1连接A的websocket同时创建session,这时A将session进行缓存,u2进行同样的操作,连接B服务器。 此时,u1群发消息,消息到达A服务,读取session缓存,遍历session发送消息,但由于u2的session不在A服务上,所以u2无法受到消息。 问题形成。

思路分析

针对上述问题,可以将session进行分布式存储或者将消息进行广播。

  1. session分布式存储 可以采用redis进行分布式的session存储,但是发现 websocket session 并未实现 Serializable 接口,无法进行序列化。此方案不可行。
  2. 消息广播 将消息发送至mq组件,由mq通知各个服务节点消息内容,满足群发消息。

代码实现

这里针对第二种消息广播的方案实现较为简单,不再做详细叙述。

经验分享 程序员 微信小程序 职场和发展