如何用C#实现数据库的并发令牌?处理并发冲突?

来源:这里教程网 时间:2026-02-21 17:26:27 作者:

在C#中使用Entity Framework Core实现数据库并发控制,主要通过并发令牌(Concurrency Token)来检测和处理多个用户同时修改同一条数据时可能引发的冲突。以下是具体实现方式和处理策略。

什么是并发令牌?

并发令牌是用于标识实体是否被其他操作修改过的字段。EF Core会在执行更新或删除操作时检查该字段的值是否与加载时一致,如果不一致则抛出DbUpdateConcurrencyException,防止覆盖他人更改。

常见的并发令牌字段包括:

时间戳/行版本(如 rowversion 列) 最后修改时间 特定业务字段(如订单状态)

如何设置并发令牌?

可以通过数据注解或Fluent API配置某个属性为并发令牌。

// 使用数据注解

public class Product
{
    public int Id { get; set; }
    public string Name { get; set; }
    1771665446  // 自动生成 rowversion 类型(推荐)
    public byte[] RowVersion { get; set; }
}

// 或者用 Fluent API 配置普通属性为并发令牌

protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.Entity<Product>()
        .Property(p => p.Name)
        .IsConcurrencyToken();
}

1771665446 是最常用的方式,它映射到 SQL Server 的

rowversion
类型,每次行更新都会自动变化,适合做乐观锁。

处理并发冲突异常

当并发更新失败时,EF Core 抛出 DbUpdateConcurrencyException。你需要捕获这个异常并决定如何处理。

try
{
    await context.SaveChangesAsync();
}
catch (DbUpdateConcurrencyException ex)
{
    foreach (var entry in ex.Entries)
    {
        if (entry.Entity is Product product)
        {
            // 获取当前数据库中的最新值
            var databaseEntry = context.Entry(product).GetDatabaseValues();
            if (databaseEntry == null)
            {
                // 记录已被删除
                throw new InvalidOperationException("该记录可能已被删除。");
            }
            // 示例:采用“客户端优先”策略,重新应用变更
            var databaseProduct = (Product)databaseEntry.ToObject();
            // 手动合并更改(例如保留数据库的某些字段,应用客户端的新值)
            databaseProduct.Name = product.Name; // 客户端新名称
            // 更新当前实体为数据库快照,并应用新值
            entry.OriginalValues.SetValues(databaseEntry);
            entry.CurrentValues.SetValues(databaseProduct);
        }
    }
    // 重试保存
    await context.SaveChangesAsync();
}

你也可以选择以下几种处理策略:

放弃更改:提示用户数据已变更,请刷新后重试。 自动合并:程序自动判断哪些字段可以安全覆盖。 日志记录 + 人工干预:记录冲突详情供后续处理。

前端配合提示用户

可以在界面上显示“上次修改时间”或版本号,让用户知道数据是否陈旧。提交时若发生冲突,返回友好提示:

```csharp catch (DbUpdateConcurrencyException) { return BadRequest("数据已被其他用户修改,请刷新页面后重试。"); } ```

基本上就这些。关键是用好 1771665446 字段实现自动版本控制,再合理捕获和处理异常。这样就能在C#项目中有效管理数据库并发问题。不复杂但容易忽略细节。

相关推荐