mybatis 如何使用乐观锁88bf必发娱乐

悲观锁(Pessimistic Lock)

顾名思义,就是很悲观,每次去拿数据的时候都认为别人会修改,所以每次在拿数据的时候都会上锁,这样别人想拿这个数据就会block直到它拿到锁。传统的关系型数据库里边就用到了很多这种锁机制,比如行锁,表锁等,读锁,写锁等,都是在做操作之前先上锁。

2.乐观锁定的第二种实现方式和第一种差不多,同样是在需要乐观锁控制的table中增加一个字段,名称无所谓,字段类型使用时间戳(timestamp),
和上面的version类似,也是在更新提交的时候检查当前数据库中数据的时间戳和自己更新前取到的时间戳进行对比,如果一致则OK,否则就是版本冲突。

乐观锁(Optimistic Lock)

顾名思义,就是很乐观,每次去拿数据的时候都认为别人不会修改,所以不会上锁,但是在更新的时候会判断一下在此期间别人有没有去更新这个数据,可以使用版本号等机制。乐观锁适用于多读的应用类型,这样可以提高吞吐量,像数据库如果提供类似于write_condition机制的其实都是提供的乐观锁。

两种锁各有优缺点,不可认为一种好于另一种,像乐观锁适用于写比较少的情况下,即冲突真的很少发生的时候,这样可以省去了锁的开销,加大了系统的整个吞吐量。但如果经常产生冲突,上层应用会不断的进行retry,这样反倒是降低了性能,所以这种情况下用悲观锁就比较合适。悲观并发控制主要用于数据争用激烈的环境,以及发生并发冲突时使用锁保护数据的成本要低于回滚事务的成本的环境中。

读取出数据时,将此版本号一同读出,之后更新时,对此版本号加一。此时,将提交数据的版本数据与数据库表对应记录的当前版本信息进行比对,如果提交的数据版本号大于数据库表当前版本号,则予以更新,否则认为是过期数据。

优点与不足:

乐观并发控制相信事务之间的数据竞争(data
race)的概率是比较小的,因此尽可能直接做下去,直到提交的时候才去锁定,所以不会产生任何锁和死锁。但如果直接简单这么做,还是有可能会遇到不可预期的结果,例如两个事务都读取了数据库的某一行,经过修改以后写回数据库,这时就遇到了问题,可能会出现脏读的情况。

下面是一个简单的示例:

一个典型的依赖数据库的悲观锁调用:

select * from user where name=”mx” for update;

这条 sql 语句锁定了 user 表中所有符合检索条件( name=”mx”
)的记录,本次事务提交之前(事务提交时会释放事务过程中的锁),外界无法修改这些记录。

乐观锁的例子:

使用版本号时,可以在数据初始化时指定一个版本号,每次对数据的更新操作都对版本号执行+1操作。并判断当前版本号是不是该数据的最新的版本号。

经典面试题~乐观锁和悲观锁

1.查询出商品信息

select status,version from t_goods where id=#{id}

2.根据商品信息生成订单

3.修改商品status为2

update t_goods set status=2,version=version+1 where id=#{id} and
version=#{version};

即操作员A对数据商品状态从1(未发货)修改为2(已发货),同时对版本号version
+1,这样操作员B假如在A之前就进入页面,没有刷新页面之前显示还是未发货,当B修改状态为2,版本号+1变成2提交时,不满足
“ 提交版本必须大于记录当前版本才能执行更新 “ 的乐观锁策略,因此,操作员
B 的提交被驳回。

  1. <update id=”updateGoodsUseCAS” parameterType=”Goods”>  
  2. <![CDATA[ 
  3.         set status=#{status},name=#{name},version=version+1 
  4. 88bf必发娱乐,    ]]>  
  5. </update> 

 

