Headers Exchange 是一种不依赖 routing key、基于消息头键值对进行路由的机制，支持 all/any 多条件匹配，适用于按优先级、业务类型等多维度组合路由的场景。
RabbitMQ 的 Headers Exchange 是一种不依赖 routing key、而是基于消息头（headers）键值对进行路由的机制。它适合需要多维度、条件组合式路由的场景，比如按消息格式、优先级、来源系统、业务类型等属性联合判断。
核心逻辑很简单：生产者在消息中设置 headers，消费者绑定队列时声明匹配规则（含 x-match 参数），Exchange 根据两者是否满足条件决定是否投递。
Headers Exchange 的绑定与匹配关键点
- 绑定时必须通过
arguments传入一组键值对，其中至少包含x-match字段； -
x-match=all表示所有指定 header 必须完全匹配（AND 逻辑）； -
x-match=any表示只要任意一个 header 匹配即路由（OR 逻辑）； - 路由过程完全忽略
routingKey，该字段在 headers 模式下可为空字符串或任意值； - headers 中未声明的字段不会参与匹配，也不会影响结果。
如何配置队列绑定（以 AMQP 客户端为例）
// 绑定队列到 headers exchange，要求同时匹配 username 和 role
channel.QueueBind(
queue: "admin.queue",
exchange: "my.headers.exchange",
routingKey: "", // 忽略
arguments: new Dictionary<string, object>
{
{ "x-match", "all" },
{ "username", "admin" },
{ "role", "super" }
}
);对应地，只有当生产者发送的消息 headers 同时包含 "username":"admin" 和 "role":"super" 时，该消息才会被路由到 admin.queue。
JavaStoryDevelop
下载
你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在
生产者如何发送带 headers 的消息
var props = channel.CreateBasicProperties();
props.Headers = new Dictionary<string, object>
{
{ "username", "admin" },
{ "role", "super" },
{ "version", "v2" }
};
channel.BasicPublish(
exchange: "my.headers.exchange",
routingKey: "",
basicProperties: props,
body: Encoding.UTF8.GetBytes("敏感操作指令")
);注意：version 字段虽存在，但若绑定时未声明，它不会影响匹配结果。
常见使用建议
-
避免滥用
x-match=any：容易导致消息误投，尤其在多个队列共用同一 exchange 时； -
键名和值类型需严格一致：比如
"status": "1"和"status": 1（int）会被视为不同值； - headers 不支持通配符或正则：只支持精确值匹配，如需模糊匹配，应改用 topic exchange 或前置过滤逻辑；
- 性能略低于 direct/fanout：因需逐项比对多个字段，高吞吐场景下建议控制 headers 字段数量。
本质上，Headers Exchange 把路由决策从字符串匹配升级为结构化属性匹配，让消息分发更贴近真实业务语义。
