第五节：框架前期准备篇之锁机制处理并发

一. 简介

(一). 在处理并发的这个问题上，锁大致分为两类：悲观锁和乐观锁。

　　1.  悲观锁：悲观的认为每次去拿数据的时候都会被别人修改，所以每次在拿数据的时候都会“上锁”，操作完成之后再“解锁”。 在数据加锁期间，其他人(其他线程)如果来拿数据就会等待，直到去掉锁。数据库层次的悲观锁有“表锁”、“行锁”等。

注：EF默认不支持悲观锁，只能通过EF调用SQL语句。

　　2.  乐观锁：乐观的认为该条数据不会被占用，自己先占了再说，占完了之后再看看是不是占上了，如果没占上就是操作失败，提示给用户。

　　3.  两种锁进行对比：悲观锁使用的体验更好，但是对系统性能的影响大，只适合并发量不大的场合。 乐观锁适用于“写少读多”的情况下，加大了系统的整个吞吐量，但是“乐观锁可能失败”给用户的体验很不好。

注：两种锁各有利弊，至于怎么取舍，根据实际业务场景来进行。

(二). 模拟一个抢单的业务场景

　　一个乘客发了一个打车订单，很多司机去抢这个订单，执行的业务简单点来说是，先select出这条数据，然后update这个条数据中的driveName字段为自己的名字，但是现在会有这么

 

一种现象，同时select出这条订单，先后更新driveName这个字段，先抢到订单的乘客会发现最后订单没了，实际上是数据库中Update第二次的操作覆盖了第一次的操作了，这就是

 

并发操作带来的尴尬场景。

 

 

二. 悲观锁

 1. 数据准备

　　新建数据库【LockDemoDB】，新建订单表OrderInfor，包括字段有：id、userName(乘客姓名)、destination(订单信息)、driverName(抢单司机的姓名)、isRobbed(该订单是否被抢, 0代表未被抢,1代表已被抢 )，事先插入一条数据用于测试对应的字段分别为： 1,  ypf,  去北京,  "",  0

如下图：

 2. 原理

　　开启事务，利用排它锁和行锁将该条数据锁住，其他线程如果要访问，必须得该线程提交完事务，锁释放后才能使用，下面分享两种写法：ADO.NET写法 和 EF调用SQL语句写法。

大致流程：

　　①：查询id为1的数据，如果不存在，则停止业务；如果存在，继续往下执行。

　　②：查询isRobbed字段的值，如果为1，代表该订单已经刚被人抢了，然后输出driverName的值，即代表被谁抢了；如果为0，代表该订单尚未被抢，继续往下执行。

　　③：执行Update操作，进行事务提交，这期间别的线程是不能访问的。

　　④：提交完事务后，锁被释放，其它线程得以继续访问。

 ADO.NET写法：

