浅析Entity Framework Core中的并发处理

前言

Entity Framework Core 2.0更新也已经有一段时间了,园子里也有不少的文章..

本文主要是浅析一下Entity Framework Core的并发处理方式.

1.常见的并发处理策略

要了解如何处理并发,就要知道并发的一般处理策略

悲观并发策略

悲观并发策略,正如其名,它指的是对数据被外界（包括本系统当前的其他事务,以及来自外部系统的事务处理）修改持保守悲观的态度,因此,在整个数据处理过程中,将数据处于锁定状态。悲观并发策略大多数情况下依靠数据库的锁机制实现，以保证操作最大程度的独占性。但随之而来的就是数据库性能的巨大开销,特别是对长事务而言,这样的开销在大量的并发情况下往往无法承受。

乐观并发策略

乐观并发策略,一般是基于数据版本 Version记录机制实现。何谓数据版本？即为数据增加一个版本标识,在基于数据库表的版本解决方案中,一般是通过为数据库表增加一个 “version” 字段来实现.读取出数据时,将此版本号一同读出,之后更新时,对此版本号加一。此时,将提交数据的版本数据与数据库表对应记录的当前版本信息进行比对，如果提交的数据版本号大于数据库表当前版本号，则予以更新，否则认为是过期数据。需要注意的是，乐观并发策略机制往往基于系统中的数据存储逻辑，因此也具备一定的局限性.

本篇就是讲解,如何在我们的Entity Framework Core中来使用和自定义我们的并发策略

2.Entity Framework Core并发令牌

要使用Entity Framework Core中的并发策略,就需要使用我们的并发令牌(ConcurrencyCheck)

在Entity Framework Core中,并发的默认处理方式是无视并发冲突的,任何修改语句在条件符合的情况下,都可以修改成功.

在高并发的情况下这种处理方式,肯定会给我们的数据库带来很多脏数据,所以,Entity Framework Core提供了并发令牌(ConcurrencyCheck)这个特性.

如果一个属性被配置为并发令牌，则EF将在保存这条记录时，会检查没有其他用户修改过数据库中的这个属性的值。EF使用了乐观并发策略，这意味着它将假定值没有改变，并尝试保存数据,但如果发现值已更改,则抛出异常。

举个例子,我们有一个用户类(User),我们配置 User中的 Name为并发令牌。这意味着，如果一个用户试图保存一个有些变化的 User，但另一个用户已经改变了 Name那么将抛出一个异常。这在应用中一般是可取的，以便我们的应用程序可以提示用户，在保存他们的改变之前，以确保此记录仍然代表同一个姓名的人。

2.1并发令牌在EF中工作的原理

当我们配置User中的Name为令牌的时候,EF会将并发令牌包含在Where、Update或delete命令的子句中并检查受影响的行数来实现验证。如果并发令牌仍然匹配，则一行将被更新。如果数据库中的值已更改，则不会更新任何行。

比如,当我们设置Name为并发令牌,然后通过ID来修改User的PassWord的时候,EF会生成如下的修改语句:

UPDATE [User] SET [PassWord] = @p1WHERE [ID] = @p0 AND [Name] = @p2;

当然,这时候,Name不匹配了,受影响的行数返回为0.

2.2并发令牌的使用约定

属性默认不被配置为并发令牌。

2.3并发令牌的使用方式

1.直接使用特性,如下配置UserName为并发令牌:

public partial class UserTable
{       
      public int Id { get; set; }[ConcurrencyCheck]    
     public string UserName { get; set; }  

      public string PassWord { get; set; }    

      public int? ClassId { get; set; }
}

2.使用FluentAPI配置属性为并发令牌

class MyContext : DbContext
{ 
    public DbSet<UserTable> People { get; set; }   
    protected override void OnModelCreating(ModelBuilder modelBuilder){modelBuilder.Entity<UserTable>().Property(p => p.UserName).IsConcurrencyToken();}
}

以上2种方式,效果是一样的.

2.4使用时间戳和行级版本号

我们知道,SQL Server给我们提供了时间戳的属性(当然,几乎所有的关系数据库都有这个).下面举个SQL Server的例子

