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

Question

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

Answer 1

要使用 header 交换，您只需将交换声明为 header 类型:

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

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

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

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

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 创建绑定(bind)。希望对您有所帮助!