跨Web API使用MassTransit请求响应遇超时问题求助

核心问题根源 #

你当前的配置存在两个致命问题：

1. 传输方式错误：使用InMemory传输仅支持进程内通信，但你是两个独立的Web API项目（跨进程），所以当Provider端注释掉本地Consumer后，请求根本无法传递到另一个API的Consumer，自然超时；而不注释时，请求是被Provider自己进程内的Consumer处理的，并非真正的跨服务调用。
2. 版本不兼容：MassTransit主包是8.3.4，但MassTransit.AspNetCore和MassTransit.Extensions.DependencyInjection是7.3.1，版本不匹配会导致潜在的配置异常。

步骤1：统一依赖包版本 #

先把所有MassTransit相关包版本统一，推荐使用最新稳定版（这里以8.3.4为例），并替换为支持跨进程的RabbitMQ传输包：

<PackageReference Include="MassTransit" Version="8.3.4" />
<PackageReference Include="MassTransit.AspNetCore" Version="8.3.4" />
<PackageReference Include="MassTransit.RabbitMQ" Version="8.3.4" />

注：如果用其他中间件（如Azure Service Bus），替换对应的传输包即可。

步骤2：修正Provider端（请求发起端）配置 #

Provider端是发起请求的服务，不需要注册Consumer，只需配置RequestClient指向Consumer端的队列地址：

// Program.cs
builder.Services.AddMassTransit(x =>
{
    // 注册请求客户端，无需添加本地Consumer
    x.AddRequestClient<CheckOrderStatus>(TimeSpan.FromSeconds(10)); // 可自定义超时时间

    x.UsingRabbitMq((context, cfg) =>
    {
        // 连接到你的RabbitMQ服务，根据实际配置修改
        cfg.Host("localhost", "/", h =>
        {
            h.Username("guest");
            h.Password("guest");
        });

        // 指定请求发送到Consumer端的队列地址
        cfg.ConfigureRequestClient<CheckOrderStatus>(new Uri("queue:check-order-status"));
    });
});

Controller代码保持不变（注意取消注释GetResponse的代码）：

[HttpGet("{orderId}")]
public async Task<IActionResult> Get(string orderId, CancellationToken cancellationToken)
{
    var response = await _client.GetResponse<OrderStatusResult>(new { orderId }, cancellationToken);
    return Ok(response.Message);
}

步骤3：修正Consumer端（请求处理端）配置 #

Consumer端需要注册自己的Consumer，并监听指定队列：

// Program.cs
builder.Services.AddMassTransit(x =>
{
    // 注册处理请求的Consumer
    x.AddConsumer<CheckOrderStatusConsumer>();

    x.UsingRabbitMq((context, cfg) =>
    {
        // 连接到同一个RabbitMQ服务
        cfg.Host("localhost", "/", h =>
        {
            h.Username("guest");
            h.Password("guest");
        });

        // 配置Consumer监听的队列，名称要和Provider端指定的一致
        cfg.ReceiveEndpoint("check-order-status", e =>
        {
            e.ConfigureConsumer<CheckOrderStatusConsumer>(context);
        });
    });
});

Consumer代码保持不变：

public class CheckOrderStatusConsumer : IConsumer<CheckOrderStatus>
{
    public async Task Consume(ConsumeContext<CheckOrderStatus> context)
    {
        await context.RespondAsync<OrderStatusResult>(new
        {
            OrderId = context.Message.OrderId, // 这里可以使用传入的orderId，而不是固定值
        });
    }
}

额外注意事项 #

1. 消息契约共享：CheckOrderStatus和OrderStatusResult这两个消息类必须放在两个API都能引用的独立类库中，确保命名空间、属性完全一致，否则MassTransit无法正确序列化/反序列化。
2. RabbitMQ服务启动：确保本地或服务器上的RabbitMQ服务已经正常运行，并且配置的用户名密码有权限访问。

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