Azure Service Bus下MassTransit Saga简化配置及事件消费问题咨询

结论 #

MassTransit Saga 可以直接消费 Azure Service Bus（ASB）主题订阅的消息，不需要额外配置订阅到队列的转发规则，完全符合你简化配置、提升吞吐量的需求。

实现逻辑 #

ASB 订阅本身具备和队列一致的消息持久化、并发消费、死信队列等能力，MassTransit 原生支持将消费者（包括 Saga）直接绑定到主题订阅进行消费，跳过中间队列转发链路后，减少了一次消息读写开销，能直接提升吞吐量，也降低了部署维护复杂度。

配置示例 #

你只需要在原有 Saga 配置的基础上，新增订阅端点绑定对应事件即可，参考代码如下：

services.AddMassTransit(x =>
{
    // 注册你的Saga状态机和状态，持久化方式替换为你实际使用的方案（如EF Core、Azure表存储等）
    x.AddSagaStateMachine<MySagaStateMachine, MySagaState>()
        .UseEntityFrameworkRepository();

    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("你的ASB服务连接字符串");

        // 原有配置：从my-saga-queue队列消费CreateSaga命令
        cfg.ReceiveEndpoint("my-saga-queue", e =>
        {
            e.ConfigureSaga<MySagaState>(context);
        });

        // 新增配置：直接绑定SomethingIsDone事件的订阅，Saga直接消费订阅消息
        cfg.SubscriptionEndpoint<SomethingIsDone>("my-saga-event-subscription", e =>
        {
            // 可根据需求配置并发数、重试规则等
            e.MaxConcurrentCalls = 16;
            e.ConfigureSaga<MySagaState>(context);
        });

        cfg.ConfigureEndpoints(context);
    });
});

注意事项 #

• SubscriptionEndpoint 的第一个泛型参数为要消费的事件类型，MassTransit 默认会匹配该类型对应名称的主题，也可通过配置自定义主题映射规则
• 订阅名建议和你的Saga业务标识绑定，避免和其他服务的订阅冲突
• MassTransit 启动时会自动创建缺失的主题、订阅资源，不需要你手动在ASB控制台预配置，进一步降低部署复杂度
• 多个端点（队列+多个事件订阅）的Saga消费的并发安全由Saga持久化层保障，只要你使用的持久化方案支持乐观/悲观并发控制，就不会出现状态一致性问题
• 如果需要消费多个不同的Saga事件，只要新增多个SubscriptionEndpoint绑定对应事件即可，各个订阅之间互相隔离不影响。

内容的提问来源于stack exchange，提问作者Joel。