MassTransit配置Azure Service Bus消息投递重试机制失效问题

你遇到的问题核心是之前的配置对象不对：

• h.RetryLimit是Azure Service Bus SDK原生客户端的重试设置，默认就是4次，所以你看到的4次重试是SDK层面的，不是MassTransit的。
• cfg.UseMessageRetry是配置消费消息阶段的重试策略，对Send操作完全不生效。

可以仅通过MassTransit内置机制实现发送端重试，不需要依赖Polly，具体配置方式有两种：

1. 全局配置发送端重试策略 #

在创建Bus实例时，通过ConfigureSend全局设置所有发送操作的重试规则：

_busControl = Bus.Factory.CreateUsingAzureServiceBus(cfg =>
{
    cfg.Host(new Uri(serviceBusUri), h => 
    {
        h.NamedKeyCredential = new AzureNamedKeyCredential("name","key");
        // 若需调整Azure SDK的重试，可在此配置（可选，与MassTransit重试独立）
        // h.ConfigureClientOptions(options =>
        // {
        //     options.Retry.MaxRetries = 0; // 关闭SDK层面重试，仅用MassTransit重试
        // });
    });

    // 配置全局发送重试
    cfg.ConfigureSend(sendCfg =>
    {
        sendCfg.UseRetry(retryCfg =>
        {
            // 示例：间隔1秒重试，最多8次
            retryCfg.Interval(8, TimeSpan.FromSeconds(1));
            // 也可使用立即重试：retryCfg.Immediate(8);
            // 针对性处理可重试异常
            retryCfg.Handle<SocketException>();
            retryCfg.Handle<ServiceBusException>(ex => ex.Reason == ServiceBusFailureReason.ServiceCommunicationProblem);
        });
    });
});

2. 单个Send操作单独配置重试 #

如果不需要全局生效，可以在单次发送时单独设置重试规则：

public async Task Send<TMessage>(TMessage message) where TMessage : IMessage
{
     var sendEndpoint = await _busControl.GetSendEndpoint(new Uri("queue-uri"));
     await sendEndpoint.Send(message, typeof(TMessage), context =>
     {
         context.UseRetry(retryCfg =>
         {
             retryCfg.Interval(8, TimeSpan.FromSeconds(1));
             retryCfg.Handle<SocketException>();
             retryCfg.Handle<ServiceBusException>(ex => ex.Reason == ServiceBusFailureReason.ServiceCommunicationProblem);
         });
     });
}

关键说明 #

• MassTransit发送重试与Azure SDK重试是独立机制：若两者同时配置，会先触发SDK重试，再触发MassTransit重试。若仅需MassTransit重试，可将SDK重试次数设为0。
• 建议针对性指定可重试异常：避免对消息格式错误等无法通过重试解决的问题做无效重试。

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