中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

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
婺源县| 社会| 九台市| 临潭县| 怀仁县| 黄骅市| 和硕县| 新宁县| 桐庐县| 安塞县| 四会市| 苏尼特右旗| 宕昌县| 五原县| 新沂市| 正阳县| 从江县| 荃湾区| 汉沽区| 卓资县| 保德县| 涿鹿县| 石柱| 乐东| 巴塘县| 英超| 岳池县| 隆安县| 平顶山市| 德阳市| 合江县| 绥芬河市| 武川县| 湾仔区| 榕江县| 普陀区| 民勤县| 平原县| 临夏市| 黑山县| 湖北省|