2013-07-15 80 views
0

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

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

谢谢!

回答

0

RabbitMQ只是一个消息队列。生产者发布消息,消费者可以根据需求获得消息。您只能通过RabbitMQ的身份验证选项限制访问特定队列。

至于部署:是的,receive.py需要连续运行。这是芹菜的工作要做到这一点。有关运行工作人员的信息,请参见Workers Guide