对于上面修改用户帐户信息的例子而言,假设数据库中帐户信息表中有一个version字段,当前值为1;而当前帐户余额字段(balance)为1000元。假设操作员A先更新完,操作员B后更新。
a、操作员A此时将其读出(version=1),并从其帐户余额中增加100(1000+100=1100)。
b、在操作员A操作的过程中,操作员B也读入此用户信息(version=1),并从其帐户余额中扣除50(1000-50=950)。
c、操作员A完成了修改工作,将数据版本号加一(version=2),连同帐户增加后余额(balance=1100),提交至数据库更新,此时由于提交数据版本大于数据库记录当前版本,数据被更新,数据库记录version更新为2。
d、操作员B完成了操作,也将版本号加一(version=2)试图向数据库提交数据(balance=950),但此时比对数据库记录版本时发现,操作员B提交的数据版本号为2,数据库记录当前版本也为2,不满足
“提交版本必须大于记录当前版本才能执行更新
“的乐观锁策略,因此,操作员B的提交被驳回。
这样,就避免了操作员B用基于version=1的旧数据修改的结果覆盖操作员A的操作结果的可能。

悲观锁的问题:

乐观锁的原理大致一样,这里我提供两种思路:

操作员B操作如下:

 

乐观锁机制在一定程度上解决了这个问题。乐观锁,大多是基于数据版本(Version)记录机制实现。何谓数据版本?即为数据增加一个版本标识,在基于数据库表的版本解决方案中,一般是通过为数据库表增加一个
“version” 字段来实现。

select id, balance, version from account where id="1"; 
查询结果:id=1, balance=1000, version=1

update account 
set balance=balance+100, version=version+1 
where id="1" and version=1

select id, balance, version from account where id="1"; 
查询结果:id=1, balance=1100, version=2

银行两操作员同时操作同一账户就是典型的例子。
比如A、B操作员同时读取一余额为1000元的账户,A操作员为该账户增加100元,B操作员同时为该账户扣除50元,A先提交,B后提交。最后实际账户余额为1000-50=950元,但本该为1000+100-50=1050。这就是典型的并发问题。

 

 

  1. public void goodsDaoTest(){  
  2. int goodsId = 1;  
  3. //根据相同的id查询出商品信息,赋给2个对象  
  4. this.goodsDao.getGoodsById(goodsId);  
  5. this.goodsDao.getGoodsById(goodsId);  
  6.     //打印当前商品信息  
  7.     System.out.println(goods2);  
  8.     //更新商品信息1  
  9. 2);//修改status为2  
  10. int updateResult1 = this.goodsDao.updateGoodsUseCAS(goods1);  
  11. “修改商品信息1″+(updateResult1==1?”成功”:”失败”));  
  12.     //更新商品信息2  
  13. 2);//修改status为2  
  14. int updateResult2 = this.goodsDao.updateGoodsUseCAS(goods1);  
  15. “修改商品信息2″+(updateResult2==1?”成功”:”失败”));  

Hibernate、JPA等ORM框架或者实现,是使用版本号,再判断UPDATE后返回的数值

  1. 1,goods status:1,goods name:道具,goods version:1  
  2. 1,goods status:1,goods name:道具,goods version:1  
  3. 修改商品信息2失败 

下面以mybatis
举例说明,关键代码如下:

因为悲观锁大多数情况下依靠数据库的锁机制实现,以保证操作最大程度的独占性。如果加锁的时间过长,其他用户长时间无法访问,影响了程序的并发访问性,同时这样对数据库性能开销影响也很大,特别是对长事务而言,这样的开销往往无法承受。所以与悲观锁相对的,我们有了乐观锁。

select id, balance, version from account where id="1"; 
查询结果:id=1, balance=1000, version=1

#操作员A已修改成功,实际account.balance=1100、account.version=2,操作员B也将版本号加一(version=2)试图向数据库提交数据(balance=950),但此时比对数据库记录版本时发现,操作员B提交的数据版本号为2,数据库记录当前版本也为2,不满足 “提交版本必须大于记录当前版本才能执行更新 “的乐观锁策略,因此,操作员B的提交被驳回。
update account 
set balance=balance-50, version=version+1 
where id="1" and version=1 

select id, balance, version from account where id="1"; 
查询结果:id=1, balance=1100, version=2

 

操作员A操作如下:

1.使用数据版本(Version)记录机制实现,通过为数据库表增加一个数字类型的
“version”
字段来实现。当读取数据时,将version字段的值一同读出,数据每更新一次,对此version值加一。当我们提交更新的时候,判断数据库表对应记录的当前版本信息与第一次取出来的version值进行比对,如果数据库表当前版本号与第一次取出来的version值相等,则予以更新。