Websocket Session 共享解决_websoket session共享的方式

Websocket Session 共享解决（方案一）

既然Websocket Session 不能直接序列化然后存储，而且如果用户请求的时候，开始与集群中的A 节点创建链接，就算把这个  Session  拿到B 节点去再给用户Push 消息，应该也是不通（没测试）的。

所以我的解决方案采用订阅式队列去触发  Websocket  反推的方式来实现看上去是  Session共享  的，思路如下图：

Websocket Session  共享 思路图解释：

模块一：这里没有什么好说明的，因为每一个用户只创建以一个  Session  ，当用户再次链接到第二个节点的时候，第一个节点的  Session  就会关闭和销毁。而每个节点采用静态（static ）的成员变量去存储（Map）当前节点的所有Websocket Session 。

模块二：因为每个节点存储的是每个节点的所有Websocket Session ，那么只需要判断下当前节点是否存在当前用户的Websocket Session ，存在则反推消息。

模块三：当有消息需要通过  Websocket  推送给对应的用户的时候，而又不知道这个用户在哪个节点，那么通过任务调度模块，把消息以订阅MQ 的方式放到  MQ  中，这样每个节点都可以收到消息，从而参照 “模块二”判断当前用户是否存在当前节点。然后推送。

Websocket Session 共享解决（方案二）

其实我们之所以要做共享，其实就是因为在集群环境中，在HA/Nginx等方案中，做轮询请求来减轻节点压力，这样导致用户可能分配在多个节点，那么如果我们采用IP等的Hash值规则，或者其他可以参考的规则。解决一个用户只会分配到一个节点上，那么就不存在Session共享了。这样的中间件好多。如我们的“伞神”提出的 采用阿里的 “Tengine 的session sticky 组件” 就可以解决。其他的也很多。