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

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 或不想依赖数据库特性,可以用业务字段(如 LastModified、Version)当并发令牌。
- 用 [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,需改用int或datetime+IsConcurrencyToken() - 同一个实体只能有一个
[Timestamp]字段;但可多个字段用[ConcurrencyCheck] - 使用
AsNoTracking()查询的数据,即使带RowVersion,也不会参与并发检查——因为没被上下文跟踪 - 手动执行 SQL(如
ExecuteSqlInterpolated)不会触发 EF Core 并发逻辑,需自行在 SQL 中加 WHERE 版本条件
基本上就这些。用好 RowVersion,不用写锁、不卡查询,就能稳住高并发下的数据一致性。