MassTransit.Azure.ServiceBus.Core 8.2.3短暂断开后未自动重连问题咨询

我们的Azure Service Fabric服务与Azure Service Bus断开连接后，数小时内未自动重连。重启虚拟机规模集后连接恢复，业务恢复正常。使用版本为MassTransit.Azure.ServiceBus.Core (8.2.3)，报错信息如下：

The service was unable to process the request; please retry the operation. For more information on exception types and proper exception handling, please refer to http://go.microsoft.com/fwlink/?LinkId=761101 TrackingId:ac18b203682c470d92fd98a2e34654a6_G18, SystemTracker:gateway10, Timestamp:2025-01-08T22:00:01 (GeneralError). For troubleshooting information, see https://aka.ms/azsdk/net/servicebus/exceptions/troubleshoot. 

Azure支持回应称该问题源于服务端网关故障（节点定期重启导致），属于临时错误，服务端已自动恢复。现咨询：为何MassTransit的重试逻辑未触发重连？该如何处理此类情况？

为什么重试逻辑未触发重连？ #

• 异常类型未被默认重试策略覆盖：MassTransit默认重试规则可能未将GeneralError这类网关级临时异常标记为可重试范围。Azure Service Bus返回的该错误属于服务端临时故障，但内置筛选逻辑没包含这类错误码。
• 消息重试与连接重试分离：MassTransit的消息重试和底层连接重试是独立逻辑，默认消息重试不会处理连接中断场景，需单独配置传输级的连接重试策略。
• 版本存在处理疏漏：你使用的8.2.3版本可能对Azure Service Bus网关异常的处理存在不足，后续版本已修复相关问题。

处理方案 #

1. 自定义异常筛选，覆盖临时错误 #

配置MassTransit时，显式添加对网关临时异常的重试支持：

services.AddMassTransit(x =>
{
    x.UsingAzureServiceBus((context, cfg) =>
    {
        cfg.Host("your-service-bus-connection-string");
        
        // 消息级重试，包含网关临时错误
        cfg.UseRetry(r =>
        {
            r.Exponential(5, TimeSpan.FromSeconds(2), TimeSpan.FromMinutes(1), 2);
            r.Handle<ServiceBusException>(ex => 
                ex.Reason == ServiceBusFailureReason.GeneralError && ex.IsTransient);
        });
        
        // 传输级重试，处理连接中断
        cfg.UseServiceBusRetry(r =>
        {
            r.Exponential(10, TimeSpan.FromSeconds(2), TimeSpan.FromMinutes(5), 2);
            r.Handle<ServiceBusException>(ex => ex.IsTransient);
        });
    });
});

2. 显式配置连接恢复机制 #

在Host配置中指定连接重试参数，确保自动重连生效：

cfg.Host("your-service-bus-connection-string", h =>
{
    h.TransportType = ServiceBusTransportType.AmqpWebSockets;
    h.RetryLimit = 10; // 连接重试次数
});

3. 升级MassTransit版本 #

将MassTransit.Azure.ServiceBus.Core升级至最新稳定版，新版本优化了对Azure Service Bus各类临时异常的处理逻辑，包含网关故障的自动重连。

4. 添加连接状态监控 #

实现接收观察者，监控连接状态，故障时触发告警或主动处理：

cfg.ConnectReceiveObserver(new ConnectionStatusObserver());

public class ConnectionStatusObserver : IReceiveObserver
{
    public Task PreReceive(ReceiveContext context) => Task.CompletedTask;
    public Task PostReceive(ReceiveContext context) => Task.CompletedTask;
    public Task PostConsume<T>(ConsumeContext<T> context) where T : class => Task.CompletedTask;
    public Task ConsumeFault<T>(ConsumeContext<T> context, Exception exception) => Task.CompletedTask;
    public Task ReceiveFault(ReceiveContext context, Exception exception)
    {
        // 记录故障日志、触发告警或执行重连逻辑
        return Task.CompletedTask;
    }
}

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