在 Microsoft.ServiceBus.Messaging.QueueClient 上使用 RX（响应式扩展）答案

【问题标题】：Use RX on Microsoft.ServiceBus.Messaging.QueueClient (Reactive Extensions)在 Microsoft.ServiceBus.Messaging.QueueClient 上使用 RX（响应式扩展）
【发布时间】：2014-03-25 00:30:09
【问题描述】：

我有一个定价应用程序。它将定价请求发送到 Azure 服务总线队列（可以是任何队列）“PricingRequestQueue”。有许多工作人员负责收集、处理它们并将结果返回到 PricingResponse Queue。

我想在 PricingResponse 队列上创建一个 Observable。我不需要任何过滤，但想使用批处理接口 (QueueClient.BeginReceiveBatch) 读取消息。队列有预期的消息数量，并且有一个要读取的会话 (QueueClient.AcceptMessageSession(correlationIdentifier)。

我仍在努力了解 RX，这将真正解决问题。

【问题讨论】：

标签： c# c#-4.0 azure system.reactive message-bus

【解决方案1】：

CloudFx 库将 Rx 扩展添加到 Azure。

https://www.nuget.org/packages/Microsoft.Experience.CloudFx/（更新链接）

但是我必须警告您，我们在当前的 CloudFx 库中发现了一些线程泄漏（特别是表存储库 - 但是自表存储 2.0 以来您不需要 Rx 扩展）。

【讨论】：