SpringBoot AMQP：抛出AmqpRejectAndDontRequeueException时自定义x-first-death-reason

当然可以自定义这个死信原因！默认情况下，抛出AmqpRejectAndDontRequeueException时RabbitMQ会把x-first-death-reason设为rejected，但我们完全可以通过Spring AMQP的扩展点来替换成自定义的消息。下面给你两种实用的实现方案：

方案一：用自定义RabbitListenerErrorHandler统一处理 #

这种方式适合在全局层面统一管理死信原因，不用在每个消息处理方法里写重复代码。

首先创建一个自定义的错误处理器：

@Component
public class CustomDeadLetterErrorHandler implements RabbitListenerErrorHandler {

    @Override
    public Object handleError(Message amqpMsg, org.springframework.messaging.Message<?> msg, ListenerExecutionFailedException ex) throws Exception {
        // 拿到原始的AMQP消息对象
        org.springframework.amqp.core.Message rawMsg = (org.springframework.amqp.core.Message) msg.getPayload();
        // 构造自定义的死信原因，比如结合业务异常信息
        String customReason = String.format("业务处理失败：%s", ex.getCause().getMessage());
        
        // 把自定义原因塞进消息头里，RabbitMQ会用这个值作为x-first-death-reason
        rawMsg.getMessageProperties().getHeaders().put("x-first-death-reason", customReason);
        
        // 抛出拒绝异常，告诉容器不要重新入队
        throw new AmqpRejectAndDontRequeueException(customReason, ex);
    }
}

然后在你的@RabbitListener注解里指定这个错误处理器：

@RabbitListener(bindings = @QueueBinding(
        value = @Queue(value = "core.queue", durable = "true", arguments = {
                @Argument(name = "x-dead-letter-exchange", value = RabbitConfiguration.ERROR_EXCHANGE),
                @Argument(name = "x-dead-letter-routing-key", value = RabbitConfiguration.ERROR_ROUTING_KEY)
        }),
        exchange = @Exchange(value = RabbitConfiguration.CORE_EXCHANGE),
        key = RabbitConfiguration.CORE_ROUTING_KEY
), errorHandler = "customDeadLetterErrorHandler")
public void processMessage(YourMessageDto message) {
    // 业务逻辑，比如校验失败直接抛异常
    if (message.getStatus() == null) {
        throw new IllegalArgumentException("消息状态不能为空");
    }
    // ...其他业务操作
}

方案二：用ChannelAwareMessageListener手动控制 #

如果需要更精细的控制（比如根据不同的异常类型设置不同的死信原因），可以用ChannelAwareMessageListener直接操作Channel和消息头：

@RabbitListener(queues = "core.queue")
public void handleMessage(org.springframework.amqp.core.Message message, Channel channel) throws IOException {
    try {
        // 解析消息并处理业务逻辑
        YourMessageDto dto = objectMapper.readValue(message.getBody(), YourMessageDto.class);
        if (dto.getAmount() < 0) {
            throw new RuntimeException("金额不能为负数");
        }
        // ...业务操作
    } catch (Exception e) {
        // 根据异常类型自定义死信原因
        String deadLetterReason = switch (e.getClass().getSimpleName()) {
            case "IllegalArgumentException" -> "参数非法：" + e.getMessage();
            case "RuntimeException" -> "业务逻辑异常：" + e.getMessage();
            default -> "未知错误：" + e.getMessage();
        };
        
        // 设置消息头里的死信原因
        message.getMessageProperties().getHeaders().put("x-first-death-reason", deadLetterReason);
        
        // 手动拒绝消息，参数false表示不重新入队
        channel.basicReject(message.getMessageProperties().getDeliveryTag(), false);
    }
}

几个注意点 #

• 当你手动设置x-first-death-reason头时，RabbitMQ会优先使用你设置的值，而不是默认的rejected。
• 如果消息多次被移入死信队列（比如死信队列也配置了死信规则），RabbitMQ会生成x-death数组，每个条目里都会包含你自定义的reason字段。
• 确保你的主队列已经正确配置了死信交换机和路由键，不然消息不会进入死信队列。

这样就能完美实现自定义死信原因的需求啦！

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