Azure Service Bus中TransactionScope.Complete无响应但事务已提交的问题排查

嘿，我看了你遇到的这个棘手问题——明明事务已经生效（消息都从错误队列成功移到目标队列了），但TransactionScope.Complete()就是卡着不返回，改了循环内创建事务的版本也没解决。咱们一步步拆解下可能的原因和解决办法：

先说说你代码里的潜在坑点 #

1. 客户端生命周期管理不当

不管是第一个版本里全局持有的_source/_destination，还是第二个版本里循环创建的客户端，你都没正确用await using来管理ServiceBusReceiver和ServiceBusSender的生命周期。Azure Service Bus的客户端对象在参与跨实体事务时，必须和事务范围的生命周期严格绑定，否则会导致事务资源无法正常释放，进而卡住Complete()。

2. 事务与消息锁的超时不匹配

你用ReceiveMessagesAsync(1000)时没设置接收超时，而且默认的消息锁超时可能比TransactionScope的超时短。当消息锁过期后，事务内部的状态会变得不一致，引发等待资源释放的死锁，这就会导致Complete()一直挂着。

3. 批量接收的负载过大

一次性接收1000条消息会让单个事务的处理时间过长，不仅容易超出事务超时，还会增加资源占用的复杂度，进一步加剧事务卡住的概率。

具体的修复方案 #

1. 正确管理客户端生命周期

每次操作时创建ServiceBusReceiver和ServiceBusSender，并用await using确保它们在事务完成后自动释放资源，不要在构造函数里提前持有这些对象：

await using var sourceReceiver = _client.CreateReceiver($"{queueName}_error");
await using var destinationSender = _client.CreateSender(queueName);

2. 显式设置事务与锁的超时

调整TransactionScope的超时时间，同时延长消息锁的自动续期时长，确保两者匹配：

// 配置事务超时
var transactionOptions = new TransactionOptions
{
    Timeout = TimeSpan.FromMinutes(5),
    IsolationLevel = IsolationLevel.Serializable
};
// 配置Receiver的锁续期
var receiverOptions = new ServiceBusReceiverOptions
{
    MaxAutoLockRenewalDuration = TimeSpan.FromMinutes(5),
    ReceiveMode = ServiceBusReceiveMode.PeekLock
};

3. 分页接收消息，拆分事务负载

把一次性接收1000条改成分页接收（比如每次100条），减少单个事务的处理压力：

int batchSize = 100;
ServiceBusReceivedMessage[] lockedMessages;
do
{
    lockedMessages = await sourceReceiver.ReceiveMessagesAsync(batchSize, TimeSpan.FromSeconds(10));
    if (lockedMessages.Length == 0) break;
    // 处理当前批次消息
} while (lockedMessages.Length > 0);

4. 把非事务操作移出事务范围

像AbandonMessageAsync这种释放锁的操作不属于事务范畴，把它移出TransactionScope，可以降低事务的复杂度：

using var ts = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled, transactionOptions);
foreach (var lockedMessage in lockedMessages)
{
    if (lookup.TryGetValue(lockedMessage.SequenceNumber, out var originalMessage))
    {
        // 事务内仅处理完成和发送消息
        await sourceReceiver.CompleteMessageAsync(lockedMessage);
        await destinationSender.SendMessageAsync(sendMessage);
    }
}
ts.Complete();
// 事务外处理不需要重发的消息
foreach (var lockedMessage in lockedMessages.Where(m => !lookup.ContainsKey(m.SequenceNumber)))
{
    await sourceReceiver.AbandonMessageAsync(lockedMessage);
}

修正后的完整代码示例 #

public async Task ResendMessages(IEnumerable<ResendableMessage> messages)
{
    var lookup = messages.ToDictionary(m => m.Seq);
    var receiverOptions = new ServiceBusReceiverOptions
    {
        MaxAutoLockRenewalDuration = TimeSpan.FromMinutes(5),
        ReceiveMode = ServiceBusReceiveMode.PeekLock
    };
    var transactionOptions = new TransactionOptions
    {
        Timeout = TimeSpan.FromMinutes(5),
        IsolationLevel = IsolationLevel.Serializable
    };

    await using var sourceReceiver = _client.CreateReceiver($"{_sourceQueueName}_error", receiverOptions);
    await using var destinationSender = _client.CreateSender(_sourceQueueName);

    int batchSize = 100;
    ServiceBusReceivedMessage[] lockedMessages;
    do
    {
        lockedMessages = await sourceReceiver.ReceiveMessagesAsync(batchSize, TimeSpan.FromSeconds(10));
        if (lockedMessages.Length == 0) break;

        using var ts = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled, transactionOptions);
        var messagesToAbandon = new List<ServiceBusReceivedMessage>();
        foreach (var lockedMessage in lockedMessages)
        {
            if (lookup.TryGetValue(lockedMessage.SequenceNumber, out var originalMessage))
            {
                var sendMessage = new ServiceBusMessage(originalMessage.Message);
                if (originalMessage.Content != null)
                    sendMessage.Body = new BinaryData(originalMessage.Content);

                await sourceReceiver.CompleteMessageAsync(lockedMessage);
                await destinationSender.SendMessageAsync(sendMessage);
            }
            else
            {
                messagesToAbandon.Add(lockedMessage);
            }
        }
        ts.Complete();

        // 事务外处理需要释放的消息
        foreach (var msg in messagesToAbandon)
        {
            await sourceReceiver.AbandonMessageAsync(msg);
        }
    } while (lockedMessages.Length > 0);
}

额外排查建议 #

• 确认你的Service Bus命名空间是标准层或高级层，基础层不支持跨实体事务，会引发异常行为；
• 开启Azure Service Bus的诊断日志，查看是否有事务超时、资源泄漏相关的警告或错误；
• 确保ServiceBusClient是全局单例（它是线程安全的，应复用而非频繁创建）。

备注：内容来源于stack exchange，提问作者Anders