詳細情報: 私が呼び出しているサーバーはサード パーティであり、送信するメッセージを制御することはできません。メッセージ ID に基づいて、それらが正しい順序で配置されていることはわかっています。また、このシステムでは ACK と Acknowledge に違いがあります。元のメッセージが「送信」キューに置かれると、ACK が受信されます。次に、応答の「受信」キューを監視します。私は通常、「承認」の後に「合格」または「不合格」を受け取ります。これらのメッセージの相関 ID は、ACK からのメッセージ ID です。
私はもともとメッセージ リスナーを使用し、OnMessge イベントに応答していました。この方法を使用すると、メッセージが非同期で配信されるため、特定の順序で配信されないことに気付き、このアプローチを断念しました。そこで、タイマー (System.Threading.Timer) を使用してポーリングし、consumer.Receive() を呼び出して一度に 1 つのメッセージを取得するようにコードを変更しました。これは私が望むように機能します。
サービスの開始時に一度コンシューマーを開き、メッセージを継続的にポーリングします。
順序を維持するために何もする必要はありません。これは、メッセージ キューがユーザーに代わって行うことの 1 つです。キューをリッスンしている単一のコンシューマーがあり、メッセージを順不同で処理している場合、バグを発見したか、メッセージが思った順序でキューに入れられていないと思います。
また、役立つかもしれないActiveMQ FAQからのこの質問があります。
編集: duffymo's answerに関するコメントを読むと、少しオーバーエンジニアリングしているように見えます。一般に、ActiveMQ、MQ Series、joram などのメッセージ キューには 2 つの特徴があります。キューに入れられたのと同じ順序でメッセージを配信することと、メッセージ配信を保証することです。別の ACK メッセージを送信するのは冗長です。これは、データベース トランザクションをコミットし、同じ情報をクエリして、データベースに実際に格納されていることを再確認することに少し似ています。
そうは言っても、サーバーはマルチスレッド化されていますか? その場合、ACK をキューに入れる前に応答をキューに入れることができる可能性があります。
ジェイソンが今言ったことすべて。その他、気をつけたいことをいくつか。多くのメッセージに対してコンシューマを開いたままにしていますか? いくつかのメッセージのコンシューマーを作成してから閉じていませんか? コンシューマーを閉じるだけで、コンシューマーに関連付けられたメッセージがキューに戻され、順序が乱れる可能性があります。
ロールバックに関連していますか？(トランザクションをロールバックしていますか?)。
最後に、Resequencerを使用して順序を変更することで、常に順序を確保できます。
メッセージの順序が重要なのはなぜですか? MessageListener は気にする必要はありません。
応答を特定の要求と一致させるために相関 ID が必要な場合、それは別の問題です。そうですか？