Masstransit 和 RabbitMQ 权限答案

【问题标题】：Masstransit and RabbitMQ permissionsMasstransit 和 RabbitMQ 权限
【发布时间】：2015-04-07 02:54:10
【问题描述】：

我正在尝试找出 Masstransit 2.9.9 和 RabbitMQ 3.4.3。我在服务器上安装了 RabbitMQ，并试图从我的桌面获取一个简单的控制台应用程序来发送消息。我创建了另一个管理员登录。

我不断收到权限错误，总线无法初始化。

ACCESS_REFUSED - 使用认证机制 PLAIN 拒绝登录。有关详细信息，请参阅代理日志文件。

当我查看日志文件时，即使我发送另一个登录信息，它似乎也使用了访客。

IServiceBus bus = ServiceBusFactory.New(sbc =>
            {
                sbc.UseRabbitMq(r =>
                  {

                      r.ConfigureHost(new Uri("rabbitmq://server/vhost/queue"), h =>
                      {
                          h.Validate();
                          h.SetUsername("user");
                          h.SetPassword("pwd");
                      });
                  }
                sbc.ReceiveFrom("rabbitmq://server/order_queue");
}

我看到可能需要为 rabbit 配置 ssl 但我不确定。

有什么想法吗？

谢谢

【问题讨论】：

标签： c# rabbitmq masstransit

【解决方案1】：

我遇到了完全相同的问题（我是第一次测试 Masstransit 和 rabbitMq）。我在 Uri 中添加了用户名和密码：

new Uri("rabbitmq://user:pwd@server/vhost/queue")

我认为您的 ReceiveFrom 地址需要用户名和密码。还需要 vhost。

sbc.ReceiveFrom("rabbitmq://user:pwd@server/vhost/order_queue");

【讨论】：

感谢您的建议。我确实尝试过，但它没有用。不再支持 uri 中的密码

【解决方案2】：

敲了敲我的脑袋后，看来 masstransit rabbitmq nuget 软件包附带的 rabbit 客户端有点过时了。我做了更新，代码有效。唯一的变化是从配置主机中删除队列

r.ConfigureHost(new Uri("rabbitmq://server/vhost"), h => ....

【讨论】：