特定のメッセージのパブリッシャーをコンシューマーから分離するためのキューベースのシステムを設計しています。追加の要件があります - パブリッシャーが新しいメッセージをプッシュし、同様の種類の以前のメッセージが既にキューにあり、まだ処理されていない (つまり、コンシューマーによって選択された) 場合、新しいメッセージの前に古いメッセージを重複排除する必要があります。メッセージがキューにプッシュされます。これは、時代遅れになっていることがわかっているメッセージの処理コストを節約するためです。私は、そのようなキューを実装するために使用されるテクノロジを調査しています。Azure サービス バスはオプションですか? キュー内の特定のメッセージの属性を変更できますか? また、そのようなキューを実装するのに最適なテクノロジについて何か提案はありますか?
1 に答える
0
セッションを使用してみてください: https://code.msdn.microsoft.com/windowsazure/Brokered-Messaging-Session-41c43fb4
このようにして、2 番目のメッセージは同じセッション ID を持ち、クライアントは同じセッション ID を持つすべてのメッセージをフェッチします。クライアントには、最も古いものを破棄するロジックが必要です。
于 2014-11-11T09:25:32.310 に答える