RabbitHutch.CreateBus() 只允许连接到一个 RabbitMQ 服务器

Question

我有一个应用程序需要连接到 2 个不同的 RabbitMQ 服务器。调用 RabbitHutch.CreateBus(connectionString1) 和 RabbitHutch.CreateBus(connectionString2) 都返回一个连接到 connectionString1 的 IBus。我实施了这种解决方法，但我想从社区中了解是否有更好的方法来实现这一点，或者我的方法是否有效。

var connectionFactory = container.Resolve<IConnectionFactory>();
var logger = container.Resolve<IEasyNetQLogger>();
var eventBus = container.Resolve<IEventBus>();
var connectionConfiguration = container.Resolve<ConnectionConfiguration>();
var persistentConnectionFactory = container.Resolve<IPersistentConnectionFactory>();
var clusterHostSelectionStrategy = container.Resolve<IClusterHostSelectionStrategy<ConnectionFactoryInfo>>();
// override these objects to connect to a different RabbitMQ server
connectionConfiguration = (new ConnectionStringParser()).Parse(configuration["spring:cloud:bus"]);
connectionFactory = new ConnectionFactoryWrapper(connectionConfiguration, clusterHostSelectionStrategy);
persistentConnectionFactory = new PersistentConnectionFactory(logger, connectionFactory, eventBus);
_bus = new RabbitAdvancedBus(
    connectionFactory,
    container.Resolve<IConsumerFactory>(),
    logger,
    container.Resolve<IClientCommandDispatcherFactory>(),
    container.Resolve<IPublishConfirmationListener>(),
    eventBus,
    container.Resolve<IHandlerCollectionFactory>(),
    container,
    connectionConfiguration,
    container.Resolve<IProduceConsumeInterceptor>(),
    container.Resolve<IMessageSerializationStrategy>(),
    container.Resolve<IConventions>(),
    container.Resolve<AdvancedBusEventHandlers>(),
    persistentConnectionFactory);

Answer 1

您使用的是哪种 DI 实现？

您可以创建 2 个容器吗？所有总线组件都注册为单例，我不想在 2 个总线实例之间共享它们。

或者，您可以尝试从根容器创建 2 个子作用域，并在每个容器中注册不同的总线实例。