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

溫馨提示×

如何監聽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
宣威市| 志丹县| 连城县| 松阳县| 滕州市| 仁化县| 繁昌县| 丰县| 高阳县| 左权县| 乌鲁木齐市| 金寨县| 瑞安市| 临湘市| 湘西| 九龙县| 铁力市| 万州区| 房山区| 胶州市| 湘潭市| 洪江市| 绵竹市| 金阳县| 五家渠市| 中超| 黑山县| 尚志市| 昌图县| 河北省| 满城县| 会泽县| 虞城县| 永吉县| 聂荣县| 大悟县| 新巴尔虎左旗| 进贤县| 万荣县| 朔州市| 阳新县|