Mysql如何利用乐观锁解决高并发问题

msql

Mysql如何利用乐观锁解决高并发问题
前言
一、案例说明：
二、乐观锁：
- 1.介绍:
- - 使用版本号实现乐观锁
- 2.代码实现
总结

前言

例如：在这之前已经许久未写博客了，最近突发奇想还是决定把这个捡起来,本篇文章将讲述mysql乐观锁解决高并发的问题。

一、案例说明：

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

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

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

对于上面修改用户帐户信息的例子而言，假设数据库中帐户信息表中有一个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的操作结果的可能。

乐观锁介绍：

二、乐观锁：

1.介绍:

代码如下（示例）：乐观锁（ Optimistic Locking ）相对悲观锁而言，乐观锁假设认为数据一般情况下不会造成冲突，所以在数据进行提交更新的时候，才会正式对数据的冲突与否进行检测，如果发现冲突了，则让返回用户错误的信息，让用户决定如何去做。

使用版本号实现乐观锁

使用数据版本（Version）记录机制实现，这是乐观锁最常用的一种实现方式。何谓数据版本？即为数据增加一个版本标识，一般是通过为数据库表增加一个数字类型的 “version” 字段来实现。当读取数据时，将version字段的值一同读出，数据每更新一次，对此version值加一。当我们提交更新的时候，判断数据库表对应记录的当前版本信息与第一次取出来的version值进行比对，如果数据库表当前版本号与第一次取出来的version值相等，则予以更新，否则认为是过期数据。

在这里插入图片描述

2.代码实现

代码如下（示例）：
商品goods表中有一个字段status，status为1代表商品未被下单，status为2代表商品已经被下单，那么我们对某个商品下单时必须确保该商品status为1。假设商品的id为1。

下单操作包括3步骤：

1.查询出商品信息

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

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

3.修改商品status为2

update goods

set status=2,version=version+1

where id=#{id} and version=#{version};

为了使用乐观锁，我们首先修改goods表，增加一个version字段，数据默认version值为1。

goods表初始数据如下：

mysql> select * from goods;  
+----+--------+------+---------+  
| id | status | name | version |  
+----+--------+------+---------+  
|  1 |      1 | 小米 |       1 |  
|  2 |      2 | 华为 |       2 |  
+----+--------+------+---------+  
2 rows in set  mysql>

对于乐观锁的实现，我使用MyBatis来进行实践，具体如下：

Goods实体类：

/** * ClassName: Goods <br/> * Function: 商品实体. <br/> * @author lz*/  
public class Goods implements Serializable {  /** * serialVersionUID:序列化ID. */  private static final long serialVersionUID = 6803791908148880587L;  /** * id:主键id. */  private int id;  /** * status:商品状态：1未下单、2已下单. */  private int status;  /** * name:商品名称. */  private String name;  /** * version:商品数据版本号. */  private int version;  @Override  public String toString(){  return "good id:"+id+",goods status:"+status+",goods name:"+name+",goods version:"+version;  }  //setter and getter  }

GoodsDao

/** * updateGoodsUseCAS:使用CAS(Compare and set)更新商品信息. <br/> * * @author lz* @param goods 商品对象 * @return 影响的行数 */  
int updateGoodsUseCAS(Goods goods);

mapper.xml

<update id="updateGoodsUseCAS" parameterType="Goods">  update goods set status=#{status},name=#{name},version=version+1 where id=#{id} and version=#{version}   
</update>

GoodsDaoTest测试类

@Test  
public void goodsDaoTest(){  int goodsId = 1;  //根据相同的id查询出商品信息，赋给2个对象  Goods goods1 = this.goodsDao.getGoodsById(goodsId);  Goods goods2 = this.goodsDao.getGoodsById(goodsId);  //打印当前商品信息  System.out.println(goods1);  System.out.println(goods2);  //更新商品信息1  goods1.setStatus(2);//修改status为2  int updateResult1 = this.goodsDao.updateGoodsUseCAS(goods1);  System.out.println("修改商品信息1"+(updateResult1==1?"成功":"失败"));  //更新商品信息2  goods2.setStatus(2);//修改status为2  int updateResult2 = this.goodsDao.updateGoodsUseCAS(goods2);  System.out.println("修改商品信息2"+(updateResult2==1?"成功":"失败"));  
}

输出结果：

good id:1,goods status:1,goods name:道具,goods version:1  
good id:1,goods status:1,goods name:道具,goods version:1  
修改商品信息1成功  
修改商品信息2失败

mysql> select * from goods;  
+----+--------+------+---------+  
| id | status | name | version |  
+----+--------+------+---------+  
|  1 |      2 | 小米 |       2 |  
|  2 |      2 | 华为 |       2 |  
+----+--------+------+---------+  
2 rows in set