如何动态更新很长的处理消息的锁定 - Azure.Messaging.ServiceBus；

Question

是否可以为 Azure.Messaging.ServiceBus 库中正在处理的消息续订锁定，如果可以，如何续订

Answer 1

根据您的用途，您需要延长锁。使用您提到的服务总线 SDK 提供的处理器，可以通过以下方式完成：

await using var client = new ServiceBusClient(connectionString);

// create the options to use for configuring the processor
var options = new ServiceBusProcessorOptions
{
    MaxAutoLockRenewalDuration = TimeSpan.FromMinutes(45); // Allow message processing for up-to 45 minutes
    AutoCompleteMessages = false,

    // Disable multi-threading for easy debugging
    MaxConcurrentCalls = 1
};

await using ServiceBusProcessor processor = client.CreateProcessor(queueName, options);

processor.ProcessMessageAsync += MessageHandler;
processor.ProcessErrorAsync += ErrorHandler;

async Task MessageHandler(ProcessMessageEventArgs args)
{
    string body = args.Message.Body.ToString();
    Console.WriteLine(body);

    await args.CompleteMessageAsync(args.Message);
}

Task ErrorHandler(ProcessErrorEventArgs args)
{
    Console.WriteLine(args.ErrorSource);

    Console.WriteLine(args.FullyQualifiedNamespace);
    Console.WriteLine(args.EntityPath);

    Console.WriteLine(args.Exception.ToString());

    return Task.CompletedTask;
}

processor.StartProcessingAsync();
Console.ReadKey();

它们的关键是 MaxAutoLockRenewalDuration 属性需要设置为最大可能时间。

如果您使用 ServiceBusReceiver，它提供RenewMessageLockAsync方法来达到目的。

Answer 2

消息锁定续订仅应用于由端点主动处理的消息，不适用于已预取。

消息锁定续订时间应大于LockDuration时间。

当 LockDuration 期限即将到期时，Azure 服务总线传输将向代理发送锁定续订请求，从而使消息保持锁定状态并且对其他使用者不可见。

虽然消息处理的总时间小于 Azure 服务总线传输设置的自动续订时间，但锁定续订将自动发生。

锁更新时间默认设置为5分钟。如果更新自动锁定，已处理邮件的 DeliveryCount 不会增加。

为当前正在处理的消息更新消息锁。当传输完成预取消息时，如果未在 LockDuration 时间内处理它们，它们将失去锁定。这将由日志中的 LockLostException 发出信号。通过将 PrefetchCount 设置为零，可以停用预取以避免锁更新异常。

配置消息以锁定续订

var ServiceBusTransport= endpointConfiguration.UseTransport<AzureServiceBusTransport>(); 
var ServiceBusReceivers = ServiceBusTransport.MessageReceivers(); 
ServiceBusReceivers .AutoRenewTimeout(maximumProcessingTime);

请参阅 此处了解更多信息。