在Rebus与Azure Service Bus中使用多个连接字符串

刚好我之前处理过类似的场景，Rebus官方完全支持注册多个独立的总线实例来对接不同的ASB命名空间，最推荐的方案是使用命名总线实例，配置和使用都很清晰，下面是具体步骤：

1. 在ConfigureServices中注册多个命名总线 #

你可以通过AddRebus的带名称参数重载，为每个ASB命名空间创建独立的配置实例：

public void ConfigureServices(IServiceCollection services)
{
    // 注册对接第一个ASB命名空间的总线（命名为"ASB-Namespace-A"）
    services.AddRebus(
        configure => configure
            .Transport(t => t.UseAzureServiceBus("Your-Connection-String-A", "queue-a"))
            .Routing(r => r.TypeBased().MapAssemblyOf<YourCommandForA>("queue-a")),
        name: "ASB-Namespace-A"
    );

    // 注册对接第二个ASB命名空间的总线（命名为"ASB-Namespace-B"）
    services.AddRebus(
        configure => configure
            .Transport(t => t.UseAzureServiceBus("Your-Connection-String-B", "queue-b"))
            .Routing(r => r.TypeBased().MapAssemblyOf<YourCommandForB>("queue-b")),
        name: "ASB-Namespace-B"
    );
}

2. 获取指定总线实例发送命令 #

不要直接注入默认的IBus，而是注入IBusFactory，通过它获取对应命名的总线实例来发送命令：

public class CrossEnvironmentCommandSender
{
    private readonly IBusFactory _busFactory;

    public CrossEnvironmentCommandSender(IBusFactory busFactory)
    {
        _busFactory = busFactory;
    }

    public async Task SendToNamespaceA(YourCommandForA command)
    {
        using var bus = _busFactory.GetBus("ASB-Namespace-A");
        await bus.Send(command);
    }

    public async Task SendToNamespaceB(YourCommandForB command)
    {
        using var bus = _busFactory.GetBus("ASB-Namespace-B");
        await bus.Send(command);
    }
}

3. 启动总线实例（如果需要消费消息） #

如果你的服务同时需要作为消费者处理消息，记得在Configure方法中启动每个命名总线：

public void Configure(IApplicationBuilder app)
{
    // 启动两个总线实例
    app.UseRebus("ASB-Namespace-A");
    app.UseRebus("ASB-Namespace-B");
}

额外提示 #

• 每个命名总线都是完全独立的，配置、路由、队列都不会互相干扰，非常适合跨环境/多命名空间的场景。
• 如果你的ASB权限允许，可以在UseAzureServiceBus后加上.AutoCreate()，让Rebus自动创建所需的队列和主题（生产环境建议提前手动创建）。
• 如果你偏好强类型的方式，也可以自定义包装类（比如IAzureBusANamespace、IAzureBusBNamespace），但命名实例是官方最简洁的标准方案。

内容的提问来源于stack exchange，提问作者Kizmar