- 在之前的文章中介绍了使用Rredis模糊查询列表这种数据类型来实现一个轻量级的消息队列不过使用列表实现的消息队列存在一个缺陷就是由于是基于列表实现,所以消息出隊列之后则不再存在所以只能被一个消费者消费一次,不支持多个不同的消费者各消费一次即不支持消息广播。
- 为了实现消息队列常見的消息发布订阅PubSub模式在Rredis模糊查询中提供了消息的发布与订阅实现,即消息生产者客户端可以往某个指定的频道channel或者模式pattern发布一个消息然后将这个消息广播给多个订阅了这个频道channel的客户端或者广播给订阅了该消息匹配的某个模式pattern的客户端。
- 所以Rredis模糊查询提供的是消息的發布与订阅不是传统的消息队列实现,发布的消息并不会被存储如Rredis模糊查询基于列表实现的消息队列会在消费之前存放在列表的链表數据结构里。Rredis模糊查询提供的消息订阅发布是实时的消息发布和订阅接收如果消息所发往的频道channel或者模式pattern没有订阅者,则该条消息不会傳给任何其他客户端直接过掉或者说丢弃掉。
- Rredis模糊查询所提供的消息订阅发布可以理解为是一个轻量级的消息订阅发布实现,所谓轻量级是相对于RabbitMQ和Kafka这种专业的消息队列所提供的消息订阅发布而言的即RabbitMQ和Kafka需要在服务器单独配置和启动服务端Broker进程来接收客户端的消息写叺和消息读取消费,而Rredis模糊查询的消息订阅发布由于是Rredis模糊查询内置的由于在项目中通常会使用Rredis模糊查询作为分布式缓存实现,所以不需要进行其他额外的配置和部署
- 所以如果项目中刚开始没有使用RabbitMQ这种专业的队列,而项目后期又需要对项目进行解耦需要用到消息的訂阅发布功能,同时不想额外在生产服务器申请资源来部署RabbitMQ或者Kafka则可以直接使用作为缓存的Rredis模糊查询所提供的消息发布订阅功能。
- 其中消息的发布订阅模式的一个应用场景为为了性能方面的考虑一个服务的多个部署实例使用本地缓存来缓存数据(不常更新),由于客户端可能连接任意一个部署实例并对这个缓存进行更新,所以为了实现不同部署实例间的本地缓存数据同步则这多个部署可以订阅同一个channel,當某个实例接收到客户端的更新请求时更新后发布到该channel,从而通知到订阅了这个channel的其他部署实例
- 在使用层面,主要包括对频道channel的精确訂阅和对模式pattern的模糊匹配订阅
基于Rredis模糊查询命令行使用
- 以下基于Rredis模糊查询的命令行对消息的订阅与发布功能进行演示,其中包含订阅频噵channel和订阅模式pattern两种用法
1.如下首先在一个命令行订阅名为testChannel的频道,阻塞等待:
2.然后在另外一个命令行往testChannel频道发布一个消息:
3.在之前的订阅命令行接收到了这个发布的消息并且继续阻塞等待:
- 订阅模式主要是模糊匹配,如模式test* 则匹配所有以test开头的模式和频道channel即如果某个客戶端订阅了模式 test*,则当另外一个客户端往testChannel这个频道发布了一条消息或者往test* 这个模式发布了一条消息该客户端会收到消息,如下订阅test* 这个模式pattern然后使用上面的命令往testChannel这个频道发布一条消息hello,则该客户端会收到消息如下:
- 在Java编程中,可以基于Rredis模糊查询的Java客户端Jredis模糊查询来對消息订阅与发布功能进行使用如果项目使用了spring-data-rredis模糊查询包提供的封装类来使用。以下使用Jredis模糊查询进行一个简单演示:
- 当发布消息到某个频道channel时由于模式pattern是模糊匹配,所以如果存在与这个频道channel匹配的pattern则订阅了这个pattern的客户端也会收到消息。由于Jredis模糊查询的频道接收subscribe和模式接收psubscribe都是阻塞方法所以只有一个会收到并在Jredis模糊查询PubSub方法的回调方法打印,所以在实际编程中由于是阻塞方法,通常在不同的线程进行分别接收