复制代码

 1             {2                 Console.WriteLine("司机您好，请输入您的名字");3                 string driverName = Console.ReadLine();4                 string connstr = ConfigurationManager.ConnectionStrings["connstr"].ConnectionString;5                 using (SqlConnection conn = new SqlConnection(connstr))6                 {7                     conn.Open();8                     using (var tx = conn.BeginTransaction())9                     {
10                         try
11                         {
12                             Console.WriteLine("开始查询");
13                             using (var selectCmd = conn.CreateCommand())
14                             {
15                                 selectCmd.Transaction = tx;
16                                 //排它锁和行锁,针对访问线程锁住该行,不能继续往下执行，只有事务提交完，其他线程才能访问
17                                 selectCmd.CommandText = "select * from OrderInfor with(xlock,ROWLOCK) where id=1";
18                                 using (var reader = selectCmd.ExecuteReader())
19                                 {
20                                     if (!reader.Read())
21                                     {
22                                         Console.WriteLine("没有id为1的订单");
23                                         return;
24                                     }
25                                     string dName = null;
26                                     string isRobbed = null;
27                                     if (!reader.IsDBNull(reader.GetOrdinal("driverName")))
28                                     {
29                                         dName = reader.GetString(reader.GetOrdinal("driverName"));
30                                     }
31                                     if (!reader.IsDBNull(reader.GetOrdinal("isRobbed")))
32                                     {
33                                         isRobbed = reader.GetString(reader.GetOrdinal("isRobbed"));
34                                     }
35 
36                                     //表示该订单已经被抢了
37                                     if (isRobbed == "1" && !string.IsNullOrEmpty(dName))
38                                     {
39                                         if (driverName == dName)
40                                         {
41                                             Console.WriteLine("该订单早已经被我抢了");
42                                         }
43                                         else
44                                         {
45                                             Console.WriteLine($"该订单早已经被司机【{dName}】抢了");
46                                         }
47                                         //不再往下执行
48                                         Console.ReadKey();
49                                         return;
50                                     }
51                                 }
52                                 Console.WriteLine("查询完成,开始执行update操作");
53                                 using (var updateCmd = conn.CreateCommand())
54                                 {
55                                     updateCmd.Transaction = tx;
56                                     updateCmd.CommandText = "Update OrderInfor set driverName=@driverName,isRobbed=@isRobbed where id=1";
57                                     updateCmd.Parameters.Add(new SqlParameter("@driverName", driverName));
58                                     updateCmd.Parameters.Add(new SqlParameter("@isRobbed", "1"));
59                                     updateCmd.ExecuteNonQuery();
60                                 }
61                                 Console.WriteLine("结束update操作");
62                                 Console.WriteLine("按任意键进行事务提交");
63                                 Console.ReadKey();
64                             }
65                             tx.Commit();
66                             Console.WriteLine("事务提交成功");
67                         }
68                         catch (Exception ex)
69                         {
70                             Console.WriteLine(ex);
71                             tx.Rollback();
72                         }
73                     }
74                 }
75             }

复制代码

EF调用SQL语句写法：

复制代码

 1             {2                 Console.WriteLine("司机您好，请输入您的名字");3                 string driverName = Console.ReadLine();4                 using (LockDemoDBEntities1 ctx = new LockDemoDBEntities1())5                 using (var tx = ctx.Database.BeginTransaction())6                 {7                     Console.WriteLine("开始查询");8                     //一定要遍历一下 SqlQuery 的返回值才会真正执行 SQL 9                     //排它锁和行锁,针对访问线程锁住该行,不能继续往下执行，只有事务提交完，其他线程才能访问
10                     var orderInfor = ctx.Database.SqlQuery<OrderInfor>("select * from OrderInfor with(xlock,ROWLOCK) where id=1").Single();
11 
12                     //表示该订单已经被抢了
13                     if (orderInfor.isRobbed == "1" && !string.IsNullOrEmpty(orderInfor.driverName))
14                     {
15                         if (driverName == orderInfor.driverName)
16                         {
17                             Console.WriteLine("该订单早已经被我抢了");
18                         }
19                         else
20                         {
21                             Console.WriteLine($"该订单早已经被司机【{orderInfor.driverName}】抢了");
22                         }
23                         //不再往下执行
24                         Console.ReadKey();
25                         return;
26                     }
27 
28                     Console.WriteLine("查询完成,开始执行update操作");
29                     ctx.Database.ExecuteSqlCommand("Update OrderInfor set driverName={0},isRobbed={1} where id=1", driverName, "1");
30                     Console.WriteLine("结束update操作");
31                     Console.WriteLine("按任意键进行事务提交");
32                     Console.ReadKey();
33                     try
34                     {
35                         tx.Commit();
36                     }
37                     catch (Exception ex)
38                     {
39                         Console.WriteLine(ex);
40                         tx.Rollback();
41                     }
42                 }
43             }

复制代码

 结果分析：

 　　①：线程1进入，查询完毕，尚未进行事务提交。

　　②：线程2进入，被锁住，无法继续往下进行操作。

　　③：线程1进行事务提交，线程1执行成功的同时，线程2提示该订单已经被xx抢了。

 

 

三. 乐观锁

 1. 数据准备

　　新建订单表OrderInfor2，包括基础字段有：id、userName(乘客姓名)、destination(订单信息)、driverName(抢单司机的姓名)、isRobbed(该订单是否被抢, 0代表未被抢,1代表已被抢 )， 新增字段：rowversion字段, 类型为timestamp,对应的实体类型为byte[]， 事先插入一条数据用于测试对应的字段分别为： 1, ypf, 去北京, "", 0 。

