rabbitmq过滤器工作队列

问题描述 投票:2回答:1

我一直在阅读rabbitMQ教程,我正在寻找有关应该使用的设置的帮助。

我有一个任务列表1-50,我想在一组4台计算机上运行一次(并且只能运行一次),每台计算机都运行一个工作程序。我在https://www.rabbitmq.com/tutorials/tutorial-two-python.html]处设置了类似于教程2的模板

不是所有的计算机都可以运行所有任务(还没有安装所有软件)

我试图实现的设置是允许对发送给工作人员的任务进行过滤的设置。

我阅读了有关如何在使用路由的广播情况下实现此目标的教程,但是我不太了解如何将其映射回类似于教程2的更简单的推送模型(因为我不想广播工作)。

在这条线的某个时刻,我也希望能够根据负载动态地缩放每个盒子上的工作人员数量。

我应该使用的最佳模型是什么,您可以推荐一些好的教程或书面材料来学习这种方法吗?

干杯,罗布

我一直在阅读RabbitMQ教程,我正在寻找有关应该使用的设置的帮助。我有一个任务列表1-50,我想在一组4个上运行一次(并且只能运行一次)...

python rabbitmq
1个回答
5
投票

RabbitMQ没有提供一种有选择地使用队列中消息的方法。队列中的使用者始终有机会接收该队列中的任何给定消息。因此,您必须将消息预先过滤到队列中,以完成特定类型的工作。完成此操作后,您的消息使用者只会从队列中消耗他们可以处理的工作类型。

© www.soinside.com 2019 - 2024. All rights reserved.