c# efcore如何处理并发操作

发布时间:2024-12-06 08:04:01

阅读量:146

在C#中使用Entity Framework Core处理并发操作时，可以采用以下几种策略：

乐观并发：乐观并发假设多个事务在同一时间访问数据的概率较低。因此，在执行更新操作时，不会立即检查数据是否已被其他事务修改。而是在更新操作中捕获版本冲突，并在捕获到冲突时采取适当的措施（例如重试操作或抛出异常）。要使用乐观并发，需要在实体类中添加一个版本字段（通常是一个整型），并将其设置为乐观并发策略的一部分。

public class MyEntity
{
    public int Id { get; set; }
    public string Name { get; set; }
    public int Version { get; set; }
}

// 在DbContext中配置乐观并发
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
    modelBuilder.Entity()
        .Version();
}

在执行更新操作时捕获版本冲突：

public async Task UpdateAsync(MyEntity entity)
{
    try
    {
        _context.Entry(entity).OriginalValues["Version"] = entity.Version;
        _context.Entry(entity).State = EntityState.Modified;
        await _context.SaveChangesAsync();
    }
    catch (DbUpdateConcurrencyException ex)
    {
        // 处理版本冲突，例如重试操作或抛出异常
    }
}

悲观并发：悲观并发假设多个事务在同一时间访问数据的概率较高。因此，在执行更新操作之前，会先锁定数据以防止其他事务修改。这可以通过使用SelectLocking方法来实现。

public async Task UpdateAsync(MyEntity entity)
{
    var entry = await _context.Entries()
        .Where(e => e.Id == entity.Id)
        .SelectLocking(LockMode.Upgrade)
        .FirstOrDefaultAsync();

    if (entry != null)
    {
        entry.OriginalValues["Name"] = entity.Name;
        _context.Entry(entry).State = EntityState.Modified;
        await _context.SaveChangesAsync();
    }
}

分布式锁：在分布式系统中处理并发操作时，可以使用分布式锁来确保同一时间只有一个事务可以访问数据。在Entity Framework Core中，可以使用SemaphoreSlim来实现分布式锁。

public async Task UpdateAsync(MyEntity entity)
{
    using (var semaphore = new SemaphoreSlim(1, 1))
    {
        await semaphore.WaitAsync();

        try
        {
            _context.Entry(entity).OriginalValues["Name"] = entity.Name;
            _context.Entry(entity).State = EntityState.Modified;
            await _context.SaveChangesAsync();
        }
        finally
        {
            semaphore.Release();
        }
    }
}