门面层双数据库事务回滚实现方案优化咨询

原实现的核心问题 #

你当前的门面层直接处理事务的开启、提交与回滚，违背了单一职责原则——门面层的定位应该是对外提供简洁的调用入口，而非承担业务逻辑或事务协调的职责。此外，手动管理事务对象的生命周期还存在资源泄漏风险，代码冗余度也较高。

更优实现思路 #

将事务协调逻辑抽离到专门的组件，用领域服务封装跨库业务操作，让各层各司其职：

• 用分布式事务管理器统一处理多数据库的事务生命周期（开启、提交、回滚、资源释放）
• 用领域服务封装跨库业务逻辑，协调数据服务与事务管理器的交互
• 门面层仅作为入口，调用领域服务的方法即可

具体代码实现 #

1. 分布式事务管理器（统一管理多库事务）

public interface IDistributedTransactionManager
{
    Task<IEnumerable<IDbContextTransaction>> StartTransactionsAsync(params IDbContext[] contexts);
    Task CommitAsync(IEnumerable<IDbContextTransaction> transactions);
    Task RollbackAsync(IEnumerable<IDbContextTransaction> transactions);
}

public class DistributedTransactionManager : IDistributedTransactionManager
{
    public async Task<IEnumerable<IDbContextTransaction>> StartTransactionsAsync(params IDbContext[] contexts)
    {
        var transactions = new List<IDbContextTransaction>();
        foreach (var context in contexts)
        {
            transactions.Add(await context.Database.BeginTransactionAsync());
        }
        return transactions;
    }

    public async Task CommitAsync(IEnumerable<IDbContextTransaction> transactions)
    {
        foreach (var transaction in transactions)
        {
            await transaction.CommitAsync();
        }
    }

    public async Task RollbackAsync(IEnumerable<IDbContextTransaction> transactions)
    {
        foreach (var transaction in transactions)
        {
            await transaction.RollbackAsync();
        }
    }
}

2. 领域服务（封装跨库业务逻辑）

public interface IUserDomainService
{
    Task<bool> DeactivateUserAsync(UserDTO userDTO);
}

public class UserDomainService : IUserDomainService
{
    private readonly IDbOneService _dbOneService;
    private readonly IDbTwoService _dbTwoService;
    private readonly IDistributedTransactionManager _transactionManager;
    private readonly IDbContext _dbOneContext;
    private readonly IDbContext _dbTwoContext;

    public UserDomainService(IDbOneService dbOneService, IDbTwoService dbTwoService,
        IDistributedTransactionManager transactionManager, IDbContext dbOneContext, IDbContext dbTwoContext)
    {
        _dbOneService = dbOneService;
        _dbTwoService = dbTwoService;
        _transactionManager = transactionManager;
        _dbOneContext = dbOneContext;
        _dbTwoContext = dbTwoContext;
    }

    public async Task<bool> DeactivateUserAsync(UserDTO userDTO)
    {
        IEnumerable<IDbContextTransaction> transactions = null;
        try
        {
            // 开启双库事务
            transactions = await _transactionManager.StartTransactionsAsync(_dbOneContext, _dbTwoContext);

            // 执行业务操作（操作在事务上下文内）
            var mappedUser = MapToDbOneUser(userDTO); // 补充DTO到实体的转换逻辑
            await _dbOneService.DeactivateUser(mappedUser);
            await _dbTwoService.RemoveUserFromLists(userDTO.userId);

            // 提交事务
            await _transactionManager.CommitAsync(transactions);
            return true;
        }
        catch (DataServiceException)
        {
            // 回滚所有事务
            if (transactions != null)
            {
                await _transactionManager.RollbackAsync(transactions);
            }
            return false;
        }
        finally
        {
            // 确保事务资源被释放
            if (transactions != null)
            {
                foreach (var transaction in transactions)
                {
                    await transaction.DisposeAsync();
                }
            }
        }
    }

    // 抽离DTO转换逻辑到领域服务
    private DbOneUser MapToDbOneUser(UserDTO userDTO)
    {
        return new DbOneUser
        {
            UserId = userDTO.userId,
            // 其他属性映射
        };
    }
}

3. 简化后的门面层

public async Task<bool> DeactivateUser(UserDTO userDTO)
{
    return await _userDomainService.DeactivateUserAsync(userDTO);
}

额外注意事项 #

• 如果两个数据库属于完全独立的系统，需考虑分布式事务协议（如两阶段提交2PC），EF Core可通过System.Transactions集成支持该协议的数据库（如SQL Server），但要注意性能开销与一致性风险。
• 数据服务（IDbOneService、IDbTwoService）应仅负责单数据库的原子操作，不涉及跨库逻辑，保持职责单一。
• 通过依赖注入框架（如Autofac、Microsoft DI）管理所有服务的生命周期，确保实例创建与销毁符合业务需求。

内容的提问来源于stack exchange，提问作者Sean McKinney