redis发布订阅c接口_用redis发布订阅模式解决集群中websocketsession共享问题

论坛 期权论坛 编程之家     
选择匿名的用户   2021-6-2 21:04   5533   0

每天分享java干货小知识,欢迎关注转发评论交流,每天一点进步!

9e51b8341e9319bf02570974c12ceace.png

大家都知道集群中会有websocketsession不一致的问题,会造成消息推送不成功,用redis发布订阅模式解决websocket session问题其实算不上session共享,因为websocketsession没法序列化存到redis,只能换一种方式实现,模拟session共享

  • 在redis的配置类里面加上,如下面(redis的基本配置我不截图了,在我的历史文章有怎么整合redis的 自己去看下)
395fd3ea8c3bd09dff27950fe413de90.png

订阅webSocketSessionShare的频道消息,监控到这个频道有消息后,会调用消息监听适配器listenerAdapter, listenerAdapter会传入WebSocketRedisMsgInterface这个业务接口(这个接口就是处理业务逻辑的,有消息后你会做什么),以及通过反射调用WebSocketRedisMsgInterface的方法 receiveMessage。

  • 下面是WebSocketRedisMsgInterface是业务接口
d0141abca1017daa8f2183b49a353693.png
  • 我们让我们的websocket处理类实现这个WebSocketRedisMsgInterface接口
afc4cea615eb1b2cc59c107c53aacb7f.png
  • 实现这个接口的逻辑就是具体要发送消息的操作(监控到redis这个频道有消息就会触发)
5f1c10878d7d756e72793c95965caf17.png
  • 下面是发送消息先存到redis的这个频道中(之前是直接推送到前端,会有sessiong不一致问题)
aba0b7c5ff00ee22e6faba2828f14a5b.png

好了,不知道各位老铁看懂没 欢迎交流!

分享到 :
0 人收藏
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

积分:3875789
帖子:775174
精华:0
期权论坛 期权论坛
发布
内容

下载期权论坛手机APP