SpringBoot Redis 发布订阅模式 PubSub

发布日期:2022-01-13 07:27   来源:未知   阅读:

  注意:redis的发布订阅模式不可以将消息进行持久化,订阅者发生网络断开、宕机等可能导致错过消息118图库资料

  对于redis的发布订阅的命令就这么简单。那么接下来我们在springboot中如何使用发布订阅的功能呢?

  添加依赖配置redis信息和连接池什么的就不说了,如果添加的有commons-pool2依赖的话,会自动帮我们配置redis连接池的

  相对于订阅者来说,发布者的实现方式很简单,以下方式就可以往channel中发送message了。

  上面的那种订阅为低级订阅,由于连接在调用subscribe的时候会导致当前线程阻塞,这种方式需要对每个连接和线程管理,所以spring提供了RedisMessageListenerContainer类来帮我们完成这些工作。

  如果我们要在程序运行时添加订阅或者取消订阅的时候该怎么办呢?我们需要提前准备好消息侦听器,添加的时候把侦听器注入到消息容器取消的时候就调用消息容器的remove方法把侦听器删除掉即可。