4

価格設定アプリケーションがあります。価格要求を Azure Service Bus Queue (任意のキュー) "PricingRequestQueue" に送信します。これらを取得して処理し、結果を PricingResponse キューに返すワーカーが多数あります。

PricingResponse キューに Observable を作成したいと思います。フィルタリングは必要ありませんが、バッチ インターフェイス (QueueClient.BeginReceiveBatch) を使用してメッセージを読み上げたいと考えています。キューには予想される数のメッセージがあり、読み取るセッションがあります (QueueClient.AcceptMessageSession(correlationIdentifier))。

私はまだ RX について理解を深めようとしていますが、これで問題は解決します。

4

1 に答える 1

1

Rx 拡張機能を Azure に追加する CloudFx ライブラリがあります。

https://www.nuget.org/packages/Microsoft.Experience.CloudFx/ (更新されたリンク)

ただし、現在の CloudFx ライブラリでいくつかのスレッド リークが見つかったことを警告する必要があります (特にテーブル ストレージのライブラリで - ただし、テーブル ストレージ 2.0 以降は Rx 拡張機能は必要ありません)。

于 2014-02-23T15:02:14.133 に答える