如何在Java中使用Spring AMQP检测RabbitMQ生产者消息发送失败？

RabbitMQ 默认行为是消息无法路由时不会主动抛出异常，因为它允许消息被丢弃或转发到死信交换机（DLX），因此 Spring AMQP 的send方法默认不会触发异常。要实现投递成功的检测，可依赖 RabbitMQ 原生支持的**发布确认（Publisher Confirms）和返回消息（Returned Messages）**机制，这是标准且优雅的解决方案。

1. 启用发布确认与返回消息 #

在配置类中开启这两个核心特性：

@Configuration
public class RabbitConfig {

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        
        // 发布确认回调：消息到达Broker时触发
        rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
            if (!ack) {
                // 消息未被Broker接收，处理失败逻辑
                System.err.println("消息投递Broker失败：" + cause);
            }
        });
        
        // 返回消息回调：消息无法路由到队列时触发
        rabbitTemplate.setReturnsCallback(returned -> {
            System.err.println("消息无法路由到队列：路由键=" + returned.getRoutingKey() 
                + ", 交换机=" + returned.getExchange() 
                + ", 原因=" + returned.getReplyText());
        });
        
        // 必须设为true，否则Broker会直接丢弃无法路由的消息，不触发回调
        rabbitTemplate.setMandatory(true);
        return rabbitTemplate;
    }
}

2. 关键机制说明 #

• 发布确认（Confirm Callback）：消息成功到达 RabbitMQ Broker 时ack=true；若 Broker 接收失败（如交换机不存在），则ack=false并返回失败原因。
• 返回消息（Returns Callback）：消息到达 Broker 但无法匹配任何队列（如路由键错误）时触发，需配合mandatory=true使用，确保 Broker 不会静默丢弃消息。

3. 同步等待确认（可选） #

如果需要同步阻塞获取投递结果，可结合CorrelationData实现：

public boolean sendMessageWithConfirm(String exchange, String routingKey, Object message) {
    CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
    SettableListenableFuture<Boolean> confirmFuture = new SettableListenableFuture<>();
    
    rabbitTemplate.setConfirmCallback((corrData, ack, cause) -> {
        if (corrData.getId().equals(correlationData.getId())) {
            confirmFuture.set(ack);
        }
    });
    
    rabbitTemplate.convertAndSend(exchange, routingKey, message, correlationData);
    
    try {
        // 阻塞等待确认，超时时间按需调整
        return confirmFuture.get(5, TimeUnit.SECONDS);
    } catch (Exception e) {
        // 处理超时或异常
        return false;
    }
}

4. 死信交换机兜底（辅助排查） #

若需留存无法路由的消息以便排查，可配置死信交换机：

• 给目标交换机绑定死信交换机（DLX），当消息无法路由时，Broker 会将消息转发到 DLX 对应的队列。
• 定期监控死信队列，及时发现路由键或绑定配置错误。

为什么send方法不抛异常？ #

RabbitMQ 的 AMQP 协议将“消息无法路由”定义为预期内场景，而非异常。Spring AMQP 遵循这一设计，因此默认通过回调机制通知开发者，而非抛出异常。

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