如何借助Entity Framework与.NET实现列值的并发安全递减？

你遇到的是典型的并发更新丢失问题，根源在于先读后写的操作不具备原子性，多个请求同时读取旧值后，都会基于该旧值执行更新，最终结果不符合预期。下面逐个分析你列出的方案，并给出最优解和示例代码：

各方案分析 #

1. 应用层Lock object #

这种方式仅在单进程单线程环境下有效，而ASP.NET MVC应用通常运行在多进程（IIS多工作进程）或多线程环境中，静态锁对象只能锁住当前进程内的请求，其他进程的请求依然会并发读取旧值，完全无法解决跨进程的并发问题，不适用Web场景。

2. TransactionScope（事务范围） #

仅用TransactionScope包裹原有的先读后写代码，默认的Read Committed隔离级别依然会出现不可重复读问题，两个请求仍能同时读到旧值。即使提升隔离级别到Serializable，会强制锁表导致性能大幅下降，且本质还是先读后写，不如直接用数据库原子操作高效。

3. 调用存储过程 #

这是最优方案之一。通过存储过程执行数据库层面的原子更新语句，数据库引擎会保证该操作的原子性，不会出现并发冲突，同时减少了往返数据库的次数，性能更高。

4. Entity Framework事务 #

和TransactionScope逻辑一致，仅靠EF事务无法解决先读后写的并发问题，除非结合乐观锁（通过RowVersion列实现）。但这是冲突后重试的机制，适合并发量不高的场景，高并发下重试开销较大。

最优方案示例代码 #

方案A：直接用EF执行原子更新SQL（无需存储过程） #

这种方式最简单，跳过先读步骤直接执行更新：

int employeeId = 1001;
// 数据库层面保证操作原子性
int affectedRows = context.Database.ExecuteSqlCommand(
    "UPDATE Employees SET Counter = Counter - 1 WHERE Id = @Id",
    new System.Data.SqlClient.SqlParameter("@Id", employeeId)
);

// 通过返回行数判断是否更新成功（1为成功，0为未找到对应员工）
if (affectedRows == 0)
{
    // 处理员工不存在的逻辑
}

方案B：调用存储过程 #

1. 先在数据库中创建存储过程：

CREATE PROCEDURE DecrementEmployeeCounter
    @EmployeeId INT
AS
BEGIN
    SET NOCOUNT ON;
    -- 原子更新计数器
    UPDATE Employees 
    SET Counter = Counter - 1 
    WHERE Id = @EmployeeId;
END

2. 在EF中调用该存储过程：

int employeeId = 1001;
context.Database.ExecuteSqlCommand(
    "EXEC DecrementEmployeeCounter @EmployeeId",
    new System.Data.SqlClient.SqlParameter("@EmployeeId", employeeId)
);

备选方案：乐观锁（适合低并发场景） #

如果必须保留先读后写的逻辑，可以通过乐观锁解决：

1. 给Employees表添加RowVersion列（数据库类型为rowversion），实体类对应属性：

public class Employee
{
    public int Id { get; set; }
    public int Counter { get; set; }
    [System.ComponentModel.DataAnnotations.Schema.Timestamp]
    public byte[] RowVersion { get; set; }
}

2. 更新代码（冲突后自动重试）：

bool updateSuccess = false;
while (!updateSuccess)
{
    try
    {
        using (var dbContext = new YourDbContext())
        {
            var employee = dbContext.Employees.Find(1001);
            if (employee == null) break;
            
            employee.Counter -= 1;
            dbContext.SaveChanges();
            updateSuccess = true;
        }
    }
    catch (System.Data.Entity.Infrastructure.DbUpdateConcurrencyException)
    {
        // 捕获并发冲突，重试更新
        continue;
    }
}

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