Redis发布订阅模式

使用银行卡消费的时候，银行往往会通过微信、短信或邮件通知用户这笔交易的信息，这便是一种发布订阅模式，这里的发布是交易信息的发布，订阅则是各个渠道。这在实际工作中十分常用，Redis 支持这样的一个模式。

发布订阅模式首先需要消息源，也就是要有消息发布出来，比如例子中的银行通知。首先是银行的记账系统，收到了交易的命令，成功记账后，它就会把消息发送出来，这个时候，订阅者就可以收到这个消息进行处理了，观察者模式就是这个模式的典型应用了。下面用图描述这样的一个过程。

这里建立了一个消息渠道，短信系统、邮件系统和微信系统都在监听这个渠道，一旦记账系统把交易消息发送到消息渠道，则监听这个渠道的各个系统就可以拿到这个消息，这样就能处理各自的任务了。它也有利于系统的拓展，比如现在新增一个彩信平台，只要让彩信平台去监听这个消息渠道便能得到对应的消息了。

我们可以知道以下两点：

 要有发送的消息渠道，让记账系统能够发送消息。要有订阅者（短信、邮件、微信等系统）订阅这个渠道的消息。

同样的，Redis 也是如此。首先来注册一个订阅的客户端，这个时候使用 SUBSCRIBE 命令。

比如监听一个叫作 chat 的渠道，这个时候我们需要先打开一个客户端，这里记为客户端 1，然后输入命令：

SUBSCRIBE chat

这个时候客户端 1 就会订阅了一个叫作 chat 渠道的消息了。之后打开另外一个客户端，记为客户端 2，输入命令：

publish chat "let's go!!"

这个时候客户端 2 就向渠道 chat 发送消息：

"let's go!!"

我们观察客户端 1，就可以发现已经收到了消息，并有对应的信息打印出来。Redis 的发布订阅过程如下图所示。

当发布消息的时候，对应的客户端已经获取到了这个信息。

下面在 Spring 的工作环境中展示如何配置发布订阅模式。首先提供接收消息的类，它将实现 org.springframework.data.redis.connection.MessageListener 接口，并实现接口定义的方法 public void onMessage（Message message,byte[]pattern），Redis 发布订阅监听类代码如下所示。

/*** imports ***/
public class RedisMessageListener implements MessageListener {private RedisTemplate redisTemplate;/*** 此处省略redisTemplate的 setter和getter方法 ***/@Overridepublic void onMessage(Message message, byte[] bytes) {// 获取消息byte[] body = message.getBody();// 使用值序列化器转换String msgBody = (String) getRedisTemplate().getValueSerializer().deserialize(body);System.err.println(msgBody);// 获取 channelbyte[] channel = message.getChannel();// 使用字符串序列化器转换String channelStr = (String) getRedisTemplate().getStringSerializer().deserialize(channel);System.err.println(channelStr);// 渠道名称转换String bytesStr = new String(bytes);System.err.println(bytesStr);}
}

为了在 Spring 中使用这个类，需要对其进行配置。

<bean id="redisMsgListener" class="com.redis.listener.RedisMessageListener"><property name="redisTemplate" ref="redisTemplate"/>
</bean>

这样就在 Spring 上下文中定义了监听类。

有了监听类还不能进行测试。为了进行测试，要给一个监听容器，在 Spring 中已有类 org.springframework.data.redis.listener.RedisMessageListenerContainer。它可以用于监听 Redis 的发布订阅消息，下面的配置就是为了实现这个功能，大家可以通过注释来了解它的配置要点。

<bean id="topicContainer"class="org.springframework.data.redis.listener.RedisMessageListenerContainer" destroy-method="destroy"><!--Redis连接工厂 --><property name="connectionFactory" ref="connectionFactory" /><!--连接池，这里只要线程池生存，才能继续监听 --><property name="taskExecutor"><beanclass="org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler"><property name="poolSize" value="3" /></bean></property><!--消息监听Map --><property name="messageListeners"><map><!-- 配置监听者，key-ref和bean id定义一致 --><entry key-ref="redisMsgListener"><!--监听类 --><bean class="org.springframework.data.redis.listener.ChannelTopic"><constructor-arg value="chat" /></bean></entry></map></property>
</bean>

这里配置了线程池，这个线程池将会持续的生存以等待消息传入，而这里配置了容器用 id 为 redisMsgListener的Bean 进行对渠道 chat 的监听。当消息通过渠道 chat 发送的时候，就会使用 id 为 redisMsgListener 的 Bean 进行处理消息。

通过以下代码测试 Redis 发布订阅。

public static void main(String[] args)    {ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");RedisTemplate redisTemplate = applicationContext.getBean(RedisTemplate.class);String channel = "chat";redisTemplate.convertAndSend(channel, "I am lazy!!");
}

convertAndSend 方法就是向渠道 chat 发送消息的，当发送后对应的监听者就能监听到消息了。运行它，后台就会打出对应的消息。

Redis发布订阅模式相关推荐

Spring Boot 使用Redis发布订阅模式处理消息
Spring Boot 使用Redis发布订阅模式 1. Redis发布订阅模式 2. Spring Boot中订阅消息 2.1 Redis监听器容器配置 2.2 创建通道监听器 2.3 测试订阅功能 ...
redis发布/订阅模式
其实在很多的MQ产品中都存在这样的一个模式,我们常听到的一个例子就是邮件订阅的场景,什么意思呢,也就是说100个人订阅了你的博客,如果博主发表了文章,那么100个人就会同时收到通知邮件,除了这个场 ...
redis发布订阅模式详解
文章目录写在前面发布订阅的使用 SUBSCRIBE命令 PUBLISH命令注意发布.订阅客户端启动顺序! PUBSUB命令 PUNSUBSCRIBE命令 UNSUBSCRIBE命令 PSUBSC ...
Redis发布订阅模式实现原理
前言发布订阅系统在我们日常的工作中经常会使用到,这种场景大部分情况我们都是使用消息队列,常用的消息队列有 Kafka,RocketMQ,RabbitMQ,每一种消息队列都有其特性,很多时候我们可能不 ...
redis集群的发布订阅模式
项目开发过程中,遇到需要发消息的情况,是不是脑海里不自主的浮现kafka.rabbitmq等常用的消息队列?但如果消息非常简单,并且用量也不大,消息队列就会有点大材小用了吧,忽然想起了redis 也有 ...
SpringBoot整合redis实现发布订阅模式
Redis的发布订阅模式发布订阅(Pub/Sub):目前广泛使用的通信模型,它采用事件作为基本的通信机制,提供大规模系统所要求的松散耦合的交互模式:订阅者(如客户端)以事件订阅的方式表达出它有兴趣接 ...
Redis的发布订阅模式
本文源码参看:https://github.com/duktig666/learn-example/tree/5586febea31c2fb368e19fbdba11ed08afd463e0/Redi ...
java 阅发布模式_redis发布订阅模式
一前言虽然有消息队列,我们还是要了解一下redis发布订阅模式哟!!!!! 二发布订阅模式 PUBLISH 命令向通道发送信息,此客户端称为publisher 发布者: SUBSCRIBE 向命令 ...
Redis 发布订阅，小功能大用处，真没那么废材！
假设我们有这么一个业务场景,在网站下单支付以后,需要通知库存服务进行发货处理. 上面业务实现不难,我们只要让库存服务提供给相关的给口,下单支付之后只要调用库存服务即可. 后面如果又有新的业务,比如说积 ...

Redis发布订阅模式

Redis发布订阅模式相关推荐

最新文章

热门文章