python - 多个消费者和生产者连接到一个消息队列，这在 AMQP 中可能吗？

Question

我想创建一个能够进行 OCR 文本处理的农场。我考虑过使用由多个 OCR 进程读取的单个消息队列。

我想确保:

• 队列中的每条消息最终都会被处理
• 工作或多或少是平均分配的
• 一张图片只会被一个 OCR 进程解析
• OCR 进程不会同时接收多条消息(因此任何其他免费的 OCR 进程都可以处理该消息)。

使用 AMQP 可以吗？

我打算使用 python 和 rabbitmq

Answer 1

是的，正如@nailxx 指出的那样。 AMQP 编程模型与 JMS 略有不同，因为您只有队列，可以在工作人员之间共享，或者由单个工作人员私下使用。您还可以轻松设置 RabbitMQ 来执行 PubSub 用例或 JMS 中称为主题 的内容。请转至我们的Getting Started RabbitMQ web site 上的页面找到大量关于此的有用信息。

现在，特别是对于您的用例，已经有大量可用的工具。人们经常使用并且得到很好支持的一个是 Celery .这是一个blog post关于它，我认为可以帮助您入门:

如果您有任何问题，请给我们发电子邮件或发布到 rabbitmq-discuss 邮件列表。