SpringBoot中的消息队列怎么利用redis进行集成
SpringBoot中的消息队列怎么利用redis进行集成?针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
创新互联专注于柳河网站建设服务及定制,我们拥有丰富的企业做网站经验。 热诚为您提供柳河营销型网站建设,柳河网站制作、柳河网页设计、柳河网站官网定制、微信小程序开发服务,打造柳河网络公司原创品牌,更为您提供柳河网站排名全网营销落地服务。
一、pom文件依赖
org.springframework.boot spring-boot-starter-data-redis
二、创建消息接收者
变量、方法及构造函数进行标注,完成自动装配的工作。 通过 @Autowired的使用来消除 set ,get方法。
@Autowired public Receiver(CountDownLatch latch) { this.latch = latch; } public void receiveMessage(String message) { LOGGER.info("收到的消息: <" + message + ">"); latch.countDown(); } }
以上基本条件达成后,以下是实现的三要素:
一个连接工厂
一个消息监听容器
Redis template
三、在application.java注入消息接收者
@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消息队列连接工厂 @Bean Receiver receiver(CountDownLatch latch) { return new Receiver(latch); } //必要的redis消息队列连接工厂 @Bean CountDownLatch latch() { return new CountDownLatch(1); } //redis模板 @Bean StringRedisTemplate template(RedisConnectionFactory connectionFactory) { return new StringRedisTemplate(connectionFactory); } //注入消息监听器容器 @Bean RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,MessageListenerAdapter listenerAdapter) { RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(connectionFactory); container.addMessageListener(listenerAdapter, new PatternTopic("msg")); return container; } //注入消息监听器容器 @Bean MessageListenerAdapter 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 { @Autowired protected ApplicationContext ctx; private static final Logger logger = LoggerFactory.getLogger(MsgQueueTest.class); @Test public 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("消息发送失败..."); } } }
关于SpringBoot中的消息队列怎么利用redis进行集成问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注创新互联行业资讯频道了解更多相关知识。
当前文章:SpringBoot中的消息队列怎么利用redis进行集成
文章来源:http://ybzwz.com/article/ijigde.html