Java 中怎么在 RabbitMQ 中使用 Header Exchange 根据消息属性头实现多维度路由-java教程-PHP中文网

header exchange通过消息headers键值对与绑定参数匹配实现多维度路由，支持x-match=all（全匹配）或any（任一匹配），不依赖routing key，需严格保证键名大小写和值类型一致。

java 中怎么在 rabbitmq 中使用 header exchange 根据消息属性头实现多维度路由

在 RabbitMQ 中使用 Header Exchange 实现多维度路由，核心是不依赖 routing key，而是通过消息的 headers 属性（键值对）与绑定时声明的 header 匹配规则进行路由。Java 客户端（如 Spring AMQP 或原生 RabbitMQ Java Client）均可支持，关键在于正确设置消息 headers 和 Exchange 绑定参数。

Header Exchange 的匹配机制

Header Exchange 不使用 routing key，而是根据消息携带的 headers 与队列绑定时指定的 header 键值对进行匹配。支持两种匹配模式：

all（默认）：所有声明的 header 必须完全匹配（键存在、值相等、类型一致）
any：只要有一个声明的 header 匹配即可
可使用 x-match 参数在绑定时显式指定，值为 "all" 或 "any"

Spring AMQP 中的配置与发送示例

使用 Spring Boot + spring-boot-starter-amqp 时，需定义 Header Exchange、队列及绑定，并在发送时设置 headers。

在SEO发布前，从路由清单生成XML网站地图和robots.txt

当代理已经知道网站路由或内容URL，并且在启动前需要有效的sitemap XML、sitemap索引或robots.txt引用时，请使用sitemap。这是一个发布构件技能，而不是爬虫或SEO平台。

下载

声明 Header Exchange：@Bean public Exchange headerExchange() { return new HeadersExchange("header.exchange"); }
绑定队列时指定 headers 和 x-match：BindingBuilder.bind(queue).to(headerExchange()).where("type").matches("order").and("priority").matches("high")（对应 x-match=all）
发送消息时设置 headers：MessageProperties props = new MessageProperties(); props.setHeader("type", "order"); props.setHeader("priority", "high"); props.setHeader("region", "cn"); Message msg = new Message("data".getBytes(), props); rabbitTemplate.send("header.exchange", "", msg);

原生 RabbitMQ Java Client 的用法要点

若不使用 Spring，直接调用 amqp-client，需注意以下细节：

声明 Exchange 时指定类型：channel.exchangeDeclare("header.exchange", "headers");
绑定队列时传入 headers map 和 x-match：Map<string object> args = new HashMap(); args.put("x-match", "all"); args.put("type", "notification"); args.put("level", "error"); channel.queueBind("alert.queue", "header.exchange", "", args);</string>
发布消息时传入 headers map：AMQP.BasicProperties props = new AMQP.BasicProperties.Builder() .headers(Map.of("type", "notification", "level", "error")) .build(); channel.basicPublish("header.exchange", "", props, body);