如何基于现有Startup.cs为RabbitMQ配置多个事件总线？

根据你的需求，下面提供两种常见场景下的实现方案，适配不同的业务隔离需求：

场景一：多独立RabbitMQ实例的多事件总线 #

如果你的不同业务需要连接到不同的RabbitMQ服务器实例，可以通过定义专属接口+独立注册的方式实现：

1. 定义专属连接接口 #

为每个事件总线创建独立的连接接口，区分不同实例的连接：

// 订单业务事件总线连接接口
public interface IOrderRabbitMQPersistentConnection : IRabbitMQPersistentConnection { }

// 支付业务事件总线连接接口
public interface IPaymentRabbitMQPersistentConnection : IRabbitMQPersistentConnection { }

2. 在Startup.cs中注册独立连接与事件总线 #

分别为每个业务注册对应的持久化连接和事件总线实例：

// 注册订单业务的RabbitMQ持久化连接
services.AddSingleton<IOrderRabbitMQPersistentConnection>(sp =>
{
    var logger = sp.GetRequiredService<ILogger<DefaultRabbitMQPersistentConnection>>();
    var factory = new ConnectionFactory()
    {
        HostName = Configuration["RabbitMQ:Order:HostName"],
        DispatchConsumersAsync = true,
        UserName = Configuration["RabbitMQ:Order:UserName"],
        Password = Configuration["RabbitMQ:Order:Password"]
    };
    var retryCount = int.Parse(Configuration["RabbitMQ:Order:RetryCount"] ?? "5");
    return new DefaultRabbitMQPersistentConnection(factory, logger, retryCount);
});

// 注册支付业务的RabbitMQ持久化连接
services.AddSingleton<IPaymentRabbitMQPersistentConnection>(sp =>
{
    var logger = sp.GetRequiredService<ILogger<DefaultRabbitMQPersistentConnection>>();
    var factory = new ConnectionFactory()
    {
        HostName = Configuration["RabbitMQ:Payment:HostName"],
        DispatchConsumersAsync = true,
        UserName = Configuration["RabbitMQ:Payment:UserName"],
        Password = Configuration["RabbitMQ:Payment:Password"]
    };
    var retryCount = int.Parse(Configuration["RabbitMQ:Payment:RetryCount"] ?? "5");
    return new DefaultRabbitMQPersistentConnection(factory, logger, retryCount);
});

// 注册订单事件总线（假设你的事件总线实现依赖连接、日志、订阅管理器）
services.AddSingleton<IOrderEventBus>(sp =>
{
    var connection = sp.GetRequiredService<IOrderRabbitMQPersistentConnection>();
    var logger = sp.GetRequiredService<ILogger<DefaultEventBus>>();
    var subscriptionManager = sp.GetRequiredService<IEventBusSubscriptionsManager>();
    return new DefaultEventBus(connection, logger, subscriptionManager, "order_bus_exchange", retryCount: 5);
});

// 注册支付事件总线
services.AddSingleton<IPaymentEventBus>(sp =>
{
    var connection = sp.GetRequiredService<IPaymentRabbitMQPersistentConnection>();
    var logger = sp.GetRequiredService<ILogger<DefaultEventBus>>();
    var subscriptionManager = sp.GetRequiredService<IEventBusSubscriptionsManager>();
    return new DefaultEventBus(connection, logger, subscriptionManager, "payment_bus_exchange", retryCount: 5);
});

3. 配置文件（appsettings.json） #

添加对应实例的配置项：

"RabbitMQ": {
  "Order": {
    "HostName": "xxx.xxx.xxx.xxx",
    "UserName": "order_service_user",
    "Password": "order_service_pwd",
    "RetryCount": 5
  },
  "Payment": {
    "HostName": "yyy.yyy.yyy.yyy",
    "UserName": "payment_service_user",
    "Password": "payment_service_pwd",
    "RetryCount": 5
  }
}

4. 使用方式 #

在业务类中直接注入对应的事件总线接口即可：

public class OrderService
{
    private readonly IOrderEventBus _orderEventBus;

    public OrderService(IOrderEventBus orderEventBus)
    {
        _orderEventBus = orderEventBus;
    }

    public void PublishOrderCreated(OrderCreatedEvent evt)
    {
        _orderEventBus.Publish(evt);
    }
}

场景二：同一RabbitMQ实例下的多事件总线 #

如果所有业务共享同一个RabbitMQ实例，仅需要业务隔离的交换机/队列，可以复用单个连接，创建多个事件总线实例：

1. 注册通用持久化连接 #

保留原有的单连接注册，复用同一个RabbitMQ连接：

services.AddSingleton<IRabbitMQPersistentConnection>(sp =>
{
    var logger = sp.GetRequiredService<ILogger<DefaultRabbitMQPersistentConnection>>();
    var factory = new ConnectionFactory()
    {
        HostName = Configuration["RabbitMQ:HostName"],
        DispatchConsumersAsync = true,
        UserName = Configuration["RabbitMQ:UserName"],
        Password = Configuration["RabbitMQ:Password"]
    };
    var retryCount = int.Parse(Configuration["RabbitMQ:RetryCount"] ?? "5");
    return new DefaultRabbitMQPersistentConnection(factory, logger, retryCount);
});

2. 注册多个事件总线实例 #

为每个业务创建独立的事件总线，指定不同的交换机名称实现隔离：

// 注册订单事件总线
services.AddSingleton<IOrderEventBus>(sp =>
{
    var connection = sp.GetRequiredService<IRabbitMQPersistentConnection>();
    var logger = sp.GetRequiredService<ILogger<DefaultEventBus>>();
    var subscriptionManager = sp.GetRequiredService<IEventBusSubscriptionsManager>();
    return new DefaultEventBus(connection, logger, subscriptionManager, "order_bus_exchange", retryCount: 5);
});

// 注册支付事件总线
services.AddSingleton<IPaymentEventBus>(sp =>
{
    var connection = sp.GetRequiredService<IRabbitMQPersistentConnection>();
    var logger = sp.GetRequiredService<ILogger<DefaultEventBus>>();
    var subscriptionManager = sp.GetRequiredService<IEventBusSubscriptionsManager>();
    return new DefaultEventBus(connection, logger, subscriptionManager, "payment_bus_exchange", retryCount: 5);
});

3. 订阅管理器隔离（可选） #

如果需要完全隔离不同总线的订阅信息，可为每个总线单独创建订阅管理器：

// 为订单总线注册专属订阅管理器
services.AddSingleton<IEventBusSubscriptionsManager>("Order", sp => new InMemoryEventBusSubscriptionsManager());
// 为支付总线注册专属订阅管理器
services.AddSingleton<IEventBusSubscriptionsManager>("Payment", sp => new InMemoryEventBusSubscriptionsManager());

// 注册事件总线时指定对应订阅管理器
services.AddSingleton<IOrderEventBus>(sp =>
{
    var connection = sp.GetRequiredService<IRabbitMQPersistentConnection>();
    var logger = sp.GetRequiredService<ILogger<DefaultEventBus>>();
    var subscriptionManager = sp.GetRequiredService<IEventBusSubscriptionsManager>("Order");
    return new DefaultEventBus(connection, logger, subscriptionManager, "order_bus_exchange", retryCount: 5);
});

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