SpringBoot非官方教程 | 第十四篇：在springboot中用redis实现消息队列

﹏ヽ暗。殇╰゛Y 2022-06-13 08:12 123阅读 0赞

> 转载请标明出处：   
> [http://blog.csdn.net/forezp/article/details/71023652][http_blog.csdn.net_forezp_article_details_71023652]   
> 本文出自[方志朋的博客][Link 1]

这篇文章主要讲述如何在springboot中用reids实现消息队列。

## 准备阶段 ##

*  安装redis,可参考我的另一篇文章，[5分钟带你入门Redis][5_Redis]。
 *  java 1.8
 *  maven 3.0
 *  idea

## 环境依赖 ##

创建一个新的springboot工程，在其pom文件,加入spring-boot-starter-data-redis依赖：

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
            </dependency>
    
     
      
       1
       2
       3
       4
       5
      
     
      
       1
       2
       3
       4
       5

## 创建一个消息接收者 ##

REcevier类，它是一个普通的类，需要注入到springboot中。

public class Receiver { 
        private static final Logger LOGGER = LoggerFactory.getLogger(Receiver.class);
    
        private CountDownLatch latch;
    
        @Autowired
        public Receiver(CountDownLatch latch) {
            this.latch = latch;
        }
    
        public void receiveMessage(String message) {
            LOGGER.info("Received <" + message + ">");
            latch.countDown();
        }
    }
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
      
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16

## 注入消息接收者 ##

@Bean
        Receiver receiver(CountDownLatch latch) {
            return new Receiver(latch);
        }
    
        @Bean
        CountDownLatch latch() {
            return new CountDownLatch(1);
        }
    
        @Bean
        StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
            return new StringRedisTemplate(connectionFactory);
        }
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
      
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15

## 注入消息监听容器 ##

在spring data redis中，利用redis发送一条消息和接受一条消息，需要三样东西：

*  一个连接工厂
 *  一个消息监听容器
 *  Redis template

上述1、3步已经完成，所以只需注入消息监听容器即可：

@Bean
        RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                                MessageListenerAdapter listenerAdapter) {
    
            RedisMessageListenerContainer container = new RedisMessageListenerContainer();
            container.setConnectionFactory(connectionFactory);
            container.addMessageListener(listenerAdapter, new PatternTopic("chat"));
    
            return container;
        }
    
        @Bean
        MessageListenerAdapter listenerAdapter(Receiver receiver) {
            return new MessageListenerAdapter(receiver, "receiveMessage");
        }
    
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
       17
      
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
       17

## 测试 ##

在springboot入口的main方法：

public static void main(String[] args) throws Exception{
            ApplicationContext ctx =  SpringApplication.run(SpringbootRedisApplication.class, args);
    
            StringRedisTemplate template = ctx.getBean(StringRedisTemplate.class);
            CountDownLatch latch = ctx.getBean(CountDownLatch.class);
    
            LOGGER.info("Sending message...");
            template.convertAndSend("chat", "Hello from Redis!");
    
            latch.await();
    
            System.exit(0);
        }
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
      
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14

先用redisTemplate发送一条消息，接收者接收到后，打印出来。启动springboot程序，控制台打印：

> 2017-04-20 17:25:15.536 INFO 39148 — \[ main\] com.forezp.SpringbootRedisApplication : Sending message…   
> 2017-04-20 17:25:15.544 INFO 39148 — \[ container-2\] com.forezp.message.Receiver : 》Received

## 源码下载： ##

[https://github.com/forezp/SpringBootLearning][https_github.com_forezp_SpringBootLearning]

## 参考资料 ##

[messaging-redis][]

[http_blog.csdn.net_forezp_article_details_71023652]: http://blog.csdn.net/forezp/article/details/71023652
[Link 1]: http://blog.csdn.net/forezp
[5_Redis]: http://blog.csdn.net/forezp/article/details/61471712
[https_github.com_forezp_SpringBootLearning]: https://github.com/forezp/SpringBootLearning
[messaging-redis]: https://spring.io/guides/gs/messaging-redis/