WebApi Core+EF中如何防止并发创建数据超出指定次数限制

这问题我之前在项目里踩过一模一样的坑，并发场景下单纯查计数再插入确实会出现重复创建的情况，结合你的技术栈，给你几个适配异步要求的靠谱方案：

方案一：EF 执行原子性 SQL 语句 #

把「校验次数+插入数据」的逻辑打包成一条原子性的SQL语句，让数据库层面直接执行，从根源避免竞态条件。示例代码如下：

var maxCount = 5; // 允许的最大创建次数
var conditionValue = "your_condition_value"; // 你的筛选条件
var insertSql = @"
IF (SELECT COUNT(*) FROM YourTableName WHERE YourConditionColumn = @Condition) < @MaxCount
BEGIN
    INSERT INTO YourTableName (Column1, Column2)
    VALUES (@Val1, @Val2)
END";

await context.Database.ExecuteSqlRawAsync(insertSql, 
    new SqlParameter("@Condition", conditionValue),
    new SqlParameter("@MaxCount", maxCount),
    new SqlParameter("@Val1", "value1"),
    new SqlParameter("@Val2", "value2"));

这种方式不需要额外的事务，数据库会把整个IF-INSERT当成一个原子操作执行，完全避免并发冲突。

方案二：带行级锁的异步事务 #

如果更倾向用EF的Linq语法而不是原生SQL，可以在查询计数时加上行级锁，确保同一时间只有一个事务能修改相关数据：

using var transaction = await context.Database.BeginTransactionAsync();
try
{
    // 用UPDLOCK和HOLDLOCK锁定查询到的行，防止其他事务并发修改
    var currentCount = await context.YourEntity
        .Where(e => e.YourCondition == conditionValue)
        .FromSqlRaw("SELECT * FROM YourEntity WHERE YourCondition = @Condition WITH (UPDLOCK, HOLDLOCK)", 
            new SqlParameter("@Condition", conditionValue))
        .CountAsync();

    if (currentCount < maxCount)
    {
        context.YourEntity.Add(new YourEntity 
        { 
            Column1 = "value1", 
            Column2 = "value2" 
        });
        await context.SaveChangesAsync();
    }

    await transaction.CommitAsync();
}
catch (Exception ex)
{
    await transaction.RollbackAsync();
    // 这里可以根据需求处理异常，比如返回错误信息
    throw;
}

注意这个方案依赖SQL Server的锁机制，如果你用的是其他数据库，需要调整对应的锁语法。

方案三：存储过程实现校验+插入 #

这也是你考虑过的方向，把逻辑封装到存储过程里，数据库层面的原子性同样能保证并发安全。示例存储过程大概是这样：

CREATE PROCEDURE InsertIfUnderLimit
    @Condition NVARCHAR(100),
    @MaxCount INT,
    @Val1 NVARCHAR(100),
    @Val2 NVARCHAR(100),
    @Inserted BIT OUTPUT
AS
BEGIN
    SET NOCOUNT ON;
    SET @Inserted = 0;

    IF (SELECT COUNT(*) FROM YourTableName WHERE YourConditionColumn = @Condition) < @MaxCount
    BEGIN
        INSERT INTO YourTableName (Column1, Column2)
        VALUES (@Val1, @Val2);
        SET @Inserted = 1;
    END
END

然后在EF里异步调用这个存储过程：

var insertedParam = new SqlParameter("@Inserted", SqlDbType.Bit) { Direction = ParameterDirection.Output };

await context.Database.ExecuteSqlRawAsync(
    "EXEC InsertIfUnderLimit @Condition, @MaxCount, @Val1, @Val2, @Inserted OUT",
    new SqlParameter("@Condition", conditionValue),
    new SqlParameter("@MaxCount", maxCount),
    new SqlParameter("@Val1", "value1"),
    new SqlParameter("@Val2", "value2"),
    insertedParam);

var wasInserted = (bool)insertedParam.Value;
// 根据wasInserted的值处理后续逻辑

关键注意点 #

• 绝对不要在应用层先查计数、再判断插入——这两个步骤之间的空隙，完全可能被另一个并发请求钻空子，导致超额创建。
• 所有操作都用异步方法（比如BeginTransactionAsync、ExecuteSqlRawAsync），完全符合WebApi Core的异步要求，不需要改成同步方法。

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