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

在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 配置普通属性为并发令牌
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.Entity()
.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();
}你也可以选择以下几种处理策略:
- 放弃更改:提示用户数据已变更,请刷新后重试。
- 自动合并:程序自动判断哪些字段可以安全覆盖。
- 日志记录 + 人工干预:记录冲突详情供后续处理。
前端配合提示用户
可以在界面上显示“上次修改时间”或版本号,让用户知道数据是否陈旧。提交时若发生冲突,返回友好提示:
```csharp catch (DbUpdateConcurrencyException) { return BadRequest("数据已被其他用户修改,请刷新页面后重试。"); } ```基本上就这些。关键是用好 [Timestamp] 字段实现自动版本控制,再合理捕获和处理异常。这样就能在C#项目中有效管理数据库并发问题。不复杂但容易忽略细节。










