C# Azure Service Bus队列触发器长时运行锁无效异常解决方案咨询

该错误本质是Azure Service Bus在默认PeekLock接收模式下，消息锁的有效期最大仅支持5分钟，当函数执行长耗时任务的时长超过锁有效期时，锁会被服务端自动释放，后续函数尝试完成/废弃消息时就会抛出以下异常：

"The lock supplied is invalid. Either the lock expired, or the message has already been removed from the queue."

方案1：开启Service Bus触发器自动锁续订（最推荐） #

Azure Functions Service Bus触发器内置自动锁续订能力，开启后会在锁到期前自动发起续订，无需手动干预，最长可续订到你设置的总时长。

进程内模型host.json配置示例 #

{
  "version": "2.0",
  "extensions": {
    "serviceBus": {
      "messageHandlerOptions": {
        "autoComplete": true,
        "maxAutoRenewDuration": "00:30:00" // 按需设置最长自动续订总时长，示例为30分钟
      }
    }
  }
}

隔离工作者模型host.json配置示例 #

{
  "version": "2.0",
  "extensions": {
    "serviceBus": {
      "processorOptions": {
        "autoCompleteMessages": true,
        "maxAutoLockRenewalDuration": "00:30:00"
      }
    }
  }
}

方案2：手动续订消息锁（适合需要精细控制的场景） #

如果不想依赖自动续订，也可以在业务代码中主动调用续订接口，自己控制锁的生命周期，代码示例如下：

using Azure.Messaging.ServiceBus;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using System;
using System.Threading.Tasks;

public class LongRunningTaskFunction
{
    private readonly TaskCompletionSource<bool> _taskFinishSource = new();

    [FunctionName("LongRunningTaskFunction")]
    public async Task Run(
        [ServiceBusTrigger("your-queue-name", Connection = "ServiceBusConnection")] 
        ServiceBusReceivedMessage message,
        ServiceBusMessageActions messageActions,
        ILogger log)
    {
        log.LogInformation("开始处理消息：{MessageId}", message.MessageId);

        // 后台定时续订任务，比最大锁有效期早1分钟续订，避免过期
        var renewLockBackgroundTask = Task.Run(async () =>
        {
            while (!_taskFinishSource.Task.IsCompleted)
            {
                await Task.Delay(TimeSpan.FromMinutes(4));
                if (!_taskFinishSource.Task.IsCompleted)
                {
                    await messageActions.RenewLockAsync(message);
                    log.LogInformation("手动续订消息{MessageId}锁成功", message.MessageId);
                }
            }
        });

        // 你的实际长耗时业务逻辑
        await ExecuteLongBusinessLogic();

        // 标记任务完成，终止续订后台任务
        _taskFinishSource.SetResult(true);
        await renewLockBackgroundTask;

        // 处理完成后确认消息（如果autoComplete设为false需要手动调用）
        await messageActions.CompleteMessageAsync(message);
        log.LogInformation("消息{MessageId}处理完成", message.MessageId);
    }

    private async Task ExecuteLongBusinessLogic()
    {
        // 模拟20分钟长耗时任务
        await Task.Delay(TimeSpan.FromMinutes(20));
    }
}

方案3：调整队列锁超时时间（适合任务时长≤5分钟的场景） #

如果你的任务时长仅略超默认锁时长，且不超过5分钟，可以直接调整队列/订阅的锁有效期到最大值，无需额外配置续订：

var queueOptions = new CreateQueueOptions("your-queue-name")
{
    LockDuration = TimeSpan.FromMinutes(5) // Service Bus支持的最大锁有效期为5分钟
};
await serviceBusAdministrationClient.CreateQueueAsync(queueOptions);

也可以直接在Azure门户的Service Bus队列配置页面修改Lock duration参数。

方案4：拆分长耗时任务 #

如果单任务时长超过数小时，建议将长任务拆分为多个串行子步骤，使用Durable Functions编排执行，每个子步骤处理完成后立即确认当前消息，触发下一个子步骤的消息，从根本上避免单任务锁过期问题。

• 消费计划下的Azure Functions最长执行时间默认是5分钟，最大可调整到10分钟，如需更长的任务执行时长请切换到Premium计划或专用App Service计划，最长可支持24小时执行时长。
• maxAutoRenewDuration配置值不能超过函数的最大执行时长，否则自动续订会提前终止。
• 自动续订和手动续订二选一即可，不需要同时配置。

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