PS：凡是对该条数据进行过update操作，rowversion字段的值都会发生变化。

 2. 原理

 　  这里提供两种思路，分别是：原生的SQL语句(这里通过EF调用) 和 EF默认的乐观锁模式。

(1). 原生的SQL语句：

　 ①：查出该条订单的记录，包括rowversion字段。

　 ②：把该rowversion字段作为update操作where的一个条件，执行更新操作。

　 ③：看受影响的行数，如果受影响的行数为0，表示该条数据在你执行更新操作前已经被人改过了，这个时候通常提示用户“更新失败”；如果受影响的行数为1，则表示没被修改过，提示用户“更新成功”。

分享代码：

复制代码

 1             {2                 try3                 {4                     Console.WriteLine("司机您好，请输入您的名字");5                     string driverName = Console.ReadLine();6                     using (LockDemoDBEntities1 ctx = new LockDemoDBEntities1())7                     {8                         Console.WriteLine("开始查询");9                         //一定要遍历一下 SqlQuery 的返回值才会真正执行 SQL 
10                         var orderInfor = ctx.Database.SqlQuery<OrderInfor2>("select * from OrderInfor2 where id=1").Single();
11 
12                         //表示该订单已经被抢了
13                         if (orderInfor.isRobbed == "1" && !string.IsNullOrEmpty(orderInfor.driverName))
14                         {
15                             if (driverName == orderInfor.driverName)
16                             {
17                                 Console.WriteLine("该订单早已经被我抢了");
18                             }
19                             else
20                             {
21                                 Console.WriteLine($"该订单早已经被司机【{orderInfor.driverName}】抢了");
22                             }
23                             //不在往下执行
24                             Console.ReadKey();
25                             return;
26                         }
27 
28                         Console.WriteLine("查询完成,按任意键进行抢单");
29                         Console.ReadKey();
30                         Console.WriteLine("正在抢单中。。。。。");
31                         //休眠3s，模拟高并发抢单
32                         Thread.Sleep(3000);
33                         int affectRows = ctx.Database.ExecuteSqlCommand("Update OrderInfor2 set driverName={0},isRobbed={1} where id=1 and rowversion={2}", driverName, "1", orderInfor.rowversion);
34                         if (affectRows == 0)
35                         {
36                             Console.WriteLine("抢单失败");
37                         }
38                         else if (affectRows == 1)
39                         {
40                             Console.WriteLine("抢单成功");
41                         }
42                         else
43                         {
44                             Console.WriteLine("见鬼了");
45                         }
46                     }
47                 }
48                 catch (Exception ex)
49                 {
50                     Console.WriteLine("失败了");
51                     Console.WriteLine(ex.Message);
52                     throw;
53                 }
54             }

复制代码

(2). EF默认的乐观锁模式

　　a. DBFirst模式：在Edmx模型上给该字段的并发模式设置为fixed(默认为None)，这样该表中所有字段都监控并发。如果不想监视所有列（在不添加RowVersion的情况下），只需在Edmx模型是给特定的字段的并发模式设置为fixed，这样只有被设置的字段被监测并发。

　　b. CodeFirst下的Fluent API下的配置：

　　　　　　全局配置：Property(e => e.RowVersion).IsRowVersion();

　　　　　　单独字段配置：Property(p => p.xxxx).IsConcurrencyToken();

　　c. CodeFirst下的DataAnnotation下的配置：rowversion属性加上特性[Timestamp],这样该表中所有字段都监控并发。如果不想监视所有列（在不添加RowVersion的情况下）， 只需给特定的字段加上特性 [ConcurrencyCheck]，这样只有被设置的字段被监测并发。

原理：通过DbUpdateConcurrencyException监测该条数据是否被改过，改过就抛异常。

分享代码：

