RabbitMQ 溢出消息转死信队列失败问题求助

我来帮你拆解下问题的核心原因，再给出适配你场景的解决方案：

为什么溢出消息没进入死信队列？ #

你设置了x-overflow: reject-publish，在RabbitMQ 3.7.4版本中，这个配置的行为是当队列达到最大长度时，直接拒绝生产者的发布请求，消息根本不会进入原队列。

而死信队列（DLX）的触发逻辑是：只有当消息已经进入原队列，之后因为被拒绝、过期，或者队列溢出时被丢弃（比如x-overflow: drop-head时丢弃头部旧消息），才会被转发到死信队列。你的溢出消息连原队列都没进，自然不会触发死信转发。

解决方案 #

方案1：升级RabbitMQ到3.8+版本（最简洁） #

RabbitMQ 3.8.0及以后新增了x-overflow: reject-publish-dlx选项，完美匹配你的需求：队列满时拒绝新消息，同时自动把被拒绝的消息转发到死信队列。

修改你的队列配置代码：

@Bean
public Queue salesQueue() {
    return QueueBuilder.durable(queue)
            .withArgument("x-max-length", 3)
            .withArgument("x-overflow", "reject-publish-dlx") // 替换为这个值
            .withArgument("x-dead-letter-exchange", queueExchange)
            .withArgument("x-dead-letter-routing-key", "deadletter-routing-key")
            .build();
}

方案2：在3.7.4版本下实现需求（无需升级） #

如果暂时无法升级RabbitMQ，有两种替代方式：

方式A：改用x-overflow: drop-head

这个配置会在队列满时，丢弃队列中最老的头部消息，被丢弃的消息会自动进入死信队列。注意：这和你原本“拒绝新消息”的需求略有差异，它是保留新消息、丢弃旧消息。

修改队列配置：

@Bean
public Queue salesQueue() {
    return QueueBuilder.durable(queue)
            .withArgument("x-max-length", 3)
            .withArgument("x-overflow", "drop-head") // 替换为这个值
            .withArgument("x-dead-letter-exchange", queueExchange)
            .withArgument("x-dead-letter-routing-key", "deadletter-routing-key")
            .build();
}

方式B：生产者捕获Nack，手动转发到死信队列

因为reject-publish会让生产者收到Nack（否定确认），你可以在生产者端监听这个结果，手动把被拒绝的消息发送到死信队列。

首先修改生产者代码：

@Service
public class Producer {
    private static long sentMessageCount = 0L;
    @Autowired
    private AmqpTemplate rabbitTemplate;
    @Value("${overflow.queue}")
    String queueName;
    @Value("${overflow-queue.exchange}")
    String deadLetterExchange;
    @Value("deadletter-routing-key")
    String deadLetterRoutingKey;

    @Scheduled(initialDelay = 5000, fixedRate = 10)
    public void queueSender() {
        long x = ++sentMessageCount;
        String message = "{'empId':'" + x + "','empName':'raj'}";
        try {
            // 开启强制路由，确保消息无法投递时触发回调
            rabbitTemplate.setMandatory(true);
            rabbitTemplate.convertAndSend(queueName, message);
        } catch (AmqpRejectAndDontRequeueException e) {
            // 捕获队列满的拒绝异常，手动转发到死信队列
            rabbitTemplate.convertAndSend(deadLetterExchange, deadLetterRoutingKey, message);
        }
    }
}

然后在你的AMQP配置中开启发布确认和返回回调：

@Bean
public ConnectionFactory connectionFactory() {
    CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
    // 这里补充你的RabbitMQ地址、账号密码等配置
    connectionFactory.setPublisherConfirms(true); // 开启发布确认
    connectionFactory.setPublisherReturns(true); // 开启消息返回监听
    return connectionFactory;
}

@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
    RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
    rabbitTemplate.setMandatory(true);
    // 设置返回回调，处理队列满导致的消息拒绝
    rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> {
        // 403是队列满的拒绝码
        if (replyCode == 403) {
            rabbitTemplate.convertAndSend(deadLetterExchange, deadLetterRoutingKey, message.getBody());
        }
    });
    return rabbitTemplate;
}

额外注意事项 #

不管用哪种方案，都要确保死信队列和绑定已正确创建，否则消息会丢失。你可以在配置中添加死信队列的定义：

@Bean
public Queue deadLetterQueue() {
    return QueueBuilder.durable("dead-letter-queue").build(); // 自定义死信队列名称
}

@Bean
public Binding deadLetterBinding() {
    return BindingBuilder.bind(deadLetterQueue())
            .to(salesExchange())
            .with("deadletter-routing-key"); // 和你配置的死信路由键一致
}

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