MassTransit.RabbitMQ请求响应场景中RequestTimeoutException问题排查

刚好碰到过类似的坑，结合你的场景来梳理下：你在ASP.NET Core 2 Web应用和.NET Core 2控制台项目中，用MassTransit.RabbitMQ（版本4.0.1.1378-develop）实现请求/响应模式时，服务端明明能收到请求并返回响应，但客户端始终抛出RequestTimeoutException，试了多种服务端响应写法都无效。

问题根源 #

后来发现核心问题是客户端的总线根本没启动——你在创建完总线实例后，忘记调用bus.Start()了！MassTransit的总线需要显式启动才能监听响应队列，否则客户端发送请求后，永远收不到服务端的响应，最终触发超时。

修正后的客户端配置代码 #

首先，在ASP.NET Core的Startup.cs中，创建总线后一定要启动它，同时建议配置优雅关闭（避免应用停止时出现资源泄漏）：

public void ConfigureServices(IServiceCollection services)
{
    var bus = Bus.Factory.CreateUsingRabbitMq(sbc => 
    {
        sbc.Host(new Uri("rabbitmq://localhost"), h => 
        {
            h.Username("guest");
            h.Password("guest"); 
        });
    });

    // 必须启动总线，否则无法接收响应
    bus.Start();

    services.AddSingleton<IPublishEndpoint>(bus);
    services.AddSingleton<IBusControl>(bus);

    var requestTimeout = TimeSpan.FromSeconds(10);
    var address = new Uri("rabbitmq://localhost/myqueue");
    services.AddScoped<IRequestClient<SubmitOrder, OrderSubmitResult>>(ctx => 
        new MessageRequestClient<SubmitOrder, OrderSubmitResult>(bus, address, requestTimeout));
}

// 配置优雅关闭逻辑
public void Configure(IApplicationBuilder app, IHostingEnvironment env, 
    IApplicationLifetime applicationLifetime, IBusControl bus)
{
    // 应用停止时，优雅停止总线（等待10秒处理剩余消息）
    applicationLifetime.ApplicationStopping.Register(() => bus.Stop(TimeSpan.FromSeconds(10)));

    // 其他中间件配置...
}

服务端代码确认 #

你的服务端代码是完全没问题的，几种响应方式都可以正常工作，比如常用的Handler写法：

var bus = Bus.Factory.CreateUsingRabbitMq(cfg => 
{
    var host = cfg.Host(new Uri("rabbitmq://localhost"), h => 
    {
        h.Username("guest");
        h.Password("guest");
    });

    cfg.ReceiveEndpoint(host, "myqueue", ep => 
    {
        // 同步Handler写法
        ep.Handler<SubmitOrder>(context => context.RespondAsync(new OrderSubmitResult()));
        
        // 异步Handler写法也支持
        // ep.Handler<SubmitOrder>(async context =>
        // {
        //     await context.RespondAsync(new OrderSubmitResult());
        // });
        
        // 或者使用自定义Consumer
        // ep.Consumer<SubmitOrderConsumer>();
    });
});

// 服务端总线同样需要启动
bus.Start();

关键注意点 #

• 总线实例必须全局单例管理，所以一定要注册为Singleton，避免重复创建RabbitMQ连接资源
• 客户端和服务端的总线都必须调用bus.Start()才能正常工作，这是最容易遗漏的点
• 优雅关闭逻辑很重要，能避免应用停止时出现未处理消息丢失或连接泄漏

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