RabbitMQ 非循环调度

Question

我对在 RabbitMQ 中实现“工作队列”模型很感兴趣。但是，我发现代理会执行基于循环的简单任务分派给工人。

https://www.rabbitmq.com/tutorials/tutorial-two-java.html

如果某个特定的工作人员正忙于执行一项非常繁重的任务并且有其他空闲工作人员，则代理应该能够将队列中的消息分派给下一个可用的工作人员而不是下一个 循环序列中的工人。有没有办法使用 RabbitMQ 来完成这个？

Answer 1

也许您正在寻找基于 QoS 的公平调度 (https://www.rabbitmq.com/tutorials/tutorial-two-java.html)。

channel.basicQos(1);

使用 QoS(1) 一个消费者很忙，直到没有发送ACK，在这种情况下，另一条消息被发送给下一个空闲消费者。

因此，如果消费者有很长的流程要做，它就不会收到消息。

如果没有空闲的消费者，消息将保留在队列中。