亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

java如何監聽redis消息隊列

小新
1375
2020-12-25 19:05:30
欄目: 云計算

java監聽redis消息隊列的方法:可以使用springBoot實現redis發布式監聽消息隊列,定時器監聽不同功能的消息。

java如何監聽redis消息隊列

java監聽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
鹤峰县| 华池县| 蒙城县| 垫江县| 册亨县| 汨罗市| 华安县| 宜黄县| 滦南县| 昔阳县| 嘉鱼县| 澳门| 营山县| 舟山市| 延长县| 额尔古纳市| 都江堰市| 本溪| 凉城县| 土默特左旗| 长武县| 磐安县| 大洼县| 鸡泽县| 稷山县| 且末县| 普兰县| 巴青县| 宝丰县| 石家庄市| 连云港市| 任丘市| 三台县| 武穴市| 本溪市| 水富县| 上高县| 崇明县| 昭通市| 岢岚县| 东港市|