springBoot实现redis 发布式监听消息队列
2020-06-08 16:31
120 查看
springBoot实现redis 发布式监听消息队列
1.定时器监听不同功能的消息
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; } }
3.发送消息
RedisTemplate redisTemplate; redisTemplate.convertAndSend(消息key,JSON.toJSONString("今天比较烦"));
2.接收消息代码
import com.alibaba.fastjson.JSON; import java.time.LocalDateTime; import java.util.regex.Matcher; import java.util.regex.Pattern; public class quest1{ public void test(String message) { Matcher matcher = Pattern.compile("\\{+").matcher(message); if (matcher.find()) { message = message.substring(matcher.start(), message.length()); } 处理结果message-- } }
相关文章推荐
- 企业级 SpringBoot 教程 (十四) 在springboot中用redis实现消息队列
- SpringBoot 基于Redis快速实现消息队列
- 使用jedis实现Redis消息队列(MQ)的发布(publish)和消息监听(subscribe)
- Java ActiveMQ简介以及springboot集成activeMQ实现消息队列监听以及实现MQ延迟
- Java ActiveMQ简介以及springboot集成activeMQ实现消息队列监听以及实现MQ延迟
- SpringBoot用redis实现消息队列(生产/消费+发布/订阅)
- 利用Redis实现消息队列原理
- Redis实现消息队列
- 一个Redis消息队列实现
- php+redis消息队列实现抢购功能
- redis实现有序的消息队列
- Redis实现消息队列
- 用redis实现支持优先级的消息队列
- Redis实现简单消息队列
- 用redis实现支持优先级的消息队列
- 利用Redis 实现消息队列
- 基于Redis实现分布式消息队列(3)
- SpringBoot2.X 整合RedisTemplate 简单实现消息队列
- SpringBoot非官方教程 | 第十四篇:在springboot中用redis实现消息队列
- redis消息队列的实现