rabbitMQに一連のジョブを送信する方法はありますか？

Question

A, B, C, Dという名前のjobsがあります。ジョブBは、ジョブAが完了した後に開始する必要があります。したがって、仕事の順序は、A->B->C->Dのようになります。

私はA、B、CおよびDの労働者の数を無制限に縮尺したいと思います。 RabbitMQを使用してこれを実装する方法はありますか、基本的にはseriesをjobsに作成する方法を探しています。

私の現在の設計は、次のようになります。

は

1. callerプロセスがseriesOfJobs作成：ジョブA,B,C,Dを記述JSONの配列が
2. callerを経由seriesManager（別のプロセス）にseriesOfJobsを送るJSON-RPCプロトコルを使用してRabbitMQRPCmainCallbackQueue
3. seriesManager構文解析seriesOfJobsがRabbitMQRPC介しworkerA（別のプロセス）にジョブAを送信しcallbackQueueA
4. workerA行うジョブAにコールバックを待ちとcallbackQueueAからのコールバックを取得し、作業者にジョブBを送信seriesManagerseriesManager

5. callbackQueueAを介して通知し、コールバックを待ち、ジョブの場合は同じC、次に同じジョブの場合はD

6. seriesManagerは、ジョブがA,B,C,D終了していることを知っている - それはここRabbitMQ RPC tutorial説明するように、私はRPCの概念を使用していますmainCallbackQueue

経由callerを通知し、これを行うための簡単な方法はありますか？

Answer 1

（私が必要なものに固執し、それを試してみて、編集しますけれども残念ながら、私がコメントするのに十分な評判を持っていないので、私は要件を明確にすることができないとして、これはやや欠けて答えてもよい）

seriesManagerは絶対に必要ですか？

workerAがworkerBのジョブBを作成し、その上などではなく、一貫中央ハブにコールバックするよりも、持っているより論理的かもしれません。

その場合、あなたの現在の設計は、に変更します

1. callerはseriesOfJobsを作成します。
2. callerは、seriesOfJobsからworkerAを送信します。
3. workerAは、ジョブAを実行し、残りのseriesOfJobsをworkerBに送信します。
4. workerBは、ジョブBを実行し、残りのseriesOfJobsをworkerCに送信します。
5. workerCは、ジョブCを実行し、残りのseriesOfJobsをworkerDに送信します。
6. workerDは、ジョブDを実行し、mainCallbackQueueを介してcallerに通知します。

私は、より単純な方法として、その厄介な中心的なハブを方程式から取り除くと考えています。