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

溫馨提示×

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
龙川县| 广南县| 华蓥市| 平遥县| 哈密市| 垦利县| 吴江市| 乐至县| 永济市| 舟山市| 新兴县| 青龙| 哈巴河县| 松溪县| 阳新县| 越西县| 永平县| 张掖市| 曲麻莱县| 房产| 惠水县| 平远县| 五常市| 翁牛特旗| 乌鲁木齐县| 乐东| 丘北县| 高邑县| 文山县| 东山县| 普格县| 新巴尔虎左旗| 页游| 宣汉县| 屏东市| 姜堰市| 江川县| 搜索| 临清市| 开远市| 祁连县|