rabbitmq - 如何使用RabbitMQ限制吞吐量？

Question

问题在哪里:

我们正在使用RabbitMQ作为任务队列。具体任务之一-向Vkontakte社交网络发送通知。他们的api每秒请求数有限制，此限制取决于您的应用程序大小。少于10万人的应用只需3次通话，依此类推。因此，我们需要人为地限制对他们服务的请求。现在，此逻辑是基于应用程序的。很简单，每个队列只能使用一个工作人员，只需设置sleep(300ms)之类的内容即可保持镇定。但是，当您应该使用N个工作程序时，这种同步就变得不容易了。

如何使用RabbitMQ限制吞吐量？

根据以上故事。如果可能的话，不仅设置基于消息的预取大小，而且基于此逻辑的时间也可以非常简单。例如，“每次提取到1条消息的质量不快于1秒(以秒为单位)”等等。

有这样的东西吗？

可能是其他策略吗？

Answer 1

RabbitMQ不可能开箱即用。

没错，对于分散的消费者而言，这种限制变得困难。我建议您看一下ZooKeeper，它可以让您同步所有使用者并利用Znodes/Watches来限制消息的处理
适用于节流但可扩展的解决方案。