FIFO Qeueingシステムでは、優先メッセージングを実装する最良の方法は何ですか

Question

優先度メッセージ（AMQPなど）を一貫してサポートしないメッセージ指向のミドルウェアの場合、キューがFIFOセマンティクスのみを持つ場合に優先消費を実装する最適な方法？一般的なユースケースは、メッセージの大きなバックログがキューに存在する場合に、優先度の低いメッセージの前に優先度の高いメッセージを受信するシステムです。

Answer 1

与えられた単一のキューに対してのみFIFOサポートが与えられた場合、もちろん、複数のキュー、仲介者のいずれかを導入するか、より複雑なコンシューマを持つ必要があります。

複数のキューは、いくつかの方法で処理できます。プロデューサとコンシューマは、優先度の高いキューとバックグラウンドタスクのキューの2つのキューを持つことに同意できます。

プロデューサが1つのキューに制限されていてもコンシューマを制御できる場合は、パスにファンアウトルータを導入することを検討してください。プロデューサ→ルータは単一のキューであるため、ルータは消費者に対して2つのキューを持っています。

これに対処するもう一つの方法は、消費者に待ち行列の前でスレッドをスピンさせ、次に内部的に作業をディスパッチさせることです。上記のルータバージョンのようなものですが、1つのアプリ内にあります。これには、アプリ内で複数のメッセージが飛んでいるという欠点があります。これは、エラーが発生した場合の復旧を複雑にする可能性があります。

優先度が高いイベントがまだぶら下がっていても、そのうちのいくつかを処理する必要がある場合は、効果的に優先度の低いイベントの枯渇を考慮する必要があります。