我们知道在单节点应用中我们只需要将websocketsession存储在ConcurrentHashMap中就OK,每次发送通知都从map中根据用户ID获取对应的websocket的session进行消息通知。
针对分布式系统,很多人第一时间想到的是websocket的session共享,这是大多数的第一反应。很遗憾的是,websocketsession不支持序列化操作,所以也就不能够存在redis等缓存中。
那么我们还有什么其他的解决方案呢?
我先大致说一下我的项目架构,springcloud项目,没有做前后端分离,所有请求都是经过web服务进行转发。
好了,下面就来说说我是怎么解决的吧。
如图,我是利用了redis的订阅发布机制实现信息共享的,web负责维护websocketsession,并监听redis
通道中的消息,将消息发送给对应的在线用户。业务服务都统一通过接口服务将消息发布到redis,这样子就不
需要每个服务都去做配置了。做到服务间职能清晰。
redis配置如下:
websocket相关配置请参考:
本人采用的是jdk自带的,在javax.websocket包下。
当然针对各个项目情况还有多种解决办法,这里就不在一一赘述,具体情况具体分析。
springcloud下实现websocket session共享
原文:https://www.cnblogs.com/sly1994/p/11815705.html