我有一个RabbitMQ集群xx.xx6、xx.xx7和xx.xx8.我正在try 使用UseCluster方法注册它们:
busConfigurator.UsingRabbitMq((context, configurator) =>
{
var settings = context.GetRequiredService<MessageBrokerSettings>();
if (settings.UseMultiNodes)
{
configurator.Host(settings.VirtualHost,hostConfig =>
{
hostConfig.Username(settings.UserName);
hostConfig.Password(settings.Password);
hostConfig.UseCluster(cluster =>
{
foreach (var host in settings.Hosts)
{
cluster.Node(host);
}
});
});
}
});
});
我知道在我的集群前面使用HAProxy会更有意义,也会更好,但现在这不是一个选项,所以我想在MassTransport(UseCluster)中利用这个功能.在运行应用程序时,由于以下错误,我的整个应用程序无法运行:
未处理的异常.System.ArgumentException:无效的 node 地址:amqp://xx.xx6:5672(参数‘Address’).
请记住,我的RabbitMQ集群可能没有什么问题,因为在使用RabbitMQ.Client库时一切正常,但在try 迁移到MassTransport时,MassTransport导致了这个问题.这至少是我所认为的问题所在.