Spring AMQP自定义异常重试失效求助：自定义异常仍被重复投递

首先明确你的核心需求：

• 抛出CustomDontRequeueException时，消息直接进入死信队列，不触发任何重试
• 其他异常（如RuntimeException）触发最多3次重试，重试耗尽后再进入死信队列

当前代码的问题根源 #

1. 异常包装导致重试策略失效：Spring AMQP的RabbitListener会把业务层抛出的所有异常包装成ListenerExecutionFailedException，而你的重试策略里把ListenerExecutionFailedException标记为可重试，所以即使底层是CustomDontRequeueException，还是会触发重试流程。
2. 重试策略未识别自定义异常：虽然你设置了traverseCauses=true（允许遍历异常链），但没有把CustomDontRequeueException加入到不可重试异常列表中，导致策略无法识别这个异常需要跳过重试。
3. ErrorHandler逻辑时机不对：重试拦截器的执行优先级高于RabbitListenerErrorHandler，所以你的ErrorHandler里的判断逻辑根本没机会生效，重试已经先触发了。

修正后的代码实现 #

1. 更新重试策略，识别自定义异常

@Bean 
public SimpleRetryPolicy rejectionRetryPolicy(){ 
    Map<Class<? extends Throwable>, Boolean> exceptionsMap = new HashMap<>(); 
    
    // 标记不可重试的异常：自定义异常 + AMQP拒绝异常
    exceptionsMap.put(CustomDontRequeueException.class, false);
    exceptionsMap.put(AmqpRejectAndDontRequeueException.class, false);
    
    // 其他所有异常允许重试
    exceptionsMap.put(Exception.class, true); 
    
    // traverseCauses=true：允许穿透包装类，检查底层异常
    SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(3, exceptionsMap, true); 
    return retryPolicy; 
}

2. 调整重试拦截器配置

@Bean 
public RetryOperationsInterceptor workMessagesRetryInterceptor() { 
    return RetryInterceptorBuilder.stateless()
            .retryPolicy(rejectionRetryPolicy()) 
            // 可选：配置退避策略（首次1秒，每次翻倍，最大10秒）
            // .backOffOptions(1000, 2, 10000) 
            // 重试耗尽或遇到不可重试异常时，将消息转发到死信队列
            .recoverer(new RepublishMessageRecoverer(defaultTemplate, this.getDlqExchange(), this.getDlqroutingkey())) 
            .build(); 
}

3. 优化Listener与业务逻辑

去掉冗余的异常捕获和ErrorHandler依赖，让异常自然向上抛出即可：

@Override 
@RabbitListener(queues = "${queueconfig.queuename}", containerFactory = "sdRabbitListenerContainerFactory")
public void processMessage(Message incomingMsg) throws Exception { 
    log.info("{} - Correlation ID: {} Received message: {} from {} queue.", 
             Thread.currentThread().getId(), 
             incomingMsg.getMessageProperties().getCorrelationId(), 
             new String(incomingMsg.getBody()), 
             incomingMsg.getMessageProperties().getConsumerQueue()); 
    // 直接执行业务逻辑，异常交由重试拦截器处理
    performAction(); 
}

业务方法保持原有逻辑即可，确保CustomDontRequeueException正确抛出：

@Override 
public void performAction() throws Exception { 
    try { 
        // 你的核心业务逻辑
    } catch (HttpClientErrorException ex) { 
        if (ex.getStatusCode() == HttpStatus.NOT_FOUND || ex.getStatusCode() == HttpStatus.REQUEST_TIMEOUT) { 
            // 这类异常需要触发重试
            throw new RuntimeException(ex); 
        } else { 
            // 直接进入死信，不重试
            throw new CustomDontRequeueException("DontRetry", ex); 
        } 
    } catch (Exception e) { 
        // 其他异常直接进入死信
        throw new CustomDontRequeueException(e); 
    } 
}

4. 确保容器工厂配置了重试拦截器

要让重试逻辑生效，必须把拦截器加入到Listener容器工厂的通知链中：

@Bean
public RabbitListenerContainerFactory<?> sdRabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    // 加入重试拦截器
    factory.setAdviceChain(workMessagesRetryInterceptor()); 
    return factory;
}

为什么这样修改有效？ #

• 重试策略通过traverseCauses=true穿透ListenerExecutionFailedException，直接检查底层的CustomDontRequeueException，从而跳过重试流程
• 不可重试异常会直接触发RepublishMessageRecoverer，将消息转发到死信队列
• 去掉了冗余的RabbitListenerErrorHandler，避免逻辑冲突，让重试拦截器统一处理异常重试与恢复逻辑

内容的提问来源于stack exchange，提问作者Naveen Kumar Pandian