在RabbitMQ监听器拦截器（Advice）中抛异常的效果咨询

问题背景 #

监听器代码 #

@RabbitListener(queues = "${myQueue}")
public void receiveMessages(Message message) {
   doTheBusinessLogic(message);
}

Advice拦截配置代码 #

@Bean(name = "rabbitListenerContainerFactory")
public SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory(
        SimpleRabbitListenerContainerFactoryConfigurer configurer,
        ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    configurer.configure(factory, connectionFactory);
    factory.setAdviceChain(new MDCAdvice());
    return factory;
}

自定义MDCAdvice代码 #

public static class MDCAdvice implements MethodInterceptor {

    @Override
    public Object invoke(MethodInvocation invocation) throws Throwable {
        // pre process
        if (throwBefore) throw new RuntimeException("before");
        try {
            return invocation.proceed();
        }
        finally {
         // post process
        throw new RuntimeException("after");
        }
    }

}

核心疑问 #

在上述MDCAdvice中抛出RuntimeException，是否与在监听器方法receiveMessages的doTheBusinessLogic(message)内抛出异常效果完全一致？具体包括：

• 是否会向RabbitMQ返回NACK？
• 如果监听器是事务性的，事务是否会回滚？
• 总体而言，这与在业务方法内抛出异常是否完全等效？

回答 #

• NACK返回逻辑：无论异常是在Advice前置逻辑、业务方法执行中，还是finally块抛出，最终都会触发RabbitMQ容器的统一异常处理逻辑，向RabbitMQ返回NACK。具体后续行为会受容器defaultRequeueRejected配置影响：若为true，消息会重新入队；若为false，消息会被丢弃或进入死信队列。
• 事务回滚逻辑：如果监听器配置了事务（容器开启事务模式），只要异常未被捕获并传播到容器层，就会触发事务回滚。不管异常来自Advice还是业务方法，触发回滚的规则完全一致。
• 效果等效性：从容器异常处理、RabbitMQ交互逻辑来看，两者效果完全等效。Spring RabbitMQ的监听器容器是针对整个MethodInvocation调用链做异常处理的，Advice属于调用链的一部分，抛出的异常会和业务方法异常进入同一处理流程。

需要注意：finally块中抛出的异常会覆盖业务方法抛出的异常，但无论最终传播到容器的是哪个异常，触发的NACK和事务回滚（若有）逻辑都是一致的。

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