java - 如何使用 Java 在 RabbitMQ 中实现 Headers Exchange？

Question

我是一个新手，试图在 java 客户端中实现 Headers 交换。我知道这就是“x-match”绑定参数的用途。当“x-match”参数设置为“any”时，只需一个匹配的标头值就足够了。或者，将“x-match”设置为“all”要求所有值必须匹配。但是任何人都可以为我提供一个框架代码以便更好地理解。

Answer 1

要使用标头交换，您只需将交换声明为标头类型：

channel.exchangeDeclare("myExchange", "headers", true);

然后，您需要在消费者消费消息之前声明一个队列，该队列将成为消息的最终目的地：

channel.queueDeclare("myQueue", true, false, false, null);

现在我们需要将交换绑定到声明绑定的队列。在此声明中，您可以设置要将消息从交换器路由到队列的标头。一个例子可能是：

Map<String, Object> bindingArgs = new HashMap<String, Object>();
bindingArgs.put("x-match", "any"); //any or all
bindingArgs.put("headerName#1", "headerValue#1");
bindingArgs.put("headerName#2", "headerValue#2");

...
channel.queueBind("myQueue", "myExchange", "", bindingArgs);
...

这将使用 headerName#1 和 headerName#2 创建绑定。我希望这有帮助！