RabbitMQ：如何指定要发布到的队列？

Question

RabbitMQ 的Channel#basicConsume 方法为我们提供了以下参数：

channel.basicConsume(queueName, autoAck, consumerTag, noLocal,
    exclusive, arguments, callback);

让我们能够准确地告诉 RabbitMQ 我们想从哪个队列消费。

但是Channel#basicPublish 没有这样的等价物：

channel.basicPublish(exchangeName, routingKey, mandatory, immediateFlag,
    basicProperties, messageAsBytes);

为什么我不能在这里指定要发布到的队列？！？ 如何将Channel 发布到例如名为logging 的队列？提前致谢！

Answer 1

为了扩展@Tien Nguyen 的答案，RabbitMQ 中有一个“作弊”，可以有效地让您直接发布到队列。每个队列都自动绑定到 AMQP 默认交换器，队列的名称作为路由键。默认交换也称为“无名交换”——即它的名称是空字符串。因此，如果您使用与队列名称相同的路由键发布到名为"" 的交换器，则消息将仅发送到该队列。正如@John 所说，它正在通过交换，这不是您需要声明或约束自己的交换。

我没有方便的 Java 客户端来尝试此代码，但它应该可以工作。

channel.basicPublish("", myQueueName, false, false, null, myMessageAsBytes);

也就是说，这与 RabbitMQ 的工作原理大相径庭。对于正常的应用程序流程，您应该声明和绑定交换。但对于特殊情况，“作弊”可能很有用。例如，我相信这就是 Rabbit 管理控制台允许您手动将消息发布到队列的方式，而无需创建和绑定交换的所有仪式。

Answer 2

基本上，队列可以绑定到基于 routingKeys 的交换。

假设您有 3 个不同的发布商。
Publisher1 发送消息以与 routingKey“事件”进行交换
Publisher2 发送消息以与 routingKey“任务”进行交换
Publisher3 发送消息以与 routingKey “jobs”进行交换

您可以让消费者只使用具有特定 routhingKey 的消息。
例如，为了让您声明这样的“事件”消息的消费者

 channel.queueBind(queueName, exchangeName, "events");

如果你想消耗所有进入交换的消息，你将路由指定为'#'

简而言之，我能说的是，
1. 消息将发布到交易所。
2.队列会根据routingKeys绑定交换。
3. RabbitMQ 会将路由键匹配的消息转发到对应的队列中。

请看教程-http://www.rabbitmq.com/tutorials/tutorial-three-java.html

RabbitMQ 中消息传递模型的核心思想是生产者永远不会将任何消息直接发送到队列。实际上，生产者通常根本不知道消息是否会被传递到任何队列。相反，生产者只能向交换器发送消息

Answer 3

请试试这个：

channel.basicPublish("", yourQueueName, null,
        message.getBytes((Charset.forName("UTF-8"))));

它适用于我的项目。