Мобильная версияПроблема конфигурации MassTransit с кластером RabbitMQ ⇐ C#
-
Anonymous
Проблема конфигурации MassTransit с кластером RabbitMQ
У меня есть кластер RabbitMQ xx.xx.xx.xx6, xx.xx.xx.xx.xx7 и xx.xx.xx.xx8. Я пытаюсь зарегистрировать их с помощью метода UseCluster:
busConfigurator.UsingRabbitMq((контекст, конфигуратор) => { настройки var = context.GetRequiredService(); если (settings.UseMultiNodes) { configurator.Host(settings.VirtualHost,hostConfig => { hostConfig.Username(settings.UserName); хостConfig.Пароль(Настройки.Пароль); хостConfig.UseCluster(кластер => { foreach (var хост в настройках.Hosts) { кластер.Узел(хост); } }); }); } }); }); Я понимаю, что использование HAProxy перед моим кластером имело бы больше смысла и было бы намного лучше, но сейчас это невозможно, поэтому я хотел бы использовать эту функцию в MassTransit (UseCluster). При запуске приложения все мое приложение не запускается из-за этой ошибки:
Необработанное исключение. System.ArgumentException: неверный адрес узла: amqp://xx.xx.xx.xx6:5672 (параметр «адрес»).
Имейте в виду, что с моим кластером RabbitMQ, вероятно, все в порядке, потому что при использовании библиотеки RabbitMQ.Client все работало, но MassTransit вызывает проблему при попытке перехода на MassTransit. По крайней мере, в этом, я думаю, проблема.
У меня есть кластер RabbitMQ xx.xx.xx.xx6, xx.xx.xx.xx.xx7 и xx.xx.xx.xx8. Я пытаюсь зарегистрировать их с помощью метода UseCluster:
busConfigurator.UsingRabbitMq((контекст, конфигуратор) => { настройки var = context.GetRequiredService(); если (settings.UseMultiNodes) { configurator.Host(settings.VirtualHost,hostConfig => { hostConfig.Username(settings.UserName); хостConfig.Пароль(Настройки.Пароль); хостConfig.UseCluster(кластер => { foreach (var хост в настройках.Hosts) { кластер.Узел(хост); } }); }); } }); }); Я понимаю, что использование HAProxy перед моим кластером имело бы больше смысла и было бы намного лучше, но сейчас это невозможно, поэтому я хотел бы использовать эту функцию в MassTransit (UseCluster). При запуске приложения все мое приложение не запускается из-за этой ошибки:
Необработанное исключение. System.ArgumentException: неверный адрес узла: amqp://xx.xx.xx.xx6:5672 (параметр «адрес»).
Имейте в виду, что с моим кластером RabbitMQ, вероятно, все в порядке, потому что при использовании библиотеки RabbitMQ.Client все работало, но MassTransit вызывает проблему при попытке перехода на MassTransit. По крайней мере, в этом, я думаю, проблема.
