2013-07-15 2 views
0

У меня есть Java API на моем сервере, и я хочу, чтобы он создавал задачи и добавлял их в Celery через RabbitMQ. Я выполнил следующий учебник, http://www.rabbitmq.com/tutorials/tutorial-two-python.html, где я использовал java для клиента (send.java) и python для получения (receive.py). В get.py, где вызывается метод обратного вызова, я вызываю метод, который я аннотировал с помощью @ celery.task, чтобы задача была добавлена ​​в сельдерей.Развертывание java-клиента, RabbitMQ и Celery на сервер

Мне интересно, как все это развертывается на сервере, хотя, в частности, почему есть файл receive.py. Является ли get.py процессом, который должен постоянно выполняться на сервере? Есть ли способ настроить RabbitMQ так, чтобы он автоматически перенаправлял java-клиентские задачи на сельдерей?

Спасибо!

ответ

0

RabbitMQ - это всего лишь очередь сообщений. Производители размещают сообщения, а потребители получают их по требованию. Вы можете ограничивать доступ только для определенных очередей с помощью опций RabbitMQ.

Что касается развертывания: да, receive.py необходимо постоянно запускать. Это Задача сельдерея. См. Workers Guide для получения информации о работе .

Смежные вопросы