如何用C#实现数据库的并发令牌？处理并发冲突？-C#.Net教程-PHP中文网

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

月夜之吻

发布： 2025-09-23 10:25:01

原创

149人浏览过

使用并发令牌可检测并处理EF Core中的数据冲突，通过[Timestamp]或Fluent API标记字段为并发令牌，更新时自动检查一致性，发生冲突时捕获DbUpdateConcurrencyException并重试、合并或提示用户刷新，推荐用[Timestamp]实现乐观锁。

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

在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; }

    [Timestamp]  // 自动生成 rowversion 类型（推荐）
    public byte[] RowVersion { get; set; }
}

登录后复制

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

腾讯智影-AI数字人

基于AI数字人能力，实现7*24小时AI数字人直播带货，低成本实现直播业务快速增增，全天智能在线直播

查看详情

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

登录后复制

[Timestamp] 是最常用的方式，它映射到 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();
}

登录后复制

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