如何调整MassTransit适配现有Azure ServiceBus拓扑结构？

我正在研究如何使用MassTransit替换NServiceBus，除了消息序列化及头部信息的兼容性已可行外，在拓扑（队列与主题的设置）方面遇到了问题。例如，我有一个Orders队列，用于接收所有订单相关命令（如CreateOrder、CancelOrder）。通过以下配置可创建Orders队列：

builder.Services.AddMassTransit(mt => {
  mt.AddConsumer<CreateOrderConsumer>();

  mt.UsingAzureServiceBus((context, cfg) => {
    cfg.Host("conn-string");

    cfg.ReceiveEndpoint("Orders", e => {
      e.ConfigureConsumers(context);
    });

  });
});

但该配置同时会创建CreateOrder主题及对应Orders订阅，将消息转发至Orders队列。这改变了现有拓扑，且针对命令这类多对一通信使用主题并不合理。请问如何配置MassTransit仅创建Orders队列，不生成CreateOrder主题，并让发送组件直接向该队列发送消息？

解决方案 #

要实现仅创建指定队列、跳过主题生成，直接向队列发送命令，需要从消费者端点配置和消息发送逻辑两方面调整：

1. 修改消费者端点配置，禁用自动主题订阅 #

在ReceiveEndpoint配置中，关闭自动消费拓扑创建，并为每个消费者单独配置排除主题订阅：

builder.Services.AddMassTransit(mt => {
    mt.AddConsumer<CreateOrderConsumer>();
    mt.AddConsumer<CancelOrderConsumer>(); // 订单相关的其他消费者

    mt.UsingAzureServiceBus((context, cfg) => {
        cfg.Host("conn-string");

        cfg.ReceiveEndpoint("Orders", e => {
            // 关闭端点的自动主题创建与订阅逻辑
            e.ConfigureConsumeTopology = false;

            // 为每个消费者单独配置，排除自动主题绑定
            e.ConfigureConsumer<CreateOrderConsumer>(context, configure =>
            {
                configure.Exclude = true;
            });
            e.ConfigureConsumer<CancelOrderConsumer>(context, configure =>
            {
                configure.Exclude = true;
            });
        });
    });
});

2. 发送消息时直接指定目标队列 #

发送命令时，跳过MassTransit默认的消息类型路由，显式指定发送到Orders队列：

方式1：通过SendEndpoint直接指定队列

public async Task SendCreateOrderCommand(ISendEndpointProvider sendEndpointProvider)
{
    var targetEndpoint = await sendEndpointProvider.GetSendEndpoint(new Uri("queue:Orders"));
    await targetEndpoint.Send(new CreateOrder 
    { 
        // 填充命令数据
        OrderId = Guid.NewGuid(),
        Amount = 199.99m
    });
}

方式2：全局配置消息发送拓扑（可选）

如果希望同类型命令默认都发送到指定队列，可以全局配置发送拓扑：

mt.UsingAzureServiceBus((context, cfg) => {
    // ... 其他配置

    // 为CreateOrder命令配置默认发送到Orders队列，禁用主题
    cfg.Send<CreateOrder>(x =>
    {
        x.UseQueue("Orders");
        x.Exclude = true;
    });

    // 同理配置CancelOrder命令
    cfg.Send<CancelOrder>(x =>
    {
        x.UseQueue("Orders");
        x.Exclude = true;
    });
});

上述配置完成后，MassTransit只会创建Orders队列，不会生成CreateOrder/CancelOrder相关主题，所有订单命令直接发送到Orders队列，与原有NServiceBus的命令队列模式保持一致。

内容的提问来源于stack exchange，提问作者mr.sunshine