ASP.NET Core DI集成MassTransit与Azure Service Bus请求超时问题

我帮你找到了问题的核心，咱们一步步来搞定这个超时问题：

问题根源：重复创建Bus实例 #

你在Startup类里犯了一个关键错误——创建并启动了两个完全独立的Azure Service Bus Bus实例：

• 在ConfigureServices方法里，你初始化了一个Bus并注册为单例，同时启动了它
• 又在Configure方法里再次初始化了一个新的Bus并启动

这就导致了一个“错位”：你的IRequestClient依赖的是ConfigureServices里的Bus实例，它发送请求后会监听自己专属的临时响应队列；而服务端处理完请求后，响应会被发送到Configure里那个Bus实例的临时队列——你的RequestClient根本没在监听这个队列，自然收不到响应，最终触发超时，哪怕服务端已经成功处理了请求。

修复步骤 #

1. 移除Configure方法中的重复Bus代码 #

把Configure方法里创建和启动Bus的两行代码完全删掉，因为你已经在ConfigureServices里注册了单例Bus，不需要再重复创建：

// 删掉Configure里的这两行代码
var bus = InitBus();
bus.Start();

2. 改用MassTransit官方DI扩展管理Bus生命周期 #

手动管理Bus的创建和启动很容易出错，MassTransit提供了专门的ASP.NET Core扩展方法，能自动处理Bus的启动、停止和生命周期，这也是官方推荐的做法。修改你的ConfigureServices方法：

public void ConfigureServices(IServiceCollection services)
{
    services.AddMvc();

    // 使用MassTransit扩展注册服务，自动管理Bus生命周期
    services.AddMassTransit(x =>
    {
        // 如果你的WebAPI需要处理消费者，可以在这里添加，比如x.AddConsumer<YourConsumer>();
        // 目前你的WebAPI是纯发送端，所以这部分可以留空

        x.UsingAzureServiceBus((context, cfg) =>
        {
            cfg.Host(new Uri("你的Service Bus命名空间URL"), h =>
            {
                h.OperationTimeout = TimeSpan.FromSeconds(5);
                h.TokenProvider = TokenProvider.CreateSharedAccessSignatureTokenProvider("KeyName", "KeyValue");
            });
        });
    });

    // 注册RequestClient，保持原有逻辑即可
    services.AddScoped<IRequestClient<SubmitOrder, OrderAccepted>>(x => 
    {
        var timeout = TimeSpan.FromSeconds(10);
        var serviceAddress = new Uri("sb://你的命名空间.servicebus.windows.net/order-service"); // 确保这个地址是接收端的队列地址
        return new MessageRequestClient<SubmitOrder, OrderAccepted>(x.GetRequiredService<IBus>(), serviceAddress, timeout, timeout);
    });

    // 让MassTransit自动启动/停止Bus，替代手动的bus.Start()
    services.AddMassTransitHostedService();
}

3. 验证服务地址正确性 #

确保serviceAddress的格式正确，指向接收端配置的order-service队列，格式应该是：sb://[你的Service Bus命名空间].servicebus.windows.net/order-service

额外注意事项 #

• MassTransit的Bus实例是重量级资源，永远只应该创建一个单例实例，避免重复创建
• 使用AddMassTransitHostedService可以确保应用关闭时自动停止Bus，避免资源泄漏
• 检查Azure Service Bus的SAS令牌权限，确保拥有Send和Listen权限（如果需要管理队列则加Manage）

内容的提问来源于stack exchange，提问作者Danil Karachentsev