SpringBoot利用redis集成消息队列的方法

<dependency>  　　<groupId>org.springframework.boot</groupId> 　　 <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>

@Autowired public Receiver(CountDownLatch latch) { this.latch = latch; } public void receiveMessage(String message) { LOGGER.info("收到的消息： <" + message + ">"); latch.countDown(); } }

@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); }

//必要的redis消息队列连接工厂@BeanReceiver receiver(CountDownLatch latch) {return new Receiver(latch);}//必要的redis消息队列连接工厂@BeanCountDownLatch latch() {return new CountDownLatch(1);}//redis模板@BeanStringRedisTemplate template(RedisConnectionFactory connectionFactory) {return new StringRedisTemplate(connectionFactory);}//注入消息监听器容器@BeanRedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,MessageListenerAdapter listenerAdapter) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);container.addMessageListener(listenerAdapter, new PatternTopic("msg"));return container;}//注入消息监听器容器@BeanMessageListenerAdapter listenerAdapter(Receiver receiver) {return new MessageListenerAdapter(receiver, "receiveMessage");}

import java.util.concurrent.CountDownLatch;import org.junit.Test;import org.junit.runner.RunWith;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.test.context.SpringBootTest;import org.springframework.context.ApplicationContext;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.test.context.junit4.SpringRunner;import com.Application;@RunWith(SpringRunner.class)@SpringBootTest(classes = Application.class)public class MsgQueueTest {@Autowiredprotected ApplicationContext ctx;private static final Logger logger = LoggerFactory.getLogger(MsgQueueTest.class);@Testpublic void SendMsg() {StringRedisTemplate template = ctx.getBean(StringRedisTemplate.class);CountDownLatch latch = ctx.getBean(CountDownLatch.class);logger.info("我要发送消息咯...");template.convertAndSend("msg", "欢迎使用redis的消息队列!");try {//发送消息连接等待中logger.info("消息正在发送...");latch.await();} catch (InterruptedException e) {logger.info("消息发送失败...");}}}