具有不同 Azure 总线订阅的多个后台工作人员

如何解决具有不同 Azure 总线订阅的多个后台工作人员

我创建了一个可以读取 azure bus service subscription 的工作线程，下面是在线示例。 但无法找到一种方法，让多个工作人员在同一个应用程序中读取不同的订阅并执行不同的操作。

为了创建我的应用程序，我在 Program.cs 中添加了以下内容

services.AddSingleton<ISubscriptionClient>(x =>
                        new SubscriptionClient(Configuration["ServiceBus:ConnectionString"],Configuration["ServiceBus:TopicName"],Configuration["ServiceBus:SubscriptionName"]));

在我的工作人员中：

private readonly ISubscriptionClient _subscriptionClient;

在 ExecuteAsync 中

_subscriptionClient.RegisterMessageHandler(async (message,token) => 
        { //do stuff }

有没有办法让每个后台工作人员使用不同的订阅？

解决方法

您需要以Configuration["ServiceBus:TopicName"] 和Configuration["ServiceBus:SubscriptionName"] 不是“硬编码”的方式注册您的客户。

this answer 中描述的服务解析器可以工作，您的实现类将这两个参数作为构造函数参数。

,

不是将 ISubscriptionClient 作为单例注入（在这种情况下不推荐使用服务解析器，因为它不会完全解决您的问题），您可以在您的工作角色中创建只读全局变量，如下所示：

private readonly ISubscriptionClient _subscriptionClient1 = new SubscriptionClient(Configuration["ServiceBus:ConnectionString1"],Configuration["ServiceBus:TopicName1"],Configuration["ServiceBus:SubscriptionName1"]));

private readonly ISubscriptionClient _subscriptionClient2 = new SubscriptionClient(Configuration["ServiceBus:ConnectionString2"],Configuration["ServiceBus:TopicName2"],Configuration["ServiceBus:SubscriptionName2"]))

然后，在 ExecutionAsync 中使用它们：

_subscriptionClient1.RegisterMessageHandler(async (message,token) => 
        { //do stuff }
_subscriptionClient2.RegisterMessageHandler(async (message,token) => 
        { //do stuff }