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

溫馨提示×

如何監聽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
武汉市| 陈巴尔虎旗| 龙川县| 西充县| 文山县| 屏山县| 丹阳市| 迭部县| 日照市| 祁连县| 贺州市| 闵行区| 合川市| 文水县| 公安县| 买车| 全南县| 新绛县| 宜春市| 中江县| 新巴尔虎右旗| 洛川县| 喀什市| 锡林郭勒盟| 浠水县| 淮阳县| 安阳县| 汉川市| 进贤县| 乌兰浩特市| 永嘉县| 南开区| 皮山县| 沅江市| 金门县| 佛学| 临桂县| 霍山县| 陇川县| 赣榆县| 阳东县|