如何解除死信队列中44万+消息的长时间锁定？

一、消息锁定原因排查 #

• 先确认是否有运行中的消费者客户端持有消息锁：即便LockedUntil显示过期，也可能因客户端未正确释放锁、Service Bus节点同步延迟，导致锁状态异常滞留
• 检查是否存在异常重启的消费者进程：进程崩溃时若未主动调用Complete或Abandon，Service Bus本应在锁超时后自动释放，但极端场景下可能出现锁状态异常
• 已排除Deferral情况：消息State为Active，可排除Deferral API永久固定锁的可能

二、解锁消息的可行方法 #

1. Service Bus Explorer操作 #

• 选中目标死信队列，批量选择锁定的消息，右键执行Abandon（放弃）操作，触发锁释放，消息会回到可用状态
• 单条消息处理时，找到对应消息后直接执行Abandon，工具会自动处理LockToken相关逻辑

2. .NET SDK编程解锁 #

• 批量处理可使用ServiceBusReceiver接收锁定消息，调用AbandonMessageAsync释放锁
• 示例代码：

await using var client = new ServiceBusClient(connectionString);
var receiver = client.CreateReceiver(queueName, new ServiceBusReceiverOptions { SubQueue = SubQueue.DeadLetter });

var messages = await receiver.ReceiveMessagesAsync(maxMessages: 100);
foreach (var message in messages)
{
    await receiver.AbandonMessageAsync(message);
}

• 注意：即便LockedUntil显示过期，只要消息处于锁定状态，ReceiveMessagesAsync仍能获取到消息并执行Abandon操作

3. 极端场景下的强制处理 #

• 若上述方法无效，可临时禁用再启用死信队列的消费者，触发Service Bus重新计算锁状态
• 谨慎操作：必要时可重启Service Bus命名空间节点，但会影响同命名空间下的其他队列

三、后续预防措施 #

• 确保消费者进程异常退出时，通过CancellationToken正确释放Service Bus客户端资源，避免锁滞留
• 监控消息锁状态，设置告警阈值，及时发现异常锁定情况
• 消费者处理逻辑中，避免长时间持有消息锁：若处理耗时较长，可调用RenewMessageLockAsync延续锁，或拆分处理逻辑

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