MassTransit+Azure Service Bus接入SQL Server事务范围报错解决方案咨询

在MassTransit消息处理器中，我用TransactionScope包裹一系列SQL Server插入操作来保证原子性，切换到Azure Service Bus后出现问题：ASB会自动关联该事务范围，触发两个错误：

1. 要求隔离级别为Serializable
2. 本地事务不支持多资源管理器（需启用DTC）

目前只能通过TransactionScopeOption.Suppress跳过事务，但这无法保证SQL操作的原子性，需要让ASB不参与SQL专属的事务范围。

方案1：禁用Azure Service Bus接收端点的事务支持 #

在配置MassTransit接收端点时，直接禁用ASB的事务关联，这样后续创建的TransactionScope只会作用于SQL操作：

cfg.ReceiveEndpoint("your-queue-name", e =>
{
    // 禁用ASB端点事务，避免自动关联到SQL的TransactionScope
    e.TransactionMode = TransactionMode.None;
    e.ConfigureConsumer<YourMessageConsumer>(serviceProvider);
});

注意：此设置会让ASB的消息确认（完成/放弃）操作脱离事务，若SQL操作失败，MassTransit会自动重试消息，需确保业务逻辑支持幂等性。

方案2：使用SQL Server本地事务替代TransactionScope #

放弃TransactionScope，直接使用SQL连接的本地事务，完全避免跨资源事务的问题：

public async Task Consume(ConsumeContext<YourMessage> context)
{
    using var sqlConnection = new SqlConnection("your-connection-string");
    await sqlConnection.OpenAsync();
    
    // 开启SQL本地事务
    using var sqlTransaction = await sqlConnection.BeginTransactionAsync();
    
    try
    {
        // 执行批量插入操作
        await using var insertCmd1 = new SqlCommand("INSERT INTO Table1 (...) VALUES (...)", sqlConnection, sqlTransaction);
        await insertCmd1.ExecuteNonQueryAsync();
        
        await using var insertCmd2 = new SqlCommand("INSERT INTO Table2 (...) VALUES (...)", sqlConnection, sqlTransaction);
        await insertCmd2.ExecuteNonQueryAsync();
        
        // 提交事务
        await sqlTransaction.CommitAsync();
    }
    catch
    {
        // 回滚事务
        await sqlTransaction.RollbackAsync();
        throw; // 抛出异常让MassTransit重试消息
    }
}

这种方式更轻量，无需依赖DTC，也不会触发ASB的事务关联，是推荐的方案（只要所有SQL操作都在同一个连接内）。

方案3：控制TransactionScope的传播特性 #

如果必须保留TransactionScope，可以指定RequiresNew创建独立事务，同时显式设置隔离级别为Serializable（匹配ASB的要求），但这种方式可能需要启用DTC，不推荐除非必须：

public async Task Consume(ConsumeContext<YourMessage> context)
{
    // 创建独立的事务范围，隔离级别设为Serializable
    using var scope = new TransactionScope(
        TransactionScopeOption.RequiresNew,
        new TransactionOptions { IsolationLevel = IsolationLevel.Serializable },
        TransactionScopeAsyncFlowOption.Enabled);
    
    try
    {
        // 执行SQL插入操作
        await ExecuteSqlInsertsAsync();
        
        scope.Complete();
    }
    catch
    {
        // 事务自动回滚
        throw;
    }
}

注意：此方案需要启用分布式事务协调器（DTC），会增加系统复杂度，仅在业务必须跨多资源事务时使用。

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