我们加一个时间戳字段为TimestampV,加上特性Timestamp,实体代码如下:

  public partial class UserTable{      
         public int Id { get; set; }      
         public string UserName { get; set; }   
         public string PassWord { get; set; }    
         public int? ClassId { get; set; }   
         public ClassTable Class { get; set; }[Timestamp]      
        public byte[] TimestampV { get; set; }}

CodeFrist生成的表如下:

自动帮我们生成的Timestamp类型的一个字段.

配置时间戳属性的方式也有2种,上面已经说了一种..特性的..

同样我们也可以使用Fluent API配置属性为时间戳,代码如下:

class MyContext : DbContext
{   
  public DbSet<UserTable> Blogs { get; set; }    
  
  protected override void OnModelCreating(ModelBuilder modelBuilder){modelBuilder.Entity<UserTable>().Property(p => p.TimestampV).ValueGeneratedOnAddOrUpdate().IsConcurrencyToken();}
}

3.如何根据需求自定义处理并发冲突

上面,我们已经配置好了需要并发处理的表,也配置好了相关的特性,下面我们就来讲讲如何使用它.

使用之前,我们先来了解一下,并发过程中所产生的3个值,也是我们需要处理的3个值

1.当前值是应用程序尝试写入数据库的值。

2.原始值是在进行任何编辑之前最初从数据库检索的值。

3.数据库值是当前存储在数据库中的值。

当我们配置好上面的并发令牌时,在EF执行SaveChanges()操作并产生并发的时候,我们会得到DbUpdateConcurrencyException的异常信息,(注意:在不配置并发令牌时,这个异常一般不会触发)

前面,我们已经讲过乐观并发策略是一种性能较高,也比较实用的处理方式,所以我们就通过时间戳来处理这个并发的问题.

示例测试代码如下:

 public void Test(){            //重新创建数据库,并新增一条数据using (var context = new School_TestContext()){context.Database.EnsureDeleted();context.Database.EnsureCreated();context.UserTable.Add(new UserTable { UserName = "John", PassWord = "Doe" });context.SaveChanges();}            using (var context = new School_TestContext()){                // 修改id为1的用户名称var person = context.UserTable.Single(p => p.Id == 1);person.UserName = "555-555-5555";                // 直接通过访问数据库来修改同一条数据 (这里是为了模拟并发)context.Database.ExecuteSqlCommand("UPDATE dbo.UserTable SET UserName = 'Jane' WHERE ID = 1");          
                try{                    //尝试保存修改int a = context.SaveChanges();}                //获取并发异常catch (DbUpdateConcurrencyException ex){                    foreach (var entry in ex.Entries){                
         if (entry.Entity is UserTable){                    
         var databaseEntity = context.UserTable.AsNoTracking().Single(p => p.Id == ((UserTable)entry.Entity).Id);                            var databaseEntry = context.Entry(databaseEntity);                            //当前上下文时间戳var date = ConvertToTimeSpanString(entry.Property("TimestampV").CurrentValue);                            var dateint = Int32.Parse(date, System.Globalization.NumberStyles.HexNumber);                            //数据库时间戳var datebase = ConvertToTimeSpanString(databaseEntry.Property("TimestampV").CurrentValue);                            var dateint2 = Int32.Parse(datebase, System.Globalization.NumberStyles.HexNumber);                            //如果当前上下文时间戳与数据库相同,或者更加新,则使用当前
  if (dateint >= dateint2){                                foreach (var property in entry.Metadata.GetProperties()){                                    //当前值
   var proposedValue = entry.Property(property.Name).CurrentValue;                                    //原始值
  var originalValue = entry.Property(property.Name).OriginalValue;                                    //数据库值
   var databaseValue = databaseEntry.Property(property.Name).CurrentValue;                                   
  //更新当前值entry.Property(property.Name).CurrentValue = proposedValue;                                  
   //更新原始值来保证修改成功entry.Property(property.Name).OriginalValue = databaseEntry.Property(property.Name).CurrentValue;                                    // 尝试重新保存数据int aa = context.SaveChanges();}}}                  
                       else{                            throw new NotSupportedException("无法处理并发," + entry.Metadata.Name);}}}}}