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

Question

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

"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 个不同主机的总线实例，并在发布之前自己随机选择其中一个。