SpringBoot中的消息隊(duì)列怎么利用redis進(jìn)行集成？針對這個(gè)問題，這篇文章詳細(xì)介紹了相對應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡單易行的方法。
創(chuàng)新互聯(lián)專注于柳河網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗(yàn)。 熱誠為您提供柳河營銷型網(wǎng)站建設(shè)，柳河網(wǎng)站制作、柳河網(wǎng)頁設(shè)計(jì)、柳河網(wǎng)站官網(wǎng)定制、微信小程序開發(fā)服務(wù)，打造柳河網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供柳河網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。
一、pom文件依賴
org.springframework.boot spring-boot-starter-data-redis
二、創(chuàng)建消息接收者
變量、方法及構(gòu)造函數(shù)進(jìn)行標(biāo)注，完成自動(dòng)裝配的工作。 通過 @Autowired的使用來消除 set ，get方法。
重慶分公司
重慶分公司
@Autowired public Receiver(CountDownLatch latch) {
this.latch = latch;
}
public void receiveMessage(String message) {
LOGGER.info("收到的消息： <" + message + ">"); latch.countDown(); } }以上基本條件達(dá)成后，以下是實(shí)現(xiàn)的三要素：
一個(gè)連接工廠
一個(gè)消息監(jiān)聽容器
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); }四、注入消息監(jiān)聽容器
//必要的redis消息隊(duì)列連接工廠
@Bean
Receiver receiver(CountDownLatch latch) {
return new Receiver(latch);
}
//必要的redis消息隊(duì)列連接工廠
@Bean
CountDownLatch latch() {
return new CountDownLatch(1);
}
//redis模板
@Bean
StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
return new StringRedisTemplate(connectionFactory);
}
//注入消息監(jiān)聽器容器
@Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,MessageListenerAdapter listenerAdapter) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.addMessageListener(listenerAdapter, new PatternTopic("msg"));
return container;
}
//注入消息監(jiān)聽器容器
@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("我要發(fā)送消息咯...");
template.convertAndSend("msg", "歡迎使用redis的消息隊(duì)列!");
try {
//發(fā)送消息連接等待中
logger.info("消息正在發(fā)送...");
latch.await();
} catch (InterruptedException e) {
logger.info("消息發(fā)送失敗...");
}
}
}關(guān)于SpringBoot中的消息隊(duì)列怎么利用redis進(jìn)行集成問題的解答就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
