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

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

2020-12-22 15:11子轩、破译者 Java教程

这篇文章主要介绍了SpringBoot利用redis集成消息队列的方法,需要的朋友可以参考下

一、pom文件依赖

									<dependency> 

									 　　<groupId>org.springframework.boot</groupId> 

									　　 <artifactId>spring-boot-starter-data-redis</artifactId> 

									</dependency>

二、创建消息接收者

变量、方法及构造函数进行标注，完成自动装配的工作。通过 @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("消息发送失败...");

									}

									}

									}