RabbitMQ 交换绑定复制消息发布到一个交换跨两个其他交换

Question

我的 rabbitMQ 中有 3 个不同的交换，我正在尝试通过其他两个交换 dmyex 和 monex 路由发送到 ma​​inex 的所有消息> 我尝试使用 channel.exchngeBind 方法来绑定交易所。

我仍然无法看到发布到 mainex 的消息会发送到 dmyex 和 monex。

这在 RabbitMq 中可行吗？

我在这里做的有什么错误吗？

ch.exchangeDeclare("mainex", DIRECT_EXCHANGE_TYPE, true, false, null);
ch.exchangeDeclare("dmyex", CONSISTENT_HASH_EXCHANGE_TYPE, true, false, null);
ch.exchangeDeclare("monex", CONSISTENT_HASH_EXCHANGE_TYPE, true, false, null);
ch.exchangeBind("dmyex","mainex","abcd_KEY");
ch.exchangeBind("monex","mainex","abcd_KEY");

Answer 1

刚刚发现下面的模型正在工作。

   ch.exchangeDeclare("mainex", DIRECT_EXCHANGE_TYPE, true, false, null);
   ch.exchangeDeclare("dmyex", CONSISTENT_HASH_EXCHANGE_TYPE, true, false, null);
   ch.exchangeDeclare("mongoex", CONSISTENT_HASH_EXCHANGE_TYPE, true, false, null);
   
   
   ch.exchangeBind("dmyex","mainex", "abcd_KEY");
   ch.exchangeBind("monex","mainex", "abcd_KEY");
   
   
   for (String q : Arrays.asList("sharding: dmyex - rabbit@node1 - 0", "sharding: dmyex - rabbit@node2 - 0","sharding: dmyex - rabbit@node3 - 0","sharding: dmyex - rabbit@node4 - 0","sharding: dmyex - rabbit@node5 - 0","sharding: dmyex - rabbit@node6 - 0")) {
       ch.queueBind(q, "dmyex", "1");
   }
   
   
   for (String q : Arrays.asList("sharding: mongoex - rabbit@node1 - 0", "sharding: mongoex - rabbit@node2 - 0","sharding: mongoex - rabbit@node3 - 0","sharding: mongoex - rabbit@node4- 0","sharding: mongoex - rabbit@node5 - 0","sharding: mongoex - rabbit@node6 - 0")) {
       ch.queueBind(q, "mongoex", "1");
   }
   
   
     AMQP.BasicProperties.Builder bldr = new AMQP.BasicProperties.Builder();
     for (int i = 0; i < 10; i++) {
     ch.basicPublish("mainex", "abcd_KEY", bldr.build(), "TestMessage".getBytes("UTF-8"));````

Answer 2

我认为交换 mainex 需要成为主题交换才能使通配符路由起作用，因为直接交换根据路由密钥的精确匹配来进行路由。根据这个CloudAMQP blog post on exchange types and routing：

直接交换根据消息路由键将消息传递到队列。路由键是生产者添加到消息头的消息属性。将路由键视为交换用来决定如何路由消息的“地址”。 消息使用与消息的路由键完全匹配的绑定键进入队列。

（this answer to a question about wildcard routing keys on SO 也提到了这一点）

应该足以让您的路由正常工作。也许更简单，如果您要为绑定到mainex 的所有交换匹配任何路由密钥，则可以将mainex 设为扇出交换。