存在交换问题的 RabbitMQ RPC

【问题标题】：RabbitMQ RPC with exchanges trouble存在交换问题的 RabbitMQ RPC
【发布时间】：2014-08-15 12:59:20
【问题描述】：

所以我一直在关注这个教程：http://www.rabbitmq.com/tutorials/tutorial-six-java.html，但我无法让它与直接交换一起工作。

有人可以通过修改代码来帮助我，以便它可以与直接交换一起使用。

我的目标：用户可以选择发送到哪台机器，当他们选择我想绑定到那台机器并将其发送到那台机器时。但是当我将队列声明更改为交换声明时，它似乎不起作用。任何帮助将不胜感激！！！

谢谢

【问题讨论】：

【解决方案1】：

在 RabbitMQ 中，您将消息发布到交换器，因此您在教程中看到的代码：channel.basicPublish("", "rpc_queue", props, message.getBytes());，意味着：使用路由密钥"rpc_queue" 向交换器"" 发送消息。这是教程一中讨论的默认或匿名交换。

因此，如果您想将消息发送到直接交换，只需将空交换名称更改为您的交换名称。

现在，你为什么要那样做？为什么不能不声明"rpc_queue"，而是在每台机器上声明一个队列，并在basicPublish 中通过它们的名称来寻址它们？

【讨论】：