分布式下WebSocket Session共享解决方案

2024-04-05 21:14:32

最近在做消息中心模块，想要实现消息实时推送到前端页面展示，直接摒弃了前端定时轮训调用接口来获取消息数据的方式，采用了WebSocket服务端推送。

流程是首先前端跟后端应用新建一个连接，并携带当前登录的用户ID，此时WebSocket会创建一个WebsocketSession来唯一绑定该连接，我们会在后端用Map建立用户ID与Session的映射关系：

Map

后续有新消息到达时，就可以通过该Map映射找到指定用户ID对应的session来推送消息。但有一个问题，后端是多应用节点，每个节点维护一个这样的Map，无法共享WebsocketSession，而且redis也无法对WebsocketSession序列化后进行存储。

方案1：Redis

由于项目目前用到了Redis，所以可以采用Redis的发布/订阅功能来实现WebsocketSession共享问题。

1.新建一个对象，属性有userId, message，用于发送消息

Object(String userId, String message)

2. 当新消息到达时，将消息注册到redis指定topic的频道上

convertAndSent("topicName", new Object(userId, message))

3.每个应用节点都订阅该topic的频道，这样新消息一注册，每个节点都能接收到Object，然后从Object中获取userId，再从映射Map中获取userId对应的WebsocketSession（在哪个节点建立的连接和Map映射关系，就会在哪个节点找到对应的session），进行消息推送。

就这样通过Redis的发布/订阅功能实现session共享。当然在步骤2，新消息到达时，可以先在本节点的Map映射中查找是否有userId对应的session，如果有，直接推送消息，而且不必要再将消息注册到redis中。

方案2：消息队列

消息队列(例如RocketMQ)广播订阅消费方式，也是可靠地方案

分布式下WebSocket Session共享解决方案相关推荐

分布式架构下，Session 共享有什么方案？
来自:会点代码的大叔分布式架构下的 Session 共享,也称作分布式 Session 一致性:分布式架构下 Session 共享有哪些问题,又有哪些解决方案,让我们一起看一下. 01 Sessio ...
分布式Session共享解决方案
转载自分布式Session共享解决方案 Session是服务器用来保存用户操作的一系列会话信息,由Web容器进行管理.单机情况下,不存在Session共享的情况,分布式情况下,如果不进行Sessio ...
Session机制详解及分布式中Session共享解决方案
Session机制详解及分布式中Session共享解决方案参考文章: (1)Session机制详解及分布式中Session共享解决方案 (2)https://www.cnblogs.com/jing ...
C#session共享+redis_Shiro权限管理框架（二）：Shiro结合Redis实现分布式环境下的Session共享...
精品推荐国内稀缺优秀Java全栈课程-Vue+SpringBoot通讯录系统全新发布! Docker快速手上视频教程(无废话版)[免费] 作者:夜月归途转载自: https://www.cnblo ...
集群环境下的Session共享
一.Cookie机制和Session机制回顾 1)定义:Session成为"会话",具体是指一个终端用户与交互系统进行通信的时间间隔,通常指从注册进入系统到注销退出系统之间所经过的 ...
session共享怎么做的（分布式如何实现session共享）？
session共享怎么做的(分布式如何实现session共享)? 问题描述:一个用户在登录成功以后会把用户信息存储在session当中,这时session所在服务器为server1,那么用户在 s ...
分布式下的session问题
分布式下的session 在分布式项目下项目中使用在分布式项目下 session是一种会话状态,是储存在服务器上的,可以区分每个用户.浏览器会保存着对应的信息.浏览器保存的叫cookie.用户访问 ...
使用spring session+redis技术，解决负载均衡下的session共享问题
使用spring session+redis技术,解决负载均衡下的session共享问题参考文章: (1)使用spring session+redis技术,解决负载均衡下的session共享问题 ( ...
【微服务之分布式Session】Session机制详解及分布式中Session共享解决方案
一.为什么要产生Session http协议本身是无状态的,客户端只需要向服务器请求下载内容,客户端和服务器都不记录彼此的历史信息,每一次请求都是独立的. 为什么是无状态的呢?因为浏览器与服务器是使用 ...

最新文章

热门文章