4

有人成功让 MassTransit 与 AppHarbor 和 CloudAMQP 合作吗？

我对它感到很厌烦。

我让发布者（网站）发送消息，但服务器（后台工作人员）似乎没有接收它们。

我担心的一件事是 MT 需要 rabbitmq 方案，而 CloudAMQP 将方案设置为 amqp。

我在配置总线时正在交换方案（从 amqp 到 rabbitmq），并注意到消息地址中的方案是 rabbitmq，这是有道理的，因为我替换了它们。但我想知道他们是否必须是 amqp 才能让服务器接他们？

这是我发送的一条简单消息，它到达了 RabbitMQ，但服务器没有接收到它。

message_id: 08cf2cbc-5b4f-14dd-1231-381f8b520000
delivery_mode:  2
headers:    
Content-Type:   application/vnd.masstransit+json
Payload
614 bytes
Encoding: string
{

  "destinationAddress": "rabbitmq://98eabe2a-aae8-464c-8555-855518dd87d0_apphb.com:*********@lemur.cloudamqp.com/98eabe2a-aae8-464c-8555-855518dd87d0_apphb.com/Messages.Product:ProductCreatedEvent",

  "headers": {},

  "message": {

    "id": "dd6ecfaa-60d2-4cd4-8cd6-a08a00e872fb"

  },

  "messageType": [

    "urn:message:Messages.Product:ProductCreatedEvent"

  ],

  "retryCount": 0,

  "sourceAddress": "rabbitmq://98eabe2a-aae8-464c-8555-855518dd87d0_apphb.com:**********@lemur.cloudamqp.com/98eabe2a-aae8-464c-8555-855518dd87d0_apphb.com/enterprise_web"

}

谢谢，乔

编辑：感谢卡尔指出网址中的密码

4

2 回答 2

7

编辑：为了让其他人考虑将 MassTransit 与 CloudAMQP 一起使用，您可能需要查看 EasyNetQ。没有从大众运输中拿走任何东西，这是一个伟大的项目。将它与 CloudAMQP 等每月收取数据使用费的服务一起使用时的问题是，MassTransit 使用轮询来检查消息，而不是订阅它们（至少在我使用的上一个版本 2.1.1 中）。即使您可能没有发布消息，此轮询也会消耗您的数据使用量。

那么这实际上是可能的。

来发现，这都是appharbor上后台worker的配置的一部分。

一旦解决了这个问题，后台工作人员就开始保持“活跃”并使用消息。问题围绕 app.config 与 myworker.exe.config 和配置转换展开。一旦我意识到这是一个配置问题，这个链接就会有所帮助。appharbor 后台工作人员的 App.config 转换

您必须将 amqp 方案换成 rabbitmq，但这还不错。这是后台工作人员的总线配置：

log.Info("Configuring MassTransit");
var rabbitUrl = ConfigurationManager.AppSettings["CLOUDAMQP_URL"];

var bus = ServiceBusFactory.New(sbc =>
{
    // configure for log4net
    sbc.UseLog4Net();

    // configure the bus
    sbc.UseRabbitMq();
    sbc.UseRabbitMqRouting();
    sbc.ReceiveFrom(String.Format("{0}/server", rabbitUrl.Replace("amqp://", "rabbitmq://"))); // need to swap the scheme for masstransit

    // finds all the consumers in the container and register them with the bus
    sbc.Subscribe(x => x.LoadFrom(container));

    sbc.BeforeConsumingMessage(() =>
    {
        var session = container.GetInstance<ISessionFactory>().OpenSession();
        CurrentSessionContext.Bind(session);
    });

    sbc.AfterConsumingMessage(() =>
    {
        var sessionFactory = container.GetInstance<ISessionFactory>();
        if (CurrentSessionContext.HasBind(sessionFactory) == false) return;

        var session = CurrentSessionContext.Unbind(sessionFactory);
        if (session != null)
        {
            session.Dispose();
        }
    });

    var results = sbc.Validate();
    if (results.Any())
    {
        throw new Exception("MassTransit may not be setup correctly. Review validate results");
    }
});

// finally inject the bus into the container
container.Inject(bus);
于 2012-07-11T17:10:10.543 回答
1

我不知道邮件中有任何人这样做。祝你好运，如果你能正常工作，请向邮件列表报告。

MT 使用的协议rabbitmq来确定要使用的传输。

根据RabbitMQ 连接器的 .NET 文档，它应该使用该amqp协议。所以这不应该是问题；但是您可以从其他地方连接到实例吗？

于 2012-07-10T23:53:03.397 回答