是否可以在给定的时间内向分布式使用者发送来自队列的不超过N个消息？

Question

我有一个从RabbitMQ读取消息的分布式系统。在我现在的情况下，我只需要处理N个msgs/s。

例如:想象一下发送文本消息的服务A。这个服务只能处理100个msgs/s，我的系统有多个使用者从RabbitMQ读取数据。需要首先处理每条消息，而不是发送到服务A。处理时间总是不同的。

所以问题是：

• 是否可以将队列配置为将不超过100个msgs/s分配给多个使用者？

Answer 1

您可以使用prefetch_size方法的qos参数来限制用户的吞吐量。

channel.basic_qos(100);

另见：http://www.rabbitmq.com/blog/2012/05/11/some-queuing-theory-throughput-latency-and-bandwidth/