如何用 RabbitMQ 平衡发布者的请求？答案

【问题标题】：How to balance publishers' requests with RabbitMQ?如何用 RabbitMQ 平衡发布者的请求？
【发布时间】：2015-04-23 16:57:33
【问题描述】：

假设您有多个生产者和一个消费者想要接收来自所有可用发布者的持久消息。

生产者以不同的速度工作。假设系统 A 产生 10 个请求/秒，系统 B 产生 1 个请求/秒。因此，如果您使用唯一的队列，您将处理来自 A 的 10 条消息，然后处理来自 B 的 1 条消息。

但是，如果您想平衡负载并处理来自 A 的一条消息，然后处理来自 B 的一条消息等，该怎么办？从多个队列消费不是一个好的选择，因为在这种情况下我们不能使用通配符绑定。

更新：
每个生产者排队似乎是最好的方法。生产者不知道他们不断变化的速度。每个消费者拥有一个队列，我可以订阅一个主题并接收来自所有可用发布者的消息。但是每个生产者都有一个队列，我需要自己编写逻辑：

嗯，这看起来很简单，但我认为代理可以提供所有这些功能而无需任何编码。如果有一个队列，我只创建一个持久队列，将其绑定到主题交换，然后启动任意数量的发布者向主题发送消息。这个选项几乎是开箱即用的。

【问题讨论】：

【解决方案1】：

我知道我参加聚会要迟到了，但还是要迟到。

在 Azure 服务总线术语中，它称为“partitioning”，它基于分区键。最好的部分是在 Azure SB 中，接收客户端不知道分区，它只是订阅单个队列。

在 RabbitMQ 中有一个 X-Consistent-Hashing 插件（“rabbitmq_consistent_hash_exchange”），但不幸的是它并不方便。消费者必须明确配置为从特定队列消费。如果您有十个队列，那么您需要设置您的消费者，以便覆盖所有十个。

另外两个选项：

请记住，使用分片插件，即使它创建“一个要消费的逻辑队列”，您也必须拥有与虚拟队列一样多的订阅者，否则某些队列将未被使用。

【讨论】：

【解决方案2】：

您可以使用Priority Queue Support 并根据生产者速度关联优先级。需要注意的是必须谨慎设置优先级（例如，如果消费者速度低于系统 B，则消费者只会消费来自 B 的消息）并且生产者必须知道他们的生产速度。

另一个需要考虑的选项是根据生产速度创建 3 种类型的队列：HIGH、MEDIUM、LOW。三个队列根据生产速度通过设置的绑定键绑定到交换机上。可以使用。

消费者将使用循环策略从这 3 个队列中消费消息。需要注意的是，生产者必须了解他们的生产速度。

但最好的选择可能是每个生产者一个队列，尤其是在生产者速度不稳定且无法分类的情况下。因此，生产者不需要知道他们的生产速度。

【讨论】：