91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

如何監聽redis消息隊列

小新
718
2020-12-21 11:12:55
欄目: 云計算

如何監聽redis消息隊列

監聽redis消息隊列的示例:

springBoot實現redis發布式監聽消息隊列,定時器監聽不同功能的消息,代碼:

import org.springframework.context.annotation.Bean;

import org.springframework.data.redis.connection.RedisConnectionFactory;

import org.springframework.data.redis.listener.PatternTopic;

import org.springframework.data.redis.listener.RedisMessageListenerContainer;

import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;

import org.springframework.stereotype.Component;

@Component

public class RedisMessageListener {

private static final String RECEIVE_NAME = "test";

/**

* 監聽quest1信息

*/

@Bean

public MessageListenerAdapter quest1() {

return new MessageListenerAdapter(new quest1(), RECEIVE_NAME);

}

/**

* 定義消息監聽者容器

* @param connectionFactory 連接工廠

* @param quest1 監聽quest1

* @return RedisMessageListenerContainer

*/

@Bean

public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,

MessageListenerAdapter quest1) {

RedisMessageListenerContainer listenerContainer = new RedisMessageListenerContainer();

listenerContainer.setConnectionFactory(connectionFactory);

listenerContainer.addMessageListener(接收消息--quest1, new PatternTopic("消息key"));

return listenerContainer;

}

}

0
策勒县| 武义县| 文登市| 泸定县| 旬阳县| 榆社县| 巴林右旗| 长宁区| 沽源县| 波密县| 谷城县| 东乌珠穆沁旗| 承德市| 凌云县| 温泉县| 拜泉县| 惠水县| 西峡县| 同心县| 铜山县| 徐汇区| 松滋市| 博乐市| 融水| 滦平县| 微山县| 绵竹市| 崇礼县| 延安市| 洛宁县| 故城县| 建平县| 江油市| 邢台县| 德化县| 敖汉旗| 南部县| 无为县| 五常市| 邹平县| 荥经县|