redis消息队列的实现方法
发表于：2025-01-31 作者：千家信息网编辑
千家信息网最后更新 2025年01月31日，这篇文章主要讲解了"redis消息队列的实现方法"，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习"redis消息队列的实现方法"吧！方式一：通过list的
千家信息网最后更新 2025年01月31日redis消息队列的实现方法
这篇文章主要讲解了"redis消息队列的实现方法"，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习"redis消息队列的实现方法"吧！
方式一：通过list的阻塞读取命令，blpop或者brpop
消费者
public class Consumer extends DemoApplicationTests{ @Test public void consume(){ int timeout = 0;//永不超时 String key = "test_que"; //list集合 第一个元素为key值，第二个元素为弹出的元素值;当超时返回[null] while(true){ List生产者
public class Productor extends DemoApplicationTests { @Test public void generateMsg() { String key = "test_que"; redisTemplate.opsForList().leftPush(key,"hht2"); }}方式二：Pub/Sub（发布/订阅）使用的 spring boot
依赖包
org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-data-redis org.springframework.boot spring-boot-starter-test test org.apache.commons commons-pool2
配置类
@Configuration@AutoConfigureAfter(RedisAutoConfiguration.class)@EnableCachingpublic class RedisConfig extends CachingConfigurerSupport { /** * 配置自定义redisTemplate * @return */ @Bean RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate template = new RedisTemplate<>(); template.setConnectionFactory(redisConnectionFactory); //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值 Jackson2JsonRedisSerializer serializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper mapper = new ObjectMapper(); mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); serializer.setObjectMapper(mapper); template.setValueSerializer(serializer); //使用StringRedisSerializer来序列化和反序列化redis的key值 template.setKeySerializer(new StringRedisSerializer()); template.setHashKeySerializer(new StringRedisSerializer()); template.setHashValueSerializer(serializer); template.afterPropertiesSet(); return template; } /** * 序列化定制 * * @return */ @Bean public Jackson2JsonRedisSerializer 模拟消息发布类
@Servicepublic class RedisPubSub { private static final Logger logger = LoggerFactory.getLogger(RedisPubSub.class); @Autowired private RedisTemplate redisTemplate; private ChannelTopic topic = new ChannelTopic("/redis/pubsub"); @Scheduled(initialDelay = 5000, fixedDelay = 10000) private void schedule() { logger.info("publish message"); publish("admin", "hey you must go now!"); } /** * 推送消息 * * @param publisher * @param message */ public void publish(String publisher, String content) { logger.info("message send {} by {}", content, publisher); redisTemplate.convertAndSend(topic.getTopic(), content); }} 模拟消息接收类
@Componentpublic class MessageSubscriber { Logger logger = LoggerFactory.getLogger(MessageSubscriber.class); public void onMessage(String message, String pattern) { logger.info("topic {} received {} ", pattern, message); }}启动类
@SpringBootApplication@EnableSchedulingpublic class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); }}感谢各位的阅读，以上就是"redis消息队列的实现方法"的内容了，经过本文的学习后，相信大家对redis消息队列的实现方法这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是，小编将为大家推送更多相关知识点的文章，欢迎关注！
消息
队列
方法
元素
序列
学习
内容
方式
推送
订阅
配置
阻塞
命令
容器
就是
思路
情况
文章
更多
永不
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
动物园管理员游戏服务器维护
国资网络安全概念
sd卡损坏无法存数据库
深圳能耗管理软件开发费用
肾癌数据库有利于
c语言服务器流程图
深圳市软件开发费人员用标准
黑芒君服务器被炸的样子
本科毕业论文进入数据库吗
绍兴企业软件开发流程
网络安全法案是什么
数据库查询列少
家庭教育与网络安全重庆
扫描二维码的数据库
服务器端口监控软件
浪潮服务器如何选传统模式
组装机使用服务器cpu
方舟服务器怎么开荒
福建省关于软件开发企业
办公系统软件开发调试
移动端软件开发的意义
宁海应用软件开发教程
软件开发师雇佣条件
天龙八部手游聊天服务器维护
网络安全法的构成
扬州浪潮服务器供应商
更改浏览器代理服务器
cago韩国服务器维护
临海库存软件开发设备制造
福建省关于软件开发企业
