.NET Core EF多服务共用事务报错：无活动事务无法提交

问题原因 #

1. 事务上下文不共享：ServiceA中开启的事务仅绑定到当前DbContext实例，而ServiceB的仓储使用独立的DbContext实例，该实例未关联任何活动事务，执行SaveAsync时触发错误。
2. 异步方法误用：代码中大量使用.Wait()阻塞异步方法，存在死锁风险，违背异步编程原则。

解决方案 #

方案1：共享DbContext实例（推荐，同数据库场景）

如果两个仓储属于同一数据库（使用同一个DbContext类型），利用.NET Core默认的Scoped生命周期，确保同请求内的服务共享同一个DbContext实例，自然继承事务上下文。

修正后的代码示例：

// ServiceA
public class ServiceA
{
    private readonly Repos_A _repoA;
    private readonly ServiceB _serviceB;
    private readonly AppDbContext _dbContext;

    public ServiceA(Repos_A repoA, ServiceB serviceB, AppDbContext dbContext)
    {
        _repoA = repoA;
        _serviceB = serviceB;
        _dbContext = dbContext;
    }

    public async Task Method_A()
    {
        using var transaction = await _dbContext.Database.BeginTransactionAsync();
        try
        {
            await _repoA.AddAsync(dbModel);
            await _repoA.SaveChangesAsync();
            
            await _serviceB.Method_B();
            
            await transaction.CommitAsync();
        }
        catch
        {
            await transaction.RollbackAsync();
            throw;
        }
    }
}

// ServiceB
public class ServiceB
{
    private readonly Repos_B _repoB;

    public ServiceB(Repos_B repoB)
    {
        _repoB = repoB;
    }

    public async Task Method_B()
    {
        await _repoB.AddAsync(dbModel);
        await _repoB.SaveChangesAsync(); // 自动加入ServiceA的事务
    }
}

关键说明：

• 确保仓储类注入的DbContext为Scoped生命周期（默认配置即可），同请求内所有服务共享实例。
• 替换.Wait()为await，保持异步流程一致性。

方案2：分布式事务（跨DbContext/跨数据库场景）

如果操作涉及不同数据库，使用分布式事务协调多个DbContext的操作，依赖数据库的分布式事务支持（如MS SQL Server的DTC）。

1. 注册分布式事务服务：

// Program.cs
builder.Services.AddDbContext<AppDbContext1>(options =>
    options.UseSqlServer("ConnectionString1", o => o.EnableRetryOnFailure()));
builder.Services.AddDbContext<AppDbContext2>(options =>
    options.UseSqlServer("ConnectionString2", o => o.EnableRetryOnFailure()));
builder.Services.AddDistributedTransactionHandler();

2. 修改ServiceA代码：

public async Task Method_A()
{
    using var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled);
    try
    {
        await _repoA.AddAsync(dbModel);
        await _repoA.SaveChangesAsync();
        
        await _serviceB.Method_B();
        
        scope.Complete();
    }
    catch
    {
        // 异常时自动回滚事务
        throw;
    }
}

关键说明：

• TransactionScope会自动将所有DbContext操作纳入分布式事务，无需手动关联。
• 必须启用TransactionScopeAsyncFlowOption.Enabled支持异步流程。

方案3：显式传递事务（手动关联）

若不想依赖DI生命周期，可手动将ServiceA的事务传递给ServiceB，让其DbContext加入事务。

// ServiceA的Method_A
public async Task Method_A()
{
    using var transaction = await _dbContext.Database.BeginTransactionAsync();
    try
    {
        await _repoA.AddAsync(dbModel);
        await _repoA.SaveChangesAsync();
        
        // 传递事务给ServiceB
        await _serviceB.Method_B(transaction);
        
        await transaction.CommitAsync();
    }
    catch
    {
        await transaction.RollbackAsync();
        throw;
    }
}

// ServiceB的Method_B修改
public async Task Method_B(IDbContextTransaction transaction)
{
    // 将当前DbContext绑定到传入的事务
    await _repoB.DbContext.Database.UseTransactionAsync(transaction.GetDbTransaction());
    
    await _repoB.AddAsync(dbModel);
    await _repoB.SaveChangesAsync();
}

关键说明：

• 需要仓储类暴露DbContext实例，或在ServiceB中直接注入DbContext。
• 灵活性高，但代码耦合度略高。

注意事项 #

• 始终使用await处理异步方法，避免.Wait()/.Result()导致的死锁。
• 缩小事务范围，减少数据库锁持有时间，降低竞争风险。
• 确保所有操作要么全部提交，要么全部回滚，保证数据一致性。

内容的提问来源于stack exchange，提问作者SENTHIL VEL