路由失败处理

当消息发送到交换机后无法匹配到任何队列时，默认会被直接丢弃。通过配置mandatory参数可让RabbitMQ将未路由的消息返回给生产者。

mandatory 参数

定义

mandatory 是 basicPublish 方法的参数之一，设置为 true 时，若消息无法路由到任何队列，RabbitMQ会将消息返回给生产者，而不是直接丢弃。

路由失败场景

Java 配置示例

// Maven 依赖
// <dependency>
//     <groupId>com.rabbitmq</groupId>
//     <artifactId>amqp-client</artifactId>
//     <version>5.20.0</version>
// </dependency>

import com.rabbitmq.client.*;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;

public class MandatoryExample {
    
    private static final String EXCHANGE_NAME = "test_exchange";
    
    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("guest");
        factory.setPassword("guest");
        
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            
            // 声明 Direct 交换机
            channel.exchangeDeclare(EXCHANGE_NAME, "direct", true);
            
            // 设置 Return 回调，处理未路由消息
            channel.addReturnListener((replyCode, replyText, exchange, routingKey, properties, body) -> {
                String message = new String(body, StandardCharsets.UTF_8);
                System.err.println("消息未路由 - 返回代码: " + replyCode);
                System.err.println("返回文本: " + replyText);
                System.err.println("交换机: " + exchange);
                System.err.println("路由键: " + routingKey);
                System.err.println("消息内容: " + message);
                // 可在此处实现重试、记录日志或转发到死信队列
            });
            
            String message = "Hello, RabbitMQ!";
            
            // mandatory = true: 无法路由时返回
            channel.basicPublish(EXCHANGE_NAME, "nonexistent_route", true, null,
                    message.getBytes(StandardCharsets.UTF_8));
            
            System.out.println("消息已发送: " + message);
        }
    }
}

注意：设置 mandatory = true 时必须配合 addReturnListener 使用，否则返回的消息不会被处理且会丢失。

mandatory vs mandatory=false 行为对比

注意事项

1. mandatory 仅对 Direct 和 Topic 交换机有效，Fanout 交换机会广播到所有绑定队列，不存在路由失败。
2. Return 回调是异步的，生产者在发送消息后不应立即关闭连接，需等待回调执行完成。
3. 若同时配置了 Publisher Confirm 和 Return 机制，confirm 会在消息返回之前触发。
4. 对于未路由且未设置 mandatory 的消息，RabbitMQ 会静默丢弃，不会抛出异常。

要点总结

• mandatory = true 可使无匹配路由的消息返回给生产者，防止消息静默丢失
• 必须配合 addReturnListener 处理返回消息，否则返回消息仍会丢失
• 默认 mandatory = false，消息无法路由时直接丢弃
• Fanout 交换机不会触发路由失败，Direct 和 Topic 交换机可能触发
• Return 回调异步执行，需确保连接在回调完成前不被关闭