复制代码

 1                 Console.WriteLine("司机您好，请输入您的名字");2                 string driverName = Console.ReadLine();3                 using (LockDemoDBEntities1 ctx = new LockDemoDBEntities1())4                 {5                     Console.WriteLine("开始查询");6 7                     var orderInfor = ctx.OrderInfor2.Where(u => u.id == "1").FirstOrDefault();8 9                     //表示该订单已经被抢了
10                     if (orderInfor.isRobbed == "1" && !string.IsNullOrEmpty(orderInfor.driverName))
11                     {
12                         if (driverName == orderInfor.driverName)
13                         {
14                             Console.WriteLine("该订单早已经被我抢了");
15                         }
16                         else
17                         {
18                             Console.WriteLine($"该订单早已经被司机【{orderInfor.driverName}】抢了");
19                         }
20                         //不在往下执行
21                         Console.ReadKey();
22                         return;
23                     }
24 
25                     Console.WriteLine("查询完成,按任意键进行抢单");
26                     Console.ReadKey();
27                     Console.WriteLine("正在抢单中。。。。。");
28                     //休眠3s，模拟高并发抢单
29                     Thread.Sleep(3000);
30 
31                     //下面执行更新操作
32                     orderInfor.driverName = driverName;
33                     orderInfor.isRobbed = "1";
34                     try
35                     {
36                         ctx.SaveChanges();
37                         Console.WriteLine("抢单成功");
38                     }
39                     catch (DbUpdateConcurrencyException)
40                     {
41                         Console.WriteLine("抢单失败");
42                     }
43                 }

复制代码

3. 结果分析

 　　①：线程1 和 线程2，同时执行且均查询完毕，等待点击按钮进行抢单。

　　②：先点击线程1，然后点击线程2，发现线程1抢单成功，线程2抢单失败，证明线程2在抢单的时候，监测到该数据已经被改动了。

 

 

四. 数据库锁详解

 

详见：https://www.cnblogs.com/yaopengfei/p/9762267.html

 

 

 

 

 

 

 

!

  • 作       者 : Yaopengfei(姚鹏飞)
  • 博客地址 : http://www.cnblogs.com/yaopengfei/
  • 声     明1 : 本人才疏学浅，用郭德纲的话说“我是一个小学生”，如有错误，欢迎讨论，请勿谩骂^_^。
  • 声     明2 : 原创博客请在转载时保留原文链接或在文章开头加上本人博客地址，否则保留追究法律责任的权利。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/438977.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

表面粗糙度的基本评定参数是_表面粗糙度100问，讲得明明白白

表面粗糙度的基本评定参数是_表面粗糙度100问，讲得明明白白

提醒&#xff1a;点上方↑↑↑“制造原理”订阅后 满足你的好奇来源&#xff1a;机械工程师1&#xff0e; 什么称为表面粗糙度&#xff1f;答&#xff1a;表面粗糙度是指零件加工表面上具有的由较小间距和峰谷所组成的微观几何形状特征。它是一种微观几何形状误差。2&#xff0…
阅读更多...
第六节：框架搭建之EF的Fluent Api模式的使用流程

第六节：框架搭建之EF的Fluent Api模式的使用流程

一. 前言 沉寂了约一个月的时间&#xff0c;今天用一篇简单的文章重新回归博客&#xff0c;主要来探讨一下Fluent Api模式在实际项目中的使用流程。 1. Fluent API属于EF CodeFirst模式的一种&#xff0c;EF还有一种模式是DataAnnotations&#xff0c;两种模式各有千秋吧&…
阅读更多...
高通modem启动过程_苹果首次承认正自研基带芯片，高通要被抛弃了？

高通modem启动过程_苹果首次承认正自研基带芯片，高通要被抛弃了？

以苹果技术实力&#xff0c;摆脱依赖&#xff0c;只是时间的问题。”作者 | 肖漫苹果和高通的基带芯片故事续集&#xff0c;又开始上映了。据彭博社 12 月 10 日报道&#xff0c;苹果公司芯片负责人对员工表示&#xff0c;苹果已开始为未来的设备自研蜂窝调制解调器&#xff0c…
阅读更多...
第七节：框架搭建之页面静态化的剖析

第七节：框架搭建之页面静态化的剖析

