spring boot 用redis进行发布订阅
异步消息的方式有很多,这篇博客详情如何用redis进行发布订阅,
完成这个示例只要要三个文件
1.redis消息监听配置
@Configurationpublicclass RedisListenerConfig {
? ? /**? ? * redis消息监听器容器
? ? * 能增加多个监听不同话题的redis监听器,只要要把消息监听器和相应的消息订阅解决器绑定,该消息监听器
? ? * 通过反射技术调使用消息订阅解决器的相关方法进行少量业务解决
? ? * @param connectionFactory
? ? * @param listenerAdapter
? ? * @return*/? ? @Bean
? ? RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? MessageListenerAdapter listenerAdapter
? ? ) {
? ? ? ? RedisMessageListenerContainer container =new RedisMessageListenerContainer();
? ? ? ? container.setConnectionFactory(connectionFactory);
? ? ? ? //能增加多个 messageListenercontainer.addMessageListener(listenerAdapter,newPatternTopic(“index”));
? ? ? ? return container;
? ? }
? ? /**? ? * 消息监听器适配器,绑定消息解决器,利使用反射技术调使用消息解决器的业务方法
? ? * @param redisReceiver
? ? * @return*/? ? @Bean
? ? MessageListenerAdapter listenerAdapter(RedisReceiver redisReceiver) {
? ? ? ? System.out.println(“消息适配器进来了”);
? ? ? ? returnnewMessageListenerAdapter(redisReceiver, “receiveMessage”);
? ? }
? ? //用默认的工厂初始化redis操作模板? ? @Bean
? ? StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
? ? ? ? returnnew StringRedisTemplate(connectionFactory);
? ? }
}
2.消息解决
@Servicepublicclass RedisReceiver {
? ? publicvoid receiveMessage(String message) {
? ? ? ? System.out.println(“消息来了:”+message);
? ? ? ? //这里是收到通道的消息之后执行的方法? ? }
}
3.一个发送消息的定时器
//定时器@EnableScheduling
@Componentpublicclass TestSenderController {
? ? @Autowired
? ? private StringRedisTemplate stringRedisTemplate;
? ? //向redis消息队列index通道发布消息@Scheduled(fixedRate = 3000)
? ? publicvoid sendMessage(){
? ? ? ? stringRedisTemplate.convertAndSend(“index”,String.valueOf(Math.random()));
? ? }
}
运行结果如图
{附}:大家能点击加入群:【java高级架构进阶】:https://jq.qq.com/?_wv=1027&k=575y0Kj里面有Java高级大牛直播讲解知识点 走的就是高端路线(假如你想跳槽换工作 但是技术又不够 或者者工作上遇到了瓶颈 我这里有一个JAVA的免费直播课程 讲的是高端的知识点基础不好的误入哟 只需你有1-5年的开发经验能加群找我要课堂链接 注意:是免费的 没有开发经验误入哦)
1. 本站所有资源来源于用户上传和网络,如有侵权请邮件联系站长!
2. 分享目的仅供大家学习和交流,您必须在下载后24小时内删除!
3. 不得使用于非法商业用途,不得违反国家法律。否则后果自负!
4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!
5. 如有链接无法下载、失效或广告,请联系管理员处理!
6. 本站资源售价只是摆设,本站源码仅提供给会员学习使用!
7. 如遇到加密压缩包,请使用360解压,如遇到无法解压的请联系管理员
开心源码网 » spring boot 用redis进行发布订阅