rabbitmq - EasyNETQ 集群 - IClusterHostSelectionStrategy 在发布消息时不起作用

Question

我添加了新的 RabbitMQ 服务器并将我的发布者连接字符串配置为

"host=PC1:5672,PC2:5672"

var bus = RabbitHutch.CreateBus(connectionString, x => x.Register<IClusterHostSelectionStrategy<ConnectionFactoryInfo>, RandomClusterHostSelectionStrategy<ConnectionFactoryInfo>>());

当我发布时，我正在使用bus.Publish(msg)

当我发布消息时，消息仅发送到 PC 1。我如何确保消息将随机发送给两者。

Answer 1

该实例仅在您实例化它时创建 1 个连接，但会随机选择该主机。

如果您真的想发送到随机主机，您可以创建 2 个连接到 2 个不同主机的总线实例，并在发布之前自己随机选择其中一个。