如何在Azure Function中实现Service Bus消息的锁自动续期？

1. 调整队列默认锁时长配置 #

• Azure Service Bus队列创建时默认锁时长为30秒，最大可配置为5分钟，该值是单轮锁有效期的上限，锁续期逻辑需要在这个时长范围内触发才能生效。你可以先到Azure门户对应Service Bus队列的配置页面，将Lock duration调整为最大值5分钟，再配合续期参数使用。
• 注意maxAutoRenewDuration控制的是总续期时长，不能突破队列本身的单轮锁时长限制。

2. 修正prefetchCount配置 #

你当前配置的prefetchCount为100，预取的消息会被拉到本地缓存，且从拉取时刻就开始计算锁时间。如果单条消息处理耗时较长、maxConcurrentCalls只有32，会导致大量预取的消息还没进入处理流程就已经过期，锁续期逻辑根本没有机会触发。

• 调整建议：将prefetchCount调整为和maxConcurrentCalls一致或略高（32~64区间），避免消息闲置过期。

3. 切换为手动锁管理（最稳妥方案） #

如果自动续期逻辑依然不稳定，可以关闭自动完成，手动控制锁续期和消息状态：

1. 调整host.json配置：

{
    "version": "2.0",
    "functionTimeout": "00:10:00",
    "extensions": {
        "serviceBus": {
            "prefetchCount": 32,
            "messageHandlerOptions": {
              "autoComplete": false,
              "maxConcurrentCalls": 32,
              "maxAutoRenewDuration": "00:10:00"
            }
        }
    }
}

2. 调整Function代码，手动实现锁续期：

[FunctionName("ServiceBusHandler")]
public async Task Run(
    [ServiceBusTrigger("你的队列名称", Connection = "ServiceBusConnection")] string message,
    MessageReceiver messageReceiver,
    string lockToken,
    ILogger log)
{
    try
    {
        // 启动后台续期任务，队列锁时长设为5分钟的情况下每4分钟续一次
        var renewCts = new CancellationTokenSource();
        var renewTask = Task.Run(async () =>
        {
            while (!renewCts.IsCancellationRequested)
            {
                await Task.Delay(TimeSpan.FromMinutes(4), renewCts.Token);
                await messageReceiver.RenewLockAsync(lockToken);
            }
        }, renewCts.Token);

        // 你的业务处理逻辑
        await ProcessBusinessLogic(message);

        // 处理完成后停止续期、提交消息
        renewCts.Cancel();
        await renewTask;
        await messageReceiver.CompleteAsync(lockToken);
    }
    catch (Exception ex)
    {
        log.LogError(ex, "消息处理失败");
        await messageReceiver.AbandonAsync(lockToken);
    }
}

4. 排查组件版本兼容问题 #

• 确认你使用的Microsoft.Azure.WebJobs.Extensions.ServiceBus包版本在5.0以上，旧版本的自动锁续期逻辑存在已知缺陷，升级到最新稳定版即可解决大部分自动续期失效问题。
• 如果你使用的是Azure Functions隔离进程模型，注意该模型的Service Bus扩展配置不会自动读取host.json的参数，需要在Program.cs中显式配置锁续期相关属性。

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