0

我无法在 CloudAMQP 上将 MassTransit 与 RabbitMq 连接起来。下面是我的代码

var bus = Bus.Factory.CreateUsingRabbitMq(otions => {
    var host = otions.Host(new Uri("rabbitmq://llama-01.rmq.cloudamqp.com"),
    h => { h.Username("my_username"); h.Password("my_password"); });
    otions.ReceiveEndpoint(host, "recvqueue", ep => {
        ep.Handler<Communicate>(Handle);
    });
});

bus.Start();

h.Password并且h.Username是正确的。当我尝试启动总线时,出现以下错误:

RabbitMQ 连接失败:代理无法访问:my_username@llama-01.rmq.cloudamqp.com:5672/

我怀疑问题出在 URI 地址中,但我找不到正确的地址。

4

1 回答 1

1

好吧,我快速浏览了他们的入门,我可以看到您的实例获得了一个与您的用户同名的虚拟主机。

在此处输入图像描述

上图是我订阅免费计划后得到的。

对于 MassTransit,您需要在连接字符串的末尾添加虚拟主机,例如rabbitmq://llama-01.rmq.cloudamqp.com/my_username,或者在主机配置中配置它以及用户名和密码。

于 2019-05-12T21:12:20.977 回答