【转】redis 消息队列发布订阅模式spring boot实现

时间：2017-10-27 15:47:37 阅读：155 评论：0 收藏：0 [点我收藏+]

最近做项目的时候写到一个事件推送的场景。之前的实现方式是起job一直查询数据库，看看有没有最新的消息。这种方式非常的不优雅，反正我是不能忍，由于羡慕本身就依赖redis，刚好redis 也有消息队列的功能，就简单的使用redis 来实现这个消息推送。

之前参考网上的例子，发现全部来自一个地方，spring 官方的一个例子，某些打着“非官方例子”的头号，还是一样就复制了一下官方的例子，怕是自己都没搞懂代码，原封不动的贴上来了，这边顺便提一句国内多数的博客都是相互“借鉴”，有些自己都没理解就把别人的内容 ctrl c ctrl v 过来了。这边我不贴官方的代码，点这里传送官方的例子。顺便提一句。CountDownLatch 对象其实跟这个内容是无关的，这点我要提一下，具体功能我不多说，官方例子是为了让程序发送到 redis 通道里面的消息被程序读取之后才结束程序而引入的类。

不多说直接上代码

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39

/**redis 消息处理器*/
@Component
public class MessageReceiver {
 
/**接收消息的方法*/
public void receiveMessage(String message){
System.out.println(message);
}
 
}
 
 
@Configuration
public class RedisConfig {
@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter) {
 
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
//订阅了一个叫chat 的通道
container.addMessageListener(listenerAdapter, new PatternTopic("chat"));
//这个container 可以添加多个 messageListener
return container;
}
 
@Bean
MessageListenerAdapter listenerAdapter(MessageReceiver receiver) {
//这个地方 是给messageListenerAdapter 传入一个消息接受的处理器，利用反射的方法调用“receiveMessage”
//也有好几个重载方法，这边默认调用处理器的方法 叫handleMessage 可以自己到源码里面看
return new MessageListenerAdapter(receiver, "receiveMessage");
}
 
/**redis 读取内容的template 这边跟本工程无关，可以不配置*/
@Bean
StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
return new StringRedisTemplate(connectionFactory);
}
}