带X-Death头消息的Spring AMQP事务回滚异常问题

方案一：自定义异常策略，复用handleDiscarded并强制事务回滚 #

问题根源是ConditionalRejectingErrorHandler.DefaultExceptionStrategy在检测到x-death头时，抛出ImmediateAcknowledgeAmqpException——该异常会被容器视为消息处理成功，导致@Transactional注解的JPA事务不触发回滚。我们可以自定义异常策略，替换默认的异常抛出逻辑：

1. 自定义ExceptionStrategy子类，继承ConditionalRejectingErrorHandler.DefaultExceptionStrategy
2. 在检测到x-death头时，先调用handleDiscarded将消息发送到status.plx
3. 抛出AmqpRejectAndDontRequeueException替代ImmediateAcknowledgeAmqpException，该异常会触发容器拒绝消息并传播到事务上下文，强制JPA事务回滚

代码示例：

@Configuration
public class AmqpConfig {

    @Bean
    public ConditionalRejectingErrorHandler amqpErrorHandler(MessageRecoverer parkingLotRecoverer) {
        return new ConditionalRejectingErrorHandler(new CustomDiscardExceptionStrategy(parkingLotRecoverer));
    }

    // 实现消息发送到status.plx的MessageRecoverer
    @Bean
    public MessageRecoverer parkingLotRecoverer(RabbitTemplate rabbitTemplate) {
        return (message, cause) -> {
            rabbitTemplate.send("status.plx", message.getMessageProperties().getReceivedRoutingKey(), message);
        };
    }

    private static class CustomDiscardExceptionStrategy extends ConditionalRejectingErrorHandler.DefaultExceptionStrategy {
        private final MessageRecoverer parkingLotRecoverer;

        public CustomDiscardExceptionStrategy(MessageRecoverer parkingLotRecoverer) {
            this.parkingLotRecoverer = parkingLotRecoverer;
        }

        @Override
        public Throwable determineThrowable(Throwable original) {
            Throwable resolvedThrowable = super.determineThrowable(original);
            Message failedMessage = getLastFailedMessage();

            if (failedMessage != null && failedMessage.getMessageProperties().getHeaders().containsKey("x-death")) {
                // 先将消息发送到停车场交换机
                this.parkingLotRecoverer.recover(failedMessage, resolvedThrowable);
                // 抛出触发回滚且不重入队的异常
                return new AmqpRejectAndDontRequeueException("Discarded message with x-death header", resolvedThrowable);
            }

            return super.determineThrowable(original);
        }
    }
}

此方案保留了原有的handleDiscarded机制，同时确保无论首次还是二次失败，JPA事务都会回滚。

方案二：调整死信路由，直接将重试消息转至停车场 #

如果业务允许仅重试一次后直接进入停车场，可以简化死信配置，避免二次处理的事务问题：

1. 修改status.dlx的死信配置，将死信交换机设置为status.plx，而非原有的status
2. 移除ConditionalRejectingErrorHandler中针对x-death头的处理逻辑

调整后的消息流转：
status→监听器异常→status.dlx（等待TTL）→status.plx

这种方式的优势：

• 无需处理x-death头的复杂逻辑，配置更简洁
• 每次监听器失败都会触发JPA事务回滚，无例外情况
• 彻底避免消息循环风险

此方案推荐在业务对重试次数要求简单（仅1次）时使用。

关键注意事项 #

• 确保监听器方法标注@Transactional，且事务管理器JpaTransactionManager配置正确
• 使用AmqpRejectAndDontRequeueException时，需确认消息不会再次进入死信循环（因为已手动发送到停车场，拒绝后消息不会被重新路由）
• 若使用方案一，需保证MessageRecoverer发送消息到status.plx的操作是可靠的，可考虑添加单独的事务或确认机制

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