redis 发布订阅核心代码
2022/2/16 19:11:43
本文主要是介绍redis 发布订阅核心代码,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
-
注入监听需要的bean
/** * 消息监听bean注入 * @return */ @Bean MessageListenerAdapter messageListener() { //RedisMsgListener 处理监听消息的逻辑,自定义 return new MessageListenerAdapter( new RedisMsgListener() ); } /** * redis 监听容器实例化bean注入,并指定对应的发布主题 * @param factory 参数 * @return 结果 */ @Bean RedisMessageListenerContainer redisContainer(RedisConnectionFactory factory) { final RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(factory); //设置订阅的消息主题 container.addMessageListener(messageListener(), new ChannelTopic( "siyuan:websocket:message" )); return container; }
- 监听订阅的消息处理类似 消费者
@Component public class RedisMsgListener implements MessageListener { private static final Logger log = LoggerFactory.getLogger(RedisMsgListener.class); @Override public void onMessage(Message message, byte[] pattern) { log.info("消息订阅成功{}", message); } }
- 消息发布 类似生产者
redisTemplate.convertAndSend("siyuan:websocket:message","发送消息");
这篇关于redis 发布订阅核心代码的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-31Tiny RDM:你的下一代Redis桌面GUI神器-icode9专业技术文章分享
- 2024-03-21redisinsight-v2
- 2024-02-26Typed property App\Api\Mapper\GamePropsConfigMapper::$apiRedis must not be accessed before initia-icode9专业技术文章分享
- 2024-02-21redisson getlock
- 2024-02-20redis config
- 2024-02-20redis leaderboard
- 2024-01-23缓存选型:Redis or MemCache
- 2024-01-22面试官:Redis持久化能关吗?怎么关?
- 2024-01-21Redis压测工具redis-benchmark-icode9专业技术文章分享
- 2024-01-19这才是你应该了解的Redis数据结构!