Azure Service Bus下MassTransit路由Slip创建Topic陷入循环

架构老林

2026-7-21

MassTransit路由Slip在Azure Service Bus中循环创建Topic问题排查与解决

问题现象

基于MassTransit开发的路由Slip功能，使用内存代理时运行正常
切换到Azure Service Bus后，执行路由Slip时进程持续输出创建Topic的日志，后续逻辑完全无法推进
RabbitMQ使用exchange:协议时功能正常

原因分析

Azure Service Bus的Topic/Subscription模型和RabbitMQ的Exchange/Queue模型存在本质差异，MassTransit的Routing Slip在Azure Service Bus下的默认配置触发了循环创建Topic的逻辑：

Routing Slip的活动生成后续步骤消息时，Azure Service Bus的拓扑创建逻辑未正确识别已存在的Topic，导致反复尝试创建
大概率是沿用了RabbitMQ的exchange:地址格式，而Azure Service Bus要求使用topic:前缀，格式不匹配触发了错误的拓扑创建流程

解决方案

修正Routing Slip活动的地址格式
将活动地址的前缀从exchange:改为topic:，示例代码：

// 原RabbitMQ格式（错误）
var activityAddress = new Uri("exchange:order-validation");
// Azure Service Bus适配格式（正确）
var activityAddress = new Uri("topic:order-validation");

可选：关闭自动创建拓扑
如果已经手动在Azure门户创建了所需的Topic和Subscription，可以在配置中关闭自动创建，避免重复创建逻辑：

services.AddMassTransit(x =>
{
    // 配置你的活动和路由Slip逻辑...
    
    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("你的Azure Service Bus连接字符串");
        
        // 禁用自动创建拓扑
        cfg.AutoCreate = false;
    });
});

检查路由Slip完成地址的格式
确保路由Slip的完成事件地址也使用正确的topic:格式，避免因完成消息地址错误触发额外的拓扑创建：

var routingSlip = new RoutingSlipBuilder()
    .AddActivity("OrderValidation", new Uri("topic:order-validation"))
    .SetCompletedAddress(new Uri("topic:routing-slip-completed"))
    .Build();