如何在消息锁超时后阻止消息重新投递至Service Bus队列

要实现锁超时后直接移除消息、不重试且不用死信队列，核心是在锁超时异常触发时，主动以ReceiveAndDelete模式接收并删除该消息，具体步骤如下：

• 捕获锁超时异常：在ProcessErrorAsync中识别LockLostException——这是Service Bus在消息锁超时时抛出的专属异常类型。
• 主动删除超时消息：当捕获到锁超时异常时，利用消息的SequenceNumber，通过ReceiveAndDelete模式创建新接收器，直接接收并删除目标消息，阻止其重新入队。

代码示例 #

// 初始化消息处理器
var processor = client.CreateProcessor("your-queue-name", new ServiceBusProcessorOptions());

processor.ProcessMessageAsync += async args =>
{
    // 执行你的业务处理逻辑
    await args.CompleteMessageAsync(args.Message);
};

processor.ProcessErrorAsync += async args =>
{
    // 判断是否为锁超时异常
    if (args.Exception is LockLostException)
    {
        // 创建ReceiveAndDelete模式的消息接收器
        using var receiver = new ServiceBusReceiver(
            "your-connection-string",
            "your-queue-name",
            new ServiceBusReceiverOptions { ReceiveMode = ReceiveMode.ReceiveAndDelete });

        try
        {
            // 根据SequenceNumber定位并删除超时消息
            var targetMessage = await receiver.ReceiveMessageAsync(
                maxWaitTime: TimeSpan.FromSeconds(5),
                sequenceNumber: args.Message.SequenceNumber);

            if (targetMessage != null)
            {
                Console.WriteLine($"锁超时消息已移除，SequenceNumber: {args.Message.SequenceNumber}");
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"删除锁超时消息失败: {ex.Message}");
        }
    }
    // 处理其他类型错误
    else
    {
        Console.WriteLine($"处理错误: {args.Exception.Message}");
    }
};

await processor.StartProcessingAsync();

注意事项 #

• 保证接收器的连接字符串、队列名称与处理器完全一致
• 设置合理的maxWaitTime，避免无意义的资源等待
• 该方案依赖消息SequenceNumber定位，需确保锁超时后消息未被其他消费者抢先接收

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