一个 redismessagelistenercontainer 可注册多个 messagelistener，需多次调用 addmessagelistener，支持 channeltopic 和 patterntopic 混合订阅；必须显式配置 threadpooltaskexecutor 防止线程爆炸；手动注册比 @redislistener 更适合多频道生产场景；需为每个 onmessage 添加 try-catch 避免容器中断。
多个 MessageListener 怎么注册到同一个 RedisMessageListenerContainer
一个 RedisMessageListenerContainer 实例可以同时管理多个监听器，无需为每个频道起一个容器。关键在于调用 addMessageListener 多次，每次传入不同监听器和对应频道（Topic）：
-
addMessageListener第一个参数是MessageListener实现类实例，第二个参数是Topic（如new ChannelTopic("order")或new PatternTopic("log.*")） - 支持混合注册：既可订阅具体频道（
ChannelTopic），也可用通配符模式（PatternTopic），但注意 Redis 服务端对 pattern 订阅有性能开销 - 若多个监听器监听同一频道，消息会广播给全部——这不是 bug，是 Pub/Sub 语义本身决定的
- 不要在监听器内部做耗时操作（比如远程 HTTP 调用、数据库写入），否则会阻塞该监听器线程，影响其他消息消费
为什么必须显式配置 TaskExecutor，而不是用默认的
不配置 taskExecutor 时，RedisMessageListenerContainer 会 fallback 到 SimpleAsyncTaskExecutor，它每次执行都新建线程，且不回收——压测或长时间运行后 JVM 线程数爆炸，容易触发 OOM 或被 OS kill。
Redis Skill - 高性能缓存管理
下载
Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。
- 必须通过
setTaskExecutor注入一个真正的线程池，例如ThreadPoolTaskExecutor - 核心线程数建议设为 2–5，避免抢占过多 CPU；队列容量不宜过大（如
setQueueCapacity(100)），防止消息积压掩盖下游瓶颈 - 线程名前缀（
setThreadNamePrefix("redis-listener-")）强烈建议设置，方便 GC 日志和 jstack 定位问题线程 - 别忘了调用
executor.initialize()，否则 Spring 不会真正启动该线程池
@RedisListener 和手动注册 MessageListener 哪个更适合多监听场景
两者底层都依赖 RedisMessageListenerContainer，但行为差异明显：
-
@RedisListener是注解驱动，自动注册，适合轻量、单方法级监听；但无法控制监听器执行顺序，也无法复用同一个监听器实例处理多个频道（除非用重复注解 + 同一方法） - 手动 new
MessageListener实现类并调用addMessageListener，能完全掌控生命周期、复用逻辑、统一异常处理，更适合生产环境多频道+差异化处理的场景 -
@RedisListener方法签名受限（只支持String、byte[]、Message等有限类型），而手动实现的onMessage可直接拿到原始Message和pattern字节数组，解析更灵活 - 如果用了
@RedisListener，又手动配置了RedisMessageListenerContainer，需确认是否启用RedisListenerEndpointRegistrar，否则注解可能不生效
自定义 ThreadPoolTaskExecutor 的拒绝策略怎么对接 Redis 缓存任务
当线程池满、队列也满时，拒绝策略（RejectedExecutionHandler）可把任务暂存 Redis，由定时任务兜底消费——但这不是 RedisMessageListenerContainer 的职责，而是业务线程池自身的扩展点。
- 继承
ThreadPoolTaskExecutor，重写execute方法或设置自定义setRejectedExecutionHandler - 拒绝时序列化任务对象（如
Runnable包装体）为 JSON，用StringRedisTemplate.opsForList().leftPush("delayed_tasks", json)入队 - 另起一个
@Scheduled(fixedDelay = 5000)定时任务，从 list 弹出并提交到同一线程池（注意幂等与失败重试） - 切记：这个机制只适用于“非实时强依赖”的补偿型任务；Pub/Sub 消息本身不能丢，所以监听器线程池的拒绝策略不应丢弃原始消息，而应记录告警并人工介入
MessageListener 共享同一个线程池，但各自 onMessage 方法里若没做 try-catch，一个监听器抛未捕获异常会导致整个容器停止接收新消息——必须在每个 onMessage 最外层包一层 try/catch(Throwable) 并记录 ERROR 日志。
