SpringBoot利用redis集成消息队列的方法
一、pom文件依赖
org.springframework.boot spring-boot-starter-data-redis
二、创建消息接收者
变量、方法及构造函数进行标注，完成自动装配的工作。通过@Autowired的使用来消除set，get方法。
@AutowiredpublicReceiver(CountDownLatchlatch){
this.latch=latch;
}
publicvoidreceiveMessage(Stringmessage){
LOGGER.info("收到的消息：<"+message+">");latch.countDown();}}
以上基本条件达成后，以下是实现的三要素：
一个连接工厂
一个消息监听容器
Redistemplate
三、在application.java注入消息接收者
@BeanReceiverreceiver(CountDownLatchlatch){
returnnewReceiver(latch);}
@BeanCountDownLatchlatch(){
returnnewCountDownLatch(1);}
@BeanStringRedisTemplatetemplate(RedisConnectionFactoryconnectionFactory){
returnnewStringRedisTemplate(connectionFactory);}
四、注入消息监听容器
//必要的redis消息队列连接工厂
@Bean
Receiverreceiver(CountDownLatchlatch){
returnnewReceiver(latch);
}
//必要的redis消息队列连接工厂
@Bean
CountDownLatchlatch(){
returnnewCountDownLatch(1);
}
//redis模板
@Bean
StringRedisTemplatetemplate(RedisConnectionFactoryconnectionFactory){
returnnewStringRedisTemplate(connectionFactory);
}
//注入消息监听器容器
@Bean
RedisMessageListenerContainercontainer(RedisConnectionFactoryconnectionFactory,MessageListenerAdapterlistenerAdapter){
RedisMessageListenerContainercontainer=newRedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.addMessageListener(listenerAdapter,newPatternTopic("msg"));
returncontainer;
}
//注入消息监听器容器
@Bean
MessageListenerAdapterlistenerAdapter(Receiverreceiver){
returnnewMessageListenerAdapter(receiver,"receiveMessage");
}
五、单元测试
importjava.util.concurrent.CountDownLatch;
importorg.junit.Test;
importorg.junit.runner.RunWith;
importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.boot.test.context.SpringBootTest;
importorg.springframework.context.ApplicationContext;
importorg.springframework.data.redis.core.StringRedisTemplate;
importorg.springframework.test.context.junit4.SpringRunner;
importcom.Application;
@RunWith(SpringRunner.class)
@SpringBootTest(classes=Application.class)
publicclassMsgQueueTest{
@Autowired
protectedApplicationContextctx;
privatestaticfinalLoggerlogger=LoggerFactory.getLogger(MsgQueueTest.class);
@Test
publicvoidSendMsg(){
StringRedisTemplatetemplate=ctx.getBean(StringRedisTemplate.class);
CountDownLatchlatch=ctx.getBean(CountDownLatch.class);
logger.info("我要发送消息咯...");
template.convertAndSend("msg","欢迎使用redis的消息队列!");
try{
//发送消息连接等待中
logger.info("消息正在发送...");
latch.await();
}catch(InterruptedExceptione){
logger.info("消息发送失败...");
}
}
}
总结
以上所述是小编给大家介绍的SpringBoot利用redis集成消息队列的方法，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。