10

我已经关注 MassTransit 几个星期了,我很好奇其中的可能性。但是,我似乎无法完全正确地理解这些概念。

预期的行为 我想发布消息以“直接”交换与绑定到两个不同队列以执行其他活动的路由键。

当我使用 MassTransit 尝试相同的逻辑以获得更好的可扩展性时。我发现 MassTransit 基于具有扇出类型的队列名称创建自己的交换。

通过交换和路由键发布消息的经典代码

using (var connection = factory.CreateConnection())
        {
            using (var channel = connection.CreateModel())
            {
                channel.ExchangeDeclare(exchange, "direct");

                var body = Encoding.UTF8.GetBytes(message);

                channel.BasicPublish(exchange, routingKey, null, body);
                Console.WriteLine(" [x] Sent {0}", message);
            }
        }

有没有办法在 MassTransit 中使用 routingkey 配置直接或主题交换?

4

3 回答 3

4

这不是 MassTransit 支持的方案。MassTransit 将始终创建一个扇出队列。如果您自己管理拓扑,则可以使用IEndpoint.Send直接将消息发送到您创建的交换。在这种情况下,你放弃了很多 MT 提供的东西。

我也不确定在这种情况下“更好的可扩展性”意味着什么。扇出交换比直接交换执行得更好(在大多数情况下),因为没有需要处理的路由逻辑。

也许如果您在MassTransit 邮件列表中澄清了您对性能的担忧,我们可以在那里为您提供更多帮助。

于 2015-05-10T12:01:06.413 回答
4

下面的代码做同样的工作,但有一个额外的扇出交换:

TestMessage(直接交换)-> TestMessage_Queue(扇出交换)-> TestMessage_Queue(队列)

var bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    var host = cfg.Host(new Uri("rabbitmq://localhost"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });
    cfg.Send<TestMessage>(x => { x.UseRoutingKeyFormatter(context => "routingKey"); });
    cfg.Message<TestMessage>(x => x.SetEntityName("TestMessage"));
    cfg.Publish<TestMessage>(x => { x.ExchangeType = ExchangeType.Direct; });
    cfg.ReceiveEndpoint(host, "TestMessage_Queue", e =>
    {
        e.BindMessageExchanges = false;
        e.Consumer<UpdateCustomerConsumer>();
        e.Bind("TestMessage", x =>
        {
            x.ExchangeType = ExchangeType.Direct;
            x.RoutingKey = "routingKey";
        });
    });
});

bus.Start();
于 2018-12-09T20:00:51.200 回答
3

MassTransit 在不使用主题交换的情况下处理发布和订阅,而是为正在发布的消息类型创建交换,并将这些交换绑定到消费者队列。

RabbitMQ 的路由密钥方法效率较低,它更喜欢使用交换结构来简化消息路由(无需维护哈希表)。

无需处理交换和路由密钥,只需定义您的命令和/或事件类型,发送或发布这些消息并让消费者完成他们的工作。

于 2015-05-19T14:17:21.797 回答