RabbitMQ未将消息发送至DLQ且队列参数不可见问题排查

我正在开发一个集成RabbitMQ并配置了DLQ（死信队列）的Spring Boot应用。抛出AmqpRejectAndDontRequeueException异常后，消息并未被发送至DLQ。同时在RabbitMQ管理界面中，dummy-queue的DLQ相关参数不可见，x-death头始终为null。

相关代码与配置 #

RabbitListener代码 #

@RabbitListener(queues = "${notification.queues.dummy.name}", containerFactory = "notificationContainerFactory")
public void processDummyEvent(DummyEventDTO eventDTO, @Header(name = "x-death", required = false) Map<?, ?> death) {
    if (shouldRetry(death)) {
        log.error("death: {}", death);
        log.error("Consuming dummy queue...");
        throw new AmqpRejectAndDontRequeueException("Throwing from dummy queue after retrying...");
    } else {
        log.error("Throwing from dummy queue...");
        throw new ImmediateAcknowledgeAmqpException("Discarding message...");
    }
}

private boolean shouldRetry(Map<?,?> death) {
    return death == null || death.get(COUNT) == null || Integer.parseInt(death.get(COUNT).toString()) < 3;
}

RabbitMQ YML配置 #

dummy:
  declare: true
  name: dummy-queue
  durable: true
  routingKey: dummy-queue-routingKey
  exchange:
    name: dummy-queue-exchange
    durable: true
    type: direct
  retryCount: 3
  arguments:
    x-dead-letter-exchange: dummy-dlq-queue-exchange
    x-dead-letter-routing-key: dummy-dlq-queue-routingKey
    x-queue-mode: lazy

dummy-dlq:
  declare: true
  name: dummy-dlq-queue
  durable: true
  routingKey: dummy-dlq-queue-routingKey
  exchange:
    name: dummy-dlq-queue-exchange
    durable: true
    type: direct
  arguments:
    x-dead-letter-exchange: dummy-queue-exchange
    x-dead-letter-routing-key: dummy-queue-routingKey
    x-queue-mode: lazy
    x-message-ttl: 10000

请问该如何解决此问题？为什么抛出AmqpRejectAndDontRequeueException后消息未发送至DLQ？

原因分析与解决方案 #

1. 队列DLQ参数未正确绑定到实际队列 #

RabbitMQ管理界面看不到dummy-queue的DLQ参数，说明队列声明逻辑没有把YML配置里的arguments正确应用到队列实例上。Spring Boot中如果用自定义代码声明队列，必须确保把配置中的参数集合传递给队列构建器。

解决方法：
检查队列配置类，确保声明dummy-queue时加载YML中的dummy.arguments参数。示例代码如下：

@Bean
public Queue dummyQueue(@Value("${dummy.name}") String name,
                        @Value("${dummy.durable}") boolean durable,
                        @ConfigurationProperties(prefix = "dummy.arguments") Map<String, Object> arguments) {
    return QueueBuilder.durable(name)
            .withArguments(arguments)
            .build();
}

注意：如果旧队列已存在且未配置DLQ参数，需要先删除旧队列，让应用重新声明带参数的新队列——RabbitMQ不支持修改已存在队列的参数。

2. 容器工厂的重试机制干扰死信逻辑 #

如果notificationContainerFactory配置了Spring Retry重试机制，抛出AmqpRejectAndDontRequeueException后，重试组件可能直接丢弃消息，跳过死信路由流程。

解决方法：
调整容器工厂配置，禁用自动重新入队，确保重试耗尽后消息能进入DLQ：

@Bean
public SimpleRabbitListenerContainerFactory notificationContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    // 禁用自动重新入队，让拒绝的消息直接触发死信逻辑
    factory.setDefaultRequeueRejected(false);
    
    // 若需保留重试，配置重试模板及耗尽策略
    RetryTemplate retryTemplate = new RetryTemplate();
    SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
    retryPolicy.setMaxAttempts(3);
    retryTemplate.setRetryPolicy(retryPolicy);
    factory.setRetryTemplate(retryTemplate);
    
    // 重试耗尽后抛出拒绝异常，触发DLQ
    factory.setRecoveryCallback(context -> {
        throw new AmqpRejectAndDontRequeueException("Retry exhausted, routing to DLQ");
    });
    return factory;
}

3. x-death头为null的原因 #

x-death头仅在消息被路由到死信队列后，再次被消费时才会存在。当前消息根本没进入DLQ，所以消费dummy-queue时自然拿不到这个头，解决前面的问题后该字段会正常出现。

4. 注意DLQ循环路由的风险 #

你的DLQ配置了x-dead-letter-exchange指向原队列交换机，且设置了x-message-ttl=10000，这会导致DLQ中的消息过期后重新路由回原队列，形成循环。需确保重试计数逻辑（依赖x-death的COUNT值）能正确终止循环，避免消息无限重复流转。

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