c# - 在 Microsoft.ServiceBus.Messaging.QueueClient 上使用 RX（响应式扩展）

Question

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

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

我仍在努力让我的头脑围绕 RX，这真的会让事情变得清晰。

Answer 1

CloudFx 库将 Rx 扩展添加到 Azure。

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

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