一. 前言 抛砖引玉&#xff1a; 提到项目性能优化&#xff0c;大部分人第一时间就会想到缓存&#xff0c;针对“读多写少”的数据&#xff0c;可以放到缓存里&#xff0c;设置个过期时间&#xff0c;这样就不用每次都去数据库中查询了&#xff0c; 减轻了数据库的压力&#xff…
阅读更多...
第八节：数据库层次的锁机制详解和事务隔离级别

第八节：数据库层次的锁机制详解和事务隔离级别

一. 基本概念 1.共享锁&#xff1a;(holdlock) (1). select的时候会自动加上共享锁&#xff0c;该条语句执行完&#xff0c;共享锁立即释放&#xff0c;与事务是否提交没有关系。 (2). 显式通过添加(holdlock)来显式添加共享锁&#xff08;比如给select语句显式添加共享锁&…
阅读更多...
第九节：基于MVC5+AutoFac+EF+Log4Net的基础结构搭建

第九节：基于MVC5+AutoFac+EF+Log4Net的基础结构搭建

一. 前言 从本节开始&#xff0c;将陆续的介绍几种框架搭建组合形式&#xff0c;分析每种搭建形式的优势和弊端&#xff0c;剖析搭建过程中涉及到的一些思想和技巧。 (一). 技术选型 1. DotNet框架&#xff1a;4.6 2. 数据库访问&#xff1a;EF 6.2 (CodeFrist模式) 3. IOC框架…
阅读更多...
第十节：基于MVC5+Unity+EF+Log4Net的基础结构搭建

第十节：基于MVC5+Unity+EF+Log4Net的基础结构搭建

一. 前言 从本节开始&#xff0c;将陆续的介绍几种框架搭建组合形式&#xff0c;分析每种搭建形式的优势和弊端&#xff0c;剖析搭建过程中涉及到的一些思想和技巧。 (一). 技术选型 1. DotNet框架&#xff1a;4.6 2. 数据库访问&#xff1a;EF 6.2 (CodeFrist模式) 3. IOC框架…
阅读更多...
a*算法的优缺点_K-近邻算法以及案例

a*算法的优缺点_K-近邻算法以及案例

什么是K-近邻算法(KNN)根据邻居判断类型。如果一个样本在特征空间中有K个最相似&#xff08;距离相近&#xff09;的样本大多数属于一个类别&#xff0c;则该样品也属于这个类别。如何求距离呢?非常简单,如图。a1,a2,a3代表样本a的特征值 b1,b2,b3代表b的样本值&#xff0c;根…
阅读更多...
第十一节：基于MVC5+Spring.Net+EF+Log4net 传统的一种搭建模式

第十一节：基于MVC5+Spring.Net+EF+Log4net 传统的一种搭建模式

阅读更多...
android 预约挂号代码_告别排队！用Python定时自动挂号和快捷查询化验报告

android 预约挂号代码_告别排队！用Python定时自动挂号和快捷查询化验报告

作者 | 阿文来源 | 程序人生(ID: coder_life)我什么要做这个事情去年单位体检查出问题来&#xff0c;经过穿刺手术确诊是个慢性肾脏病2期&#xff0c; IGA 肾病三期&#xff0c;可能大家对于这个病并不是很了解&#xff0c;但是另外一个词可能大家都听过&#xff0c;叫"尿…
阅读更多...
灵动思绪EF(Entity FrameWork)

灵动思绪EF(Entity FrameWork)

很久之前就想写这篇文章了&#xff0c;但是由于种种原因&#xff0c;没有将自己学习的EF知识整理成一片文章。今天我就用CodeFirst和ModelFirst两种方式的简单案例将自己学习的EF知识做个总结。 在讲解EF之前&#xff0c;我们先来看下ORM ORM全称&#xff1a;(Object-Relatio…
阅读更多...
json qbytearray 串 转_JSON数据采集网关,json转Modbus RTU串IO口RS485转4~20mA边缘计算智能终端...

json qbytearray 串 转_JSON数据采集网关,json转Modbus RTU串IO口RS485转4~20mA边缘计算智能终端...

JSON数据采集网关边缘计算智能终端是一种能够将各种传感器仪表仪器设备的数据采集后按照JSON格式上传服务器的网关&#xff0c;可以实现云边协同。JSON(JavaScript Object Notation)是java中的数据格式。例如{“Energy”:”100”, “time”:”22:22:15”}这样的格式&#xff0c…
阅读更多...
ABP入门系列（3）——领域层定义仓储并实现

