如何在多个ASP.NET MVC Action方法间延续数据库事务？

首先明确：跨HTTP请求保持长期数据库事务是反Web应用最佳实践的，因为HTTP的无状态特性会导致事务长时间占用数据库连接、锁资源，引发性能瓶颈、死锁甚至连接池耗尽的问题。优先推荐通过重构业务逻辑规避这种场景，以下是具体可行的方案：

方案一：用临时数据+状态标记重构业务（推荐） #

核心思路是把需要用户确认的操作拆分为"预提交"和"正式提交"两个阶段，避免事务跨请求：

1. 预提交阶段（第一个Action）：

   • 执行必要的预操作，将数据存入临时表，或在主表中添加"待确认"状态标记
   • 生成校验码和临时数据标识，返回给客户端

2. 正式提交阶段（第二个Action）：

   • 接收客户端传来的校验码和临时标识，验证有效性
   • 在单个请求内开启事务，将临时数据迁移到主表（或更新主表状态为"已完成"）
   • 提交事务，清理临时数据

代码示例 #

预提交Action

[AjaxOnly]
public JsonResult PrepareTransaction()
{
    try
    {
        var checkNumber = GetLastCheckNumber(smContext);
        // 将预操作数据存入临时表
        var tempRecord = new TempTransactionRecord
        {
            CheckNumber = checkNumber,
            CreatedTime = DateTime.Now,
            Status = "Pending"
        };
        smContext.TempTransactionRecords.Add(tempRecord);
        smContext.SaveChanges();
        
        return Json(new { CheckNumber = checkNumber, TempId = tempRecord.Id });
    }
    catch (Exception ex)
    {
        return Json(new { Error = ex.Message });
    }
}

确认提交Action

[AjaxOnly]
public JsonResult ConfirmTransaction(int tempId, string checkNumber)
{
    using (var transaction = smContext.Database.BeginTransaction())
    {
        try
        {
            // 校验临时记录的合法性
            var tempRecord = smContext.TempTransactionRecords
                .FirstOrDefault(t => t.Id == tempId && t.CheckNumber == checkNumber);
            if (tempRecord == null)
            {
                return Json(new { Error = "无效的校验信息" });
            }
            
            // 执行正式业务操作：将临时数据同步到主表
            var mainRecord = new MainTransactionRecord
            {
                CheckNumber = tempRecord.CheckNumber,
                // 填充其他业务字段
            };
            smContext.MainTransactionRecords.Add(mainRecord);
            // 清理临时数据
            smContext.TempTransactionRecords.Remove(tempRecord);
            
            smContext.SaveChanges();
            transaction.Commit();
            
            return Json(new { Success = true });
        }
        catch (Exception ex)
        {
            transaction.Rollback();
            return Json(new { Error = ex.Message });
        }
    }
}

补充优化 #

• 可以添加定时任务，自动清理超过指定时长（如10分钟）的"待确认"临时记录，避免数据冗余
• 临时表可以添加索引，提升校验时的查询效率

方案二：跨请求绑定数据库事务（仅迫不得已时使用） #

如果业务逻辑绝对要求单事务跨请求，可通过绑定数据库连接的方式实现，但需承担资源占用和线程安全风险：

实现思路 #

1. 第一个请求：开启事务，保留数据库连接（不能用using释放），生成唯一事务令牌，将令牌、校验码和连接/事务实例存入线程安全的字典
2. 第二个请求：通过令牌从字典中取出连接和事务，绑定到新的DbContext，继续执行操作
3. 操作完成后，提交/回滚事务，关闭连接并从字典中移除记录

代码示例 #

全局事务存储（需线程安全）

private static readonly Dictionary<string, (DbConnection Connection, DbTransaction Transaction)> _activeTransactions = new();
private static readonly object _lockObj = new();

启动事务Action

[AjaxOnly]
public JsonResult StartTransaction()
{
    DbConnection connection = null;
    DbTransaction transaction = null;
    try
    {
        connection = smContext.Database.GetDbConnection();
        if (connection.State != ConnectionState.Open)
        {
            connection.Open();
        }
        transaction = connection.BeginTransaction();
        
        var checkNumber = GetLastCheckNumber(smContext);
        var transactionToken = Guid.NewGuid().ToString();
        
        // 线程安全地存储事务信息
        lock (_lockObj)
        {
            _activeTransactions[transactionToken] = (connection, transaction);
        }
        
        return Json(new { CheckNumber = checkNumber, TransactionToken = transactionToken });
    }
    catch (Exception ex)
    {
        transaction?.Rollback();
        connection?.Close();
        return Json(new { Error = ex.Message });
    }
}

延续事务Action

[AjaxOnly]
public JsonResult ContinueTransaction(string transactionToken, string checkNumber)
{
    if (!_activeTransactions.TryGetValue(transactionToken, out var transactionData))
    {
        return Json(new { Error = "事务已过期或无效" });
    }
    
    try
    {
        // 将现有事务绑定到当前DbContext
        smContext.Database.UseTransaction(transactionData.Transaction);
        
        // 执行后续业务操作
        // ...
        
        transactionData.Transaction.Commit();
        // 清理资源
        lock (_lockObj)
        {
            _activeTransactions.Remove(transactionToken);
        }
        transactionData.Connection.Close();
        
        return Json(new { Success = true });
    }
    catch (Exception ex)
    {
        transactionData.Transaction.Rollback();
        lock (_lockObj)
        {
            _activeTransactions.Remove(transactionToken);
        }
        transactionData.Connection.Close();
        return Json(new { Error = ex.Message });
    }
}

关键注意事项 #

• 必须添加超时清理机制（如后台定时任务），自动释放超过指定时长的事务和连接，避免资源泄漏
• 严格控制事务的持续时间，尽量缩短用户确认的等待窗口
• 监控数据库连接池状态，防止连接耗尽

总结 #

• 优先采用方案一，这是最符合Web无状态特性、性能最优且风险最低的方案
• 仅在业务逻辑无法重构时，才考虑方案二，但必须做好资源管控和异常处理

内容的提问来源于stack exchange，提问作者D W