如何配置MassTransit直接使用Azure Service Bus主题订阅

默认MassTransit会给每个消费者自动创建专属队列，同时生成主题订阅并把消息转发到这个队列。如果想跳过自动生成的这套关联逻辑，手动控制消费者和主题订阅的交互，按以下方式配置：

针对RabbitMQ的配置 #

在Bus配置里，手动指定接收端点（队列），并直接绑定到目标主题，同时明确消息对应的主题名称：

services.AddMassTransit(x =>
{
    x.AddConsumer<YourMessageConsumer>();

    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host("rabbitmq://localhost");

        // 自定义接收队列的名称
        cfg.ReceiveEndpoint("your-custom-subscription-queue", e =>
        {
            // 指定消息对应的主题名称
            e.ConfigureConsumer<YourMessageConsumer>(context, cc =>
            {
                cc.Message<YourMessage>(m => m.SetEntityName("your-target-topic"));
            });

            // 手动将主题绑定到当前队列端点
            e.Bind("your-target-topic", b =>
            {
                // 可选：设置路由键（如果主题用了路由规则）
                b.RoutingKey = "your-routing-key";
            });
        });
    });
});

针对Azure Service Bus的配置 #

如果用Azure Service Bus，可以直接订阅指定主题，自定义订阅名称，无需手动创建队列（底层会自动关联订阅对应的接收队列）：

services.AddMassTransit(x =>
{
    x.AddConsumer<YourMessageConsumer>();

    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("your-service-bus-connection-string");

        // 直接订阅目标主题，设置自定义订阅名
        cfg.SubscribeToTopic<YourMessage>("your-custom-subscription-name", e =>
        {
            e.ConfigureConsumer<YourMessageConsumer>(context);
            
            // 可选：添加过滤规则，只接收符合条件的消息
            e.Filter = "MessageType = 'Critical'";
        });
    });
});

注意事项 #

• 不管用哪种消息中间件，消费者本质上还是通过队列接收消息（主题订阅的核心就是把消息转发到订阅关联的队列），所谓“直接与订阅交互”其实是手动掌控主题、订阅、队列的关联逻辑，不用MassTransit的自动生成规则。
• 如果要复用已有的主题/订阅/队列，确保配置里的名称和现有资源完全一致，避免MassTransit创建新的资源。

内容的提问来源于stack exchange，提问作者Peter Hedberg