Azure Service Bus会话队列锁过期后如何续期？解决SessionLockLostException

嘿，我刚好碰过一模一样的场景！你遇到的问题根源就是30秒的会话锁撑不住第一条消息的处理时长，导致锁过期后调用CompleteAsync时触发异常。其实Azure Service Bus提供了专门的锁续期方法，而且实现起来并不复杂，我给你详细说下怎么弄：

核心逻辑拆解 #

首先得区分两个锁：会话锁和消息锁——会话锁是用来独占整个会话的，消息锁是针对单条消息的。你的场景里，处理消息耗时超过30秒，两个锁都可能过期，所以得同时续期：

• 会话锁续期：用SessionReceiver的RenewSessionLockAsync()方法延长会话的独占时间
• 消息锁续期：用ProcessSessionMessageEventArgs的RenewMessageLockAsync()方法延长当前消息的锁定时间
• 最佳实践是在后台开个定时任务，在锁过期前（比如提前10秒）自动续期，直到消息处理完为止

完整代码示例 #

下面是一个可直接复用的示例，包含会话接收、耗时消息处理、自动续期锁的逻辑：

using Azure.Messaging.ServiceBus;
using System.Threading;
using System.Threading.Tasks;

public async Task ProcessSessionQueueMessages(string connectionString, string queueName)
{
    // 初始化Service Bus客户端
    await using var client = new ServiceBusClient(connectionString);
    
    // 创建会话处理器，配置基础参数
    var processor = client.CreateSessionProcessor(queueName, new ServiceBusSessionProcessorOptions
    {
        SessionIdleTimeout = TimeSpan.FromMinutes(5), // 会话空闲超时，按需调整
        MaxAutoLockRenewalDuration = TimeSpan.FromMinutes(10) // SDK自动续期的最大时长，可选配置
    });

    // 绑定消息处理和错误处理事件
    processor.ProcessMessageAsync += HandleSessionMessage;
    processor.ProcessErrorAsync += HandleProcessingError;

    // 启动处理器
    await processor.StartProcessingAsync();

    // 这里可以替换成实际的停止逻辑，比如监听控制台退出信号
    await Task.Delay(Timeout.Infinite);
    await processor.StopProcessingAsync();
}

private async Task HandleSessionMessage(ProcessSessionMessageEventArgs args)
{
    var targetMessage = args.Message;
    var session = args.Session;
    var renewalCts = new CancellationTokenSource();

    // 启动后台续期任务：同时续期会话锁和消息锁
    var lockRenewalTask = Task.Run(async () =>
    {
        while (!renewalCts.Token.IsCancellationRequested)
        {
            try
            {
                // 续期会话锁
                await session.RenewSessionLockAsync(renewalCts.Token);
                // 续期当前消息的锁
                await args.RenewMessageLockAsync(renewalCts.Token);
                
                // 每20秒续一次（比30秒锁时长提前10秒，避免网络延迟导致续期不及时）
                await Task.Delay(TimeSpan.FromSeconds(20), renewalCts.Token);
            }
            catch (OperationCanceledException)
            {
                // 任务被取消，正常退出循环
                break;
            }
            catch (Exception ex)
            {
                // 记录续期失败的日志，根据业务决定是否终止处理
                Console.WriteLine($"锁续期失败: {ex.Message}");
                break;
            }
        }
    }, renewalCts.Token);

    try
    {
        // 替换成你的实际耗时处理逻辑（比如调用外部API、批量数据库操作等）
        await SimulateLongRunningProcessing(targetMessage);

        // 处理完成，删除消息
        await session.CompleteAsync(targetMessage.SystemProperties.LockToken);
        Console.WriteLine($"消息 {targetMessage.MessageId} 处理完成");
    }
    catch (SessionLockLostException ex)
    {
        // 会话锁丢失的处理逻辑：比如将消息放回队列，等待重新处理
        Console.WriteLine($"会话锁已过期: {ex.Message}");
        await session.AbandonAsync(targetMessage.SystemProperties.LockToken);
    }
    finally
    {
        // 不管处理成功还是失败，都要取消续期任务并释放资源
        renewalCts.Cancel();
        await lockRenewalTask;
        renewalCts.Dispose();
    }
}

// 模拟耗时40秒的消息处理（超过30秒的锁时长）
private async Task SimulateLongRunningProcessing(ServiceBusReceivedMessage message)
{
    await Task.Delay(TimeSpan.FromSeconds(40));
}

private Task HandleProcessingError(ProcessErrorEventArgs args)
{
    // 全局错误处理：记录错误日志，排查问题
    Console.WriteLine($"处理过程中出现错误: {args.Exception.Message}");
    return Task.CompletedTask;
}

几个关键注意点 #

• 自动续期vs手动续期：上面的示例是手动实现续期逻辑，更灵活；如果你不想自己写定时任务，可以直接配置MaxAutoLockRenewalDuration，SDK会自动帮你续期锁，直到达到这个最大时长。
• 续期时机：建议在锁过期前的1/2时间点调用续期方法，比如30秒锁时长，每20秒续一次，留足网络延迟的缓冲时间。
• 异常兜底：如果续期失败或者锁已经丢失，一定要调用AbandonAsync把消息放回队列，避免消息丢失；也可以根据业务需求将消息移到死信队列。
• 会话空闲超时：设置SessionIdleTimeout可以避免会话长时间占用资源，当会话在指定时间内没有新消息时，会自动释放会话锁。

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