EF Core乐观并发锁怎么用 EF Core RowVersion使用教程

11次阅读

EF Core 乐观并发锁通过版本校验实现,不阻塞操作,推荐用 [Timestamp] 标记 byte[]字段自动管理;也可用 [ConcurrencyCheck] 标记业务字段手动维护版本;冲突时抛 DbUpdateConcurrencyException,可重载、合并或重试。

EF Core 乐观并发锁怎么用 EF Core RowVersion 使用教程

EF Core 乐观并发锁的核心是“不锁数据,只校验版本”,适合读多写少、冲突概率低的场景。它不阻塞其他读写操作,而是在 SaveChanges() 时通过 WHERE 条件比对版本值来判断数据是否被他人修改过。一旦发现不一致,就抛出异常,由你决定如何处理。

加一个 RowVersion 字段并标记为并发令牌

这是最推荐、最省心的方式,尤其在 SQL Server 中天然支持 rowversion 列。

  • 在实体类中添加 byte[] 类型字段,并用 [Timestamp] 特性标记:

public class Product {public int Id { get; set;}     public string Name {get; set;}     public decimal Price {get; set;}     [Timestamp]  // 自动映射为 rowversion(SQL Server)或 bytea(PostgreSQL)public byte[] RowVersion { get; set;} }

  • 或者用 Fluent API 在 OnModelCreating 中配置(效果等同):

protected override void OnModelCreating(ModelBuilder modelBuilder) {modelBuilder.Entity<Product>()         .Property(p => p.RowVersion)         .IsRowVersion();  // EF Core 会自动设为不可写、每次更新自增}

注意:该字段无需手动赋值,SQL Server 每次 INSERT/UPDATE 都会自动生成新值;EF Core 会在 UPDATE 语句的 WHERE 子句中自动带上它。

用普通字段做并发检查(灵活但需自己维护)

如果你用的是 MySQL、SQLite 或不想依赖数据库特性,可以用业务字段(如 LastModifiedVersion)当并发令牌。

  • [ConcurrencyCheck] 标记字段:

public class Order {public int Id { get; set;}     public string OrderNumber {get; set;}     [ConcurrencyCheck]     public int Version {get; set;}  // 手动递增 }

  • 或用 Fluent API 配置:

modelBuilder.Entity<Order>()     .Property(o => o.Version)     .IsConcurrencyToken();

关键点:你得在每次更新前主动给 Version 加 1(比如 entity.Version++),否则校验永远通过——EF Core 只负责在 SQL 的 WHERE 中加入 AND Version = 原值,不帮你管理值本身。

保存时自动触发校验,冲突了怎么办?

调用 SaveChanges()SaveChangesAsync() 时,EF Core 会生成类似这样的 SQL:

UPDATE Products  SET Price = 29.99, Name = 'New Name'  WHERE Id = 1 AND RowVersion = 0x00000000000007D3

如果 WHERE 条件不匹配(说明别人已改过),影响行数为 0,EF Core 就抛出 DbUpdateConcurrencyException

  • 捕获异常后,常见处理方式有:
  • 重新加载最新数据(entry.Reload()entry.GetDatabaseValuesAsync()),提示用户“数据已被他人修改”,让用户确认是否覆盖
  • 合并变更:取数据库当前值(databaseValues),保留用户修改的字段(currentValues),再尝试保存
  • 自动重试(配合 Polly 等库):例如最多重试 3 次,每次间隔递增

示例简写:

try {context.SaveChanges(); } catch (DbUpdateConcurrencyException ex) {foreach (var entry in ex.Entries)     {var dbValues = entry.GetDatabaseValues();         if (dbValues != null)         {entry.OriginalValues.SetValues(dbValues); // 刷新原始值,为重试准备         }     }     context.SaveChanges(); // 重试}

注意事项和避坑点

  • [Timestamp] 只在 SQL Server / PostgreSQL 有效;MySQL 不支持 rowversion,需改用 intdatetime + IsConcurrencyToken()
  • 同一个实体只能有一个 [Timestamp] 字段;但可多个字段用 [ConcurrencyCheck]
  • 使用 AsNoTracking() 查询的数据,即使带 RowVersion,也不会参与并发检查——因为没被上下文跟踪
  • 手动执行 SQL(如 ExecuteSqlInterpolated)不会触发 EF Core 并发逻辑,需自行在 SQL 中加 WHERE 版本条件

基本上就这些。用好 RowVersion,不用写锁、不卡查询,就能稳住高并发下的数据一致性。

星耀云
版权声明:本站原创文章,由 星耀云 2025-12-21发表,共计2192字。
转载说明:转载本网站任何内容,请按照转载方式正确书写本站原文地址。本站提供的一切软件、教程和内容信息仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络,版权争议与本站无关。
text=ZqhQzanResources