默认交换机

默认交换机是RabbitMQ预创建的空名称Direct交换机，支持通过队列名直接投递消息。

定义

默认交换机（Default Exchange）是RabbitMQ自动创建的特殊Direct交换机，名称为空字符串""。每个队列在声明时自动与该交换机绑定，绑定键为队列名称本身。

核心机制

隐式绑定规则

1. 每个队列声明时自动绑定到默认交换机
2. 绑定路由键等于队列名称
3. 无法手动声明或删除默认交换机
4. 无法为默认交换机创建其他绑定关系

使用示例

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;

public class DefaultExchangeExample {
    private static final String QUEUE_NAME = "task_queue";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            
            // 声明队列（自动绑定到默认交换机）
            channel.queueDeclare(QUEUE_NAME, true, false, false, null);
            
            // 使用默认交换机发布消息（交换机名称为空字符串）
            // 路由键必须等于队列名称
            String message = "Hello from default exchange!";
            channel.basicPublish("", QUEUE_NAME, null, 
                    message.getBytes("UTF-8"));
            
            System.out.println("Message sent: " + message);
            
            // 消费消息
            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                String received = new String(delivery.getBody(), "UTF-8");
                System.out.println("Received: " + received);
                channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
            };
            
            channel.basicConsume(QUEUE_NAME, false, deliverCallback, consumerTag -> {});
        }
    }
}

适用场景

简单点对点通信

// 生产者直接通过队列名发送消息，无需显式声明交换机
channel.basicPublish("", "simple_queue", null, message.getBytes("UTF-8"));

原型开发与快速测试

// 快速测试队列功能，无需管理交换机
public class QuickTest {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        
        try (Connection conn = factory.newConnection();
             Channel ch = conn.createChannel()) {
            
            // 声明队列直接使用默认交换机
            ch.queueDeclare("test_queue", false, false, true, null);
            ch.basicPublish("", "test_queue", null, "test".getBytes());
            
            System.out.println("Quick test completed");
        }
    }
}

注意事项

• 默认交换机为Direct类型，仅支持精确匹配，路由键必须等于队列名
• 所有队列自动绑定到默认交换机，但无法显式声明或修改绑定关系
• 适用于简单点对点场景，复杂路由需使用自定义交换机
• 默认交换机本身不可删除，即使删除所有队列仍存在
• 生产环境建议显式声明交换机，提高路由逻辑的可读性和可控性

要点总结

• 默认交换机是RabbitMQ预创建的空名称Direct交换机
• 每个队列自动绑定到默认交换机，路由键等于队列名
• 适用于简单点对点通信和快速原型开发
• 无法手动声明、修改或删除默认交换机的绑定关系
• 生产环境推荐显式声明交换机以提升架构清晰度

文章存放路径：D:\git2\jwdev\articles\RABBITMQ\进阶\交换机类型详解\默认交换机.md