MassTransit Hosted Service Saga状态机HTTP POST请求超时问题排查

可能原因 #

• 消息契约不匹配：发送的匿名对象和SubmitOrder契约的字段、类型存在差异，MassTransit无法匹配到消费逻辑，消息会进入死信队列无响应返回。
• 消费者端点地址不匹配：发布方配置的SubmitOrder请求客户端绑定的是SubmitOrderConsumer对应队列，但后端托管服务仅注册了OrderStateMachine Saga状态机，若SubmitOrder由Saga消费，请求会发送到错误队列无人处理。
• Saga状态机未正确处理事件：OrderStateMachine中未定义SubmitOrder事件的处理逻辑，或处理完成后未返回OrderSubmissionAccepted/OrderSubmissionRejected响应。
• 默认请求超时阈值过短：MassTransit默认请求超时为30秒，若Saga处理逻辑存在延迟、IO等待耗时超过阈值会触发超时。
• RabbitMQ队列消息堆积：对应队列存在未消费消息，可能是消费者未启动、消费逻辑卡死导致处理不及时。

排查步骤 #

• 登录RabbitMQ管理后台（默认端口15672），检查请求目标队列是否有消息进入，是否有消息流转到死信队列，若消息进入死信优先排查契约匹配、队列消费者绑定问题。
• 给Saga状态机添加事件接收日志，确认Saga是否正常接收到SubmitOrder请求消息，未收到则排查队列地址、契约匹配问题。
• 检查Saga处理逻辑，确认处理完SubmitOrder事件后是否调用了RespondAsync方法返回对应类型的响应，漏发响应会导致客户端无返回等待超时。
• 逐一核对发送的消息字段和SubmitOrder类的字段名、类型、可空性是否完全一致，比如发送的Timestamp类型是否和契约定义匹配。

解决方法 #

• 队列地址错误修正：将发布方SubmitOrder请求客户端的地址改为Saga对应的端点地址，使用KebabCaseEndpointNameFormatter.Instance.Saga<OrderState>()生成正确队列名替换原消费者队列名。
• 契约不匹配修正：发送请求时直接实例化SubmitOrder类赋值，避免匿名对象字段写错问题，示例代码：

await _submitOrderRequestClient.GetResponse<OrderSubmissionAccepted, OrderSubmissionRejected>(new SubmitOrder
{
    OrderId = model.Id,
    Timestamp = InVar.Timestamp,
    CustomerNumber = model.CustomerNumber,
    PaymentCardNumber = model.PaymentCardNumber,
    Notes = model.Notes
});

• 超时时长调整：注册请求客户端时指定更长的超时时间，示例：

mt.AddRequestClient<SubmitOrder>(new Uri($"queue:{KebabCaseEndpointNameFormatter.Instance.Saga<OrderState>()}"), TimeSpan.FromMinutes(1));

• 补全Saga响应逻辑：在Saga的SubmitOrder事件处理逻辑中添加响应返回，示例：

When(SubmitOrder)
    .Then(context => 
    {
        // 业务处理逻辑
    })
    .RespondAsync(context => context.Init<OrderSubmissionAccepted>(new 
    {
        OrderId = context.Saga.CorrelationId
    }))
    .TransitionTo(Submitted);

• 若SubmitOrder由普通Consumer而非Saga处理，在托管服务的MassTransit配置中添加x.AddConsumer<SubmitOrderConsumer>();注册消费者。

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