3

Majordomo パターンでは、ワーカーのコード セクションは次のようになります。

mdwrk session ("tcp://localhost:5555", sourceStr.c_str(), verbose);

zmsg *reply = 0;
while (1) {
    zmsg *request = session.recv (reply);
    if (request == 0) {
        break;              //  Worker was interrupted
    }

    //reply = request;        //  Echo is complex... :-)
    reply = new zmsg(sourceStr.c_str());
}

私の従業員にとって、クライアントからの要求は、取引所に送信される注文です。注文を取引所に送信した後、Insert、Pending、New などのメッセージが返された後、FIX 応答の内容を zmsg *reply に詰め込む方法について頭を悩ませています。

FIX メッセージは非同期に返されるため、何とも言えません。

返信= FIXResponse;

これはどのように解決されますか？

4

1 に答える 1

0

Majordomo プロトコルは同期要求を処理するためのものであり、ここではあまり適切ではないと思います。

あなたの他の質問の 1 つに出くわしました。これらの回答には複数のソースがあることがわかります。それらすべてを単一の安定した PULL ソケットにプッシュできますか? (そして、必要に応じて再発行します。ボリュームが少ない場合は、信頼性のために永続的なサブスクライバーを使用することもできます。)

于 2012-07-25T21:31:53.027 に答える