RabbitMQ自定义重试策略配置无效问题求助

核心问题分析 #

你的重试逻辑未生效，大概率是重试拦截器未关联到RabbitMQ监听容器，其次可能是异常抛出方式或配置细节问题。以下是针对性的解决步骤：

1. 确保拦截器注册到监听容器工厂 #

配置SimpleRabbitListenerContainerFactory，将你的RetryOperationsInterceptor加入通知链，这样拦截器才能作用于消息监听方法：

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(
        ConnectionFactory connectionFactory,
        RetryOperationsInterceptor interceptor) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setAdviceChain(interceptor); // 关键：绑定重试拦截器
    return factory;
}

然后在@RabbitListener注解中指定该容器工厂（如果它不是默认工厂的话）：

@RabbitListener(queues = "your-target-queue", containerFactory = "rabbitListenerContainerFactory")
public void processMessage(String message) throws RetryException, DoNotRetryException {
    // 业务逻辑，直接抛出目标异常
}

2. 确保异常直接抛出，未被捕获 #

监听方法必须直接抛出RetryException或DoNotRetryException，不能在方法内部用try-catch捕获并吞掉异常，否则重试拦截器无法感知到异常触发重试逻辑：

❌ 错误示例：

public void processMessage(String message) {
    try {
        // 业务逻辑
    } catch (RetryException e) {
        // 捕获异常后未重新抛出，拦截器无法处理
    }
}

✅ 正确示例：

public void processMessage(String message) throws RetryException, DoNotRetryException {
    // 业务逻辑触发异常时直接抛出
    if (needRetry()) {
        throw new RetryException("需要重试");
    }
    if (skipRetry()) {
        throw new DoNotRetryException("直接进入DLQ");
    }
}

3. 验证SimpleRetryPolicy配置细节 #

你的SimpleRetryPolicy配置本身是正确的，但可以确认以下两点：

• 确保抛出的异常是直接匹配RetryException.class或DoNotRetryException.class，而非它们的子类（如果是子类，需将子类也加入exceptionsMap，或依赖traverseCauses=true遍历异常链）
• 构造参数3代表最大重试次数（即第一次调用失败后，最多重试3次，总共4次执行）

4. 验证DLQ转发配置 #

确保dlExchange和dlRoutingKey在RabbitMQ中已正确创建，且rabbitTemplate有足够权限访问这些资源，避免重试失败后无法转发到DLQ。

测试验证 #

• 触发RetryException：查看应用日志，确认监听方法被调用4次（1次初始+3次重试），之后消息被转发到DLQ
• 触发DoNotRetryException：确认监听方法仅被调用1次，直接转发到DLQ

内容的提问来源于stack exchange，提问作者Aviral Nimbekar