我是一个尝试在 java 客户端中实现 Headers 交换的新手。我知道这就是“x-match”绑定(bind)参数的用途。当“x-match”参数设置为“any”时，只有一个匹配的 header 值就足够了。或者，将“x-match”设置为“all”要求所有值都必须匹配。 但是任何人都可以为我提供一个框架代码以便更好地理解。
最佳答案
要使用 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)。希望对您有所帮助!
关于java - 我如何使用 Java 在 RabbitMQ 中实现 Headers Exchange？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/19240290/