如何在Spring Boot中使用Redis发布订阅功能_配置RedisMessageListenerContainer

P粉602998670

P粉602998670

2026-07-10

917人浏览

原创

redismessagelistenercontainer 必须手动声明 bean,spring boot 2.0+ 不自动配置;监听器需实现 messagelistener 并通过 addmessagelistener() 注册,不可用 @eventlistener;序列化需与发布端一致,推荐统一使用 stringredistemplate。

如何在spring boot中使用redis发布订阅功能_配置redismessagelistenercontainer

RedisMessageListenerContainer 配置必须手动声明 Bean

Spring Boot 2.0+ 默认不自动配置 RedisMessageListenerContainer,哪怕你引入了 spring-boot-starter-data-redis 并配好了 RedisConnectionFactory。不显式定义这个 Bean,@EventListener 或监听器类根本不会被注册,订阅行为静默失效。

常见错误现象:RedisMessageListenerContainer 没有启动日志(如 “Starting RedisMessageListenerContainer”),发布消息后监听器无任何响应,也没有报错。

正确做法是手动声明 Bean,并确保它依赖已配置的 RedisConnectionFactory

@Bean
public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory) {
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setTaskExecutor(new ThreadPoolTaskExecutor()); // 避免阻塞主线程
    return container;
}

监听器注册要用 addMessageListener(),不是 @EventListener

Spring 的 @EventListener 只适用于 Spring 事件(ApplicationEvent),对 Redis 发布/订阅消息完全无效。必须通过 RedisMessageListenerContainer.addMessageListener() 显式注册监听器实例。

典型误区:写一个带 @Component@EventListener 的类,以为能收到 Redis 消息——结果永远收不到。

实操建议:

Redis 8.2.3
Redis 8.2.3

Redis 8.2.3 是一款安全优先的高性能键值存储系统。该版本紧急修复了可能引发远程代码执行(RCE)的高危漏洞(CVE-2025-62507),并解决了 HyperLogLog 及 Cuckoo Filter 等数据结构在特定场景下的崩溃问题。建议所有用户立即升级,以保障生产环境的系统稳定与数据安全。

下载
  • 监听器需实现 MessageListener 接口(或继承 KeyExpirationEventMessageListener 等子类)
  • PatternTopic 订阅通配符频道(如 PatternTopic("user:*")),用 ChannelTopic 订阅精确频道(如 ChannelTopic("user.login")
  • 注册时传入监听器实例和 Topic 列表,例如:container.addMessageListener(myListener, new ChannelTopic("order.created"))

消息序列化问题常导致 onMessage() 收到 null 或乱码

默认 RedisMessageListenerContainer 使用 JdkSerializationRedisSerializer,但如果你的生产者用的是 StringRedisTemplate(即 StringRedisSerializer),两边序列化方式不一致,onMessage(Message, byte[]) 中的 message.getBody() 会是乱码或空字节数组。

解决方案取决于你的使用场景:

  • 统一用 StringRedisTemplate:配置容器时设置 setTopicSerializer(new StringRedisSerializer())(注意:该方法仅在 Spring Data Redis 2.6+ 可用)
  • 降级兼容老版本:自定义 MessageListener,在 onMessage() 内手动用 new String(message.getBody(), StandardCharsets.UTF_8) 解码
  • 避免混用:不要让 RedisTemplateStringRedisTemplate 对同一组频道收发消息

发布端必须用 RedisTemplate 或 StringRedisTemplate 的 convertAndSend()

不能用 execute() + 原生 PUBLISH 命令绕过序列化逻辑,否则监听器收到的消息体无法被反序列化(尤其当容器配置了非默认序列化器时)。

正确发布方式只有两个:

  • redisTemplate.convertAndSend("channel.name", "hello") —— 要求 redisTemplate 的 value serializer 与监听器解码方式匹配
  • stringRedisTemplate.convertAndSend("channel.name", "hello") —— 最简单,推荐用于纯字符串消息

容易忽略的一点:convertAndSend() 是异步非阻塞的,但若连接池耗尽或 Redis 不可用,它会抛出 RedisConnectionFailureException,需在外层捕获并处理,而不是假设“发了就一定到”。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

redis

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
spring框架介绍
spring框架介绍

本专题整合了spring框架相关内容,想了解更多详细内容,请阅读专题下面的文章。

2025.08.06

1153

22

Java Spring Security 与认证授权
Java Spring Security 与认证授权

本专题系统讲解 Java Spring Security 框架在认证与授权中的应用,涵盖用户身份验证、权限控制、JWT与OAuth2实现、跨站请求伪造(CSRF)防护、会话管理与安全漏洞防范。通过实际项目案例,帮助学习者掌握如何 使用 Spring Security 实现高安全性认证与授权机制,提升 Web 应用的安全性与用户数据保护。

2026.01.26

194

25

li是什么元素
li是什么元素

li是HTML标记语言中的一个元素,用于创建列表。li代表列表项,它是ul或ol的子元素,li标签的作用是定义列表中的每个项目。本专题为大家li元素相关的各种文章、以及下载和课程。

2023.08.03

596

5

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.02

1884

19

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.14

1558

11

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.02

2448

6

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

518

6

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

524

6

mysql和redis怎么保证双写一致性
mysql和redis怎么保证双写一致性

确保 mysql 和 redis 双写一致性的技术包括:1、事务性更新:同时更新 mysql 和 redis,保证一致性;2、主从复制:mysql 主服务器更改同步到 redis 从服务器;3、基于事件的更新:mysql 记录更改并发送到 redis等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

2426

6

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

进程与SOCKET
进程与SOCKET

共6课时 | 0.5万人学习

Redis+MySQL数据库面试教程
Redis+MySQL数据库面试教程

共72课时 | 9万人学习