3. Exchange 类型与路由机制：Direct、Topic、Fanout、Headers 原理与适用场景

RabbitMQ 的核心路由能力由 Exchange（交换机） 承载。生产者将消息发送至 Exchange，Exchange 根据自身类型与绑定键（Binding Key）将消息路由到一个或多个队列。理解四种 Exchange 类型的路由算法，是设计高性能消息系统的前提。

3.1 路由模型总览

Exchange 接收消息后，通过以下三个要素决定路由目标：

• Routing Key（路由键）：消息携带的标签，由生产者指定。
• Binding Key（绑定键）：队列绑定到 Exchange 时声明的匹配规则。
• Exchange Type（交换机类型）：决定路由键与绑定键的匹配算法。

3.2 Direct Exchange —— 精确匹配

路由算法： Routing Key 必须与 Binding Key 完全相等，消息才会被路由到该队列。

// 生产者：发送 routing key = "order.created"
channel.basicPublish("direct_exchange", "order.created", null, msgBody);

// 消费者：队列绑定 binding key = "order.created"
channel.queueBind("queue_orders", "direct_exchange", "order.created");
// 只有 routing key 完全等于 "order.created" 的消息才会进入 queue_orders

3.3 Topic Exchange —— 模式匹配

路由算法： Routing Key 必须与 Binding Key 的 通配符模式 匹配。Binding Key 支持两个通配符：

• *（星号）：匹配一个单词（由点号分隔的段）。
• #（井号）：匹配零个或多个单词。

// 生产者：发送 routing key = "us.news.weather"
channel.basicPublish("topic_exchange", "us.news.weather", null, msgBody);

// 消费者 A：绑定 "us.#" —— 匹配所有以 us 开头的消息
// 消费者 B：绑定 "*.news.*" —— 匹配中间段为 news 的消息
// 消费者 C：绑定 "us.news.weather" —— 精确匹配（等同于 Direct）

3.4 Fanout Exchange —— 广播

路由算法： 忽略 Routing Key，将消息 复制并发送到所有绑定的队列。

// 生产者：routing key 被忽略
channel.basicPublish("fanout_exchange", "", null, msgBody);

// 所有绑定到 fanout_exchange 的队列都会收到消息副本
channel.queueBind("queue_cache", "fanout_exchange", "");
channel.queueBind("queue_log", "fanout_exchange", "");

3.5 Headers Exchange —— 多属性匹配

路由算法： 不依赖 Routing Key，而是匹配消息的 Headers 属性（键值对集合）。绑定队列时需指定一组 Headers 键值对，并设置匹配策略：

• x-match = all：消息的 Headers 必须包含所有指定的键值对（AND 逻辑）。
• x-match = any：消息的 Headers 只需匹配任意一个指定的键值对（OR 逻辑）。

// 生产者：设置消息 Headers
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder()
    .headers(Map.of("type", "order", "priority", "high"))
    .build();
channel.basicPublish("headers_exchange", "", props, msgBody);

// 消费者：绑定条件 x-match = all
Map<String, Object> bindArgs = Map.of("x-match", "all", "type", "order", "priority", "high");
channel.queueBind("queue_high_priority_orders", "headers_exchange", "", bindArgs);
// 只有 type=order 且 priority=high 的消息才会进入该队列

3.6 四种 Exchange 对比总结

3.7 路由机制与索引命中率的关系

在 RabbitMQ 内部，Exchange 的路由表使用 哈希表（Direct）、Trie 树（Topic） 或 线性遍历（Headers） 实现。路由性能直接影响消息投递的索引命中率：

• Direct Exchange：哈希索引 O(1)，命中率最高，适合高频精确路由。
• Topic Exchange：Trie 树匹配 O(k)（k 为 Binding Key 长度），当通配符过多时树深度增加，命中率下降。
• Fanout Exchange：无索引查找，直接复制，命中率概念不适用。
• Headers Exchange：线性扫描 Headers 表 O(n)，n 为绑定队列数，命中率最低。

3.8 场景选择决策树

在实际架构设计中，可按以下决策路径选择 Exchange 类型：

1. 是否需要广播到所有队列？ → 是 → Fanout Exchange
2. 路由条件是否基于多个属性（非字符串）？ → 是 → Headers Exchange
3. 是否需要通配符匹配（如 us.#）？ → 是 → Topic Exchange
4. 默认选择 → Direct Exchange（性能最优，语义最清晰）