ABP入门系列（3）——领域层定义仓储并实现

一、先来介绍下仓储 仓储&#xff08;Repository&#xff09;&#xff1a; 仓储用来操作数据库进行数据存取。仓储接口在领域层定义&#xff0c;而仓储的实现类应该写在基础设施层。 在ABP中&#xff0c;仓储类要实现IRepository接口&#xff0c;接口定义了常用的增删改查以及…
阅读更多...
XCIE-HUAWEI-PBR-MQC-引入形成的路由环路

XCIE-HUAWEI-PBR-MQC-引入形成的路由环路

XCIE-HUAWEI-PBR-MQC-引入形成的路由环路 首先来个测试 给你们选&#xff0c;答案选啥呢? 正确答案在结尾公布 正确答案是C 为什么呢&#xff1f; 首先&#xff0c;虽然ACL有一个齐总是拒绝的&#xff0c;但是呢&#xff0c;他两都是同一条路由 但是呢&#xff01;&#x…
阅读更多...
ABP入门系列（5）——展现层实现增删改查

ABP入门系列（5）——展现层实现增删改查

ABP入门系列目录——学习Abp框架之实操演练源码路径&#xff1a;Github-LearningMpaAbp 这一章节将通过完善Controller、View、ViewModel&#xff0c;来实现展现层的增删改查。最终实现效果如下图&#xff1a; 展现层最终效果 一、定义Controller ABP对ASP.NET MVC Controlle…
阅读更多...
限制会话id服务端不共享_不懂 Zookeeper？看完不懂你打我

限制会话id服务端不共享_不懂 Zookeeper？看完不懂你打我

高并发分布式开发技术体系已然非常的庞大&#xff0c;从国内互联网企业使用情况&#xff0c;可发现RPC、Dubbo、ZK是最基础的技能要求。关于Zookeeper你是不是还停留在Dubbo注册中心的印象中呢&#xff1f;还有它的工作原理呢&#xff1f;经典应用场景呢&#xff1f;对前面三个…
阅读更多...
防抖与节流方案_前端ajax优化解决方案

防抖与节流方案_前端ajax优化解决方案

伴随着前端ajax的应用场景越来越多&#xff0c;那就免不了一个整合的ajax优化解决方案了&#xff0c;自己优化太麻烦&#xff1f;没事&#xff0c;有它帮你解决&#xff1a;hajax 与当下比较热门的请求库 axios 和原生的 fetch相比&#xff0c;hajax有什么一些什么内容和特点呢…
阅读更多...
ABP入门系列（6）——定义导航菜单

ABP入门系列（6）——定义导航菜单

ABP入门系列目录——学习Abp框架之实操演练源码路径&#xff1a;Github-LearningMpaAbp 完成了增删改查以及页面展示&#xff0c;这一节我们来为任务清单添加【导航菜单】。 在以往的项目中&#xff0c;大家可能会手动在layout页面中添加一个a标签来新增导航菜单&#xff0c;这…
阅读更多...
ABP入门系列（7）——分页实现

ABP入门系列（7）——分页实现

ABP入门系列目录——学习Abp框架之实操演练源码路径&#xff1a;Github-LearningMpaAbp 完成了任务清单的增删改查&#xff0c;咱们来讲一讲必不可少的的分页功能。 首先很庆幸ABP已经帮我们封装了分页实现&#xff0c;实在是贴心啊。 来来来&#xff0c;这一节咱们就来捋一捋如…
阅读更多...
下载matlab安装包太慢_Matlab2017a软件安装包以及安装教程

下载matlab安装包太慢_Matlab2017a软件安装包以及安装教程

安装步骤&#xff1a;1.如图所示&#xff0c;完整的安装包应该有13个压缩包&#xff0c;必须要全部下载完成才能解压。鼠标右击“thMWoMaR17a.part01.rar”压缩包&#xff0c;选择“解压到thMWoMaR17a”&#xff0c;然后等待解压完成2.打开“thMWoMaR17a”文件夹&#xff0c;解…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023