6

ライブアップデートの送信には、javanioを使用して作成されたcometサーバーを使用したいと思います。情報を受信するときは、データをスキャンして、rabbitmqを介してワーカースレッドにタスクを送信します。理想的には、セロリサーバーをウサギの反対側に配置し、これらのタスクを処理するワーカースレッドのプールを管理することを望みます。

ただし、私の理解では、セロリはrabbitmqの両端に配置することで機能し、基本的に、コンシューマーとプロデューサーの両方のコードに埋め込まれることで、プロデューサーとコンシューマーの役割を引き継ぎます。上記のようにセロリをセットアップする方法はありますか?ありがとう

4

2 に答える 2

8

メッセージを公開するためにCeleryを使用する必要はありません。独自のアプリからRabbitMQまたは他のブローカーにメッセージを公開し、Celeryを使用してタスクを消費できます。

Celeryは単純なメッセージプロトコルを使用します。アプリケーションにクライアント側を実装できます。

プロトコルのクライアント側を実装したくない場合は、要求を受け入れて適切な呼び出しを行う単純なhttpサーバーを実装できます。このように。

于 2012-08-15T09:05:01.303 に答える