Spring Data Redis 原生不支持通过配置文件直接开启消息监听自动重试，需要手动配置 RedisMessageListenerContainer 的错误处理器或结合 Spring Retry 组件实现。适用基于 Pub/Sub 模式的业务场景，风险边界在于 Redis 发布订阅本身不支持消息确认，重试失败可能导致消息丢失。

快速处理思路

通过 Java 配置类定义 RedisMessageListenerContainer Bean，显式注入自定义 ErrorHandler，并在 ErrorHandler 内部调用 RetryTemplate 执行监听逻辑。

@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.addMessageListener(listenerAdapter, new PatternTopic("your_topic"));
    container.setErrorHandler(new RetryErrorHandler(retryTemplate()));
    return container;
}

为什么会这样

RedisMessageListenerContainer 默认捕获异常后仅记录日志而不重发消息，因为 Redis Pub/Sub 机制本身是无状态的。

Spring Data Redis 的监听容器设计解耦了消息接收与业务处理，默认实现不包含重试策略，需要开发者根据业务容忍度自行集成 Spring Retry 组件。公开资料中没有看到可靠的量化数据表明默认配置的具体丢包率，但架构上决定了无 ACK 机制下的消息不可靠性。

分步处理

第一步：引入 Spring Retry 依赖，确保项目中包含 org.springframework.retry 相关包。

第二步：配置 RetryTemplate，设置最大重试次数和退避策略，避免无限重试阻塞线程。

@Bean
public RetryTemplate retryTemplate() {
    RetryTemplate retryTemplate = new RetryTemplate();
    SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(3); // 最大重试 3 次
    retryTemplate.setRetryPolicy(retryPolicy);
    return retryTemplate;
}

第三步：实现 ErrorHandler 接口，在 handleError 方法中包裹重试逻辑，捕获最终失败异常。

第四步：将 ErrorHandler 注入 RedisMessageListenerContainer，完成容器装配。

风险边界：重试期间线程会被占用，高并发场景下需评估线程池大小，避免重试导致线程耗尽。

怎么验证是否生效

查看应用日志，确认异常抛出后是否有重试记录，通常 Spring Retry 会输出 RetryContext 相关信息。

模拟依赖服务不可用，发送测试消息，观察日志中异常出现次数是否符合设定的最大重试次数。

验证最终失败后消息不再消费，确认没有进入死循环，同时检查业务数据状态是否符合预期。

常见坑

Redis Pub/Sub 不支持消息确认（ACK），一旦消费者端重试耗尽仍失败，消息即丢失，无法像 Kafka 那样回滚 Offset。

重试策略配置不当可能导致无限循环，务必设置最大尝试次数（Max Attempts）。

监听器方法内部如果捕获了异常且不抛出，ErrorHandler 不会触发，重试机制将失效。

常见问题

Redis 监听器支持事务回滚吗？

不支持，Redis Pub/Sub 消息一旦发出无法撤回，本地事务回滚不影响消息已分发的事实。

和 Spring Kafka 的重试配置有什么区别？

Kafka 容器支持配置属性自动开启重试且支持 Offset 提交控制，Redis 需要手动编写 Bean 且无 Offset 机制。

重试失败后消息去哪了？

默认情况下消息丢失，建议结合持久化队列或死信队列方案在业务层兜底。

参考来源

Spring Data Redis Reference Documentation, Redis Message Listener Container, https://docs.spring.io/spring-data/redis/reference/redis/listener.html

Spring Retry Project, GitHub Repository, https://github.com/spring-projects/spring-retry