将 java 客户端、RabbitMQ 和 Celery 部署到服务器

Question

我的服务器上有一个 Java API，我希望它创建任务并通过 RabbitMQ 将它们添加到 Celery。我遵循以下教程http://www.rabbitmq.com/tutorials/tutorial-two-python.html，其中我使用 java 作为客户端 (send.java) 和 python 接收 (receive.py)。在调用回调方法的receive.py中，我调用了一个我用@celery.task注释的方法，以便将任务添加到celery中。

我想知道所有这些是如何部署在服务器上的，具体来说，为什么会有一个 receive.py 文件。 receive.py 是必须在服务器上持续运行的进程吗？有没有办法配置 RabbitMQ 以便它自动将 java 客户端任务路由到 celery？

谢谢！

Answer 1

RabbitMQ 只是一个消息队列。生产者发布消息，消费者按需获取。您只能通过 RabbitMQ 的身份验证选项限制对特定队列的访问。

至于部署：是的，receive.py 需要持续运行。 Celery 的工作就是这样做。有关运行 worker 的信息，请参阅 Workers Guide。