mysql乐观锁总结和实践

╰+哭是因爲堅強的太久メ 2022-06-17 01:55 128阅读 0赞

上一篇文章《[MySQL悲观锁总结和实践][MySQL]》谈到了MySQL悲观锁，但是悲观锁并不是适用于任何场景，它也有它存在的一些不足，因为悲观锁大多数情况下依靠数据库的锁机制实现，以保证操作最大程度的独占性。如果加锁的时间过长，其他用户长时间无法访问，影响了程序的并发访问性，同时这样对数据库性能开销影响也很大，特别是对长事务而言，这样的开销往往无法承受。所以与悲观锁相对的，我们有了乐观锁，具体参见下面介绍：

**乐观锁介绍：**

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

1.使用数据版本（Version）记录机制实现，这是乐观锁最常用的一种实现方式。何谓数据版本？即为数据增加一个版本标识，一般是通过为数据库表增加一个数字类型的 “version” 字段来实现。当读取数据时，将version字段的值一同读出，数据每更新一次，对此version值加一。当我们提交更新的时候，判断数据库表对应记录的当前版本信息与第一次取出来的version值进行比对，如果数据库表当前版本号与第一次取出来的version值相等，则予以更新，否则认为是过期数据。用下面的一张图来说明：![点击查看原始大小图片][22a9518f-e355-315f-8d66-d91af4fda723.jpg]

如上图所示，如果更新操作顺序执行，则数据的版本（version）依次递增，不会产生冲突。但是如果发生有不同的业务操作对同一版本的数据进行修改，那么，先提交的操作（图中B）会把数据version更新为2，当A在B之后提交更新时发现数据的version已经被修改了，那么A的更新操作会失败。

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

**使用举例**：以MySQL InnoDB为例

还是拿之前的实例来举：商品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 t\_goods

set status=2,version=version+1

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

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

t\_goods表初始数据如下：

Sql代码   ![收藏代码][icon_star.png]

1.  mysql> **select** \* **from** t\_goods;  
2.  \+\----+--------+------+---------+  
3.  | id | status | **name** | version |  
4.  \+\----+--------+------+---------+  
5.  |  1 |      1 | 道具 |       1 |  
6.  |  2 |      2 | 装备 |       2 |  
7.  \+\----+--------+------+---------+  
8.  2 **rows** in **set**  
9.    
10. mysql>

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

Goods实体类：

Java代码   ![收藏代码][icon_star.png]

1.  /\*\* 
2.   \* ClassName: Goods <br/> 
3.   \* Function: 商品实体. <br/> 
4.   \* date: 2013-5-8 上午09:16:19 <br/> 
5.   \* @author chenzhou1025@126.com 
6.   \*/  
7.  **public** **class** Goods **implements** Serializable \{  
8.    
9.      /\*\* 
10.      \* serialVersionUID:序列化ID. 
11.      \*/  
12.     **private** **static** **final** **long** serialVersionUID = 6803791908148880587L;  
13.       
14.     /\*\* 
15.      \* id:主键id. 
16.      \*/  
17.     **private** **int** id;  
18.       
19.     /\*\* 
20.      \* status:商品状态：1未下单、2已下单. 
21.      \*/  
22.     **private** **int** status;  
23.       
24.     /\*\* 
25.      \* name:商品名称. 
26.      \*/  
27.     **private** String name;  
28.       
29.     /\*\* 
30.      \* version:商品数据版本号. 
31.      \*/  
32.     **private** **int** version;  
33.       
34.     @Override  
35.     **public** String toString()\{  
36.         **return** "good id:"\+id+",goods status:"\+status+",goods name:"\+name+",goods version:"\+version;  
37.     \}  
38.   
39.     //setter and getter  
40.   
41. \}

GoodsDao

Java代码   ![收藏代码][icon_star.png]

1.  /\*\* 
2.   \* updateGoodsUseCAS:使用CAS(Compare and set)更新商品信息. <br/> 
3.   \* 
4.   \* @author chenzhou1025@126.com 
5.   \* @param goods 商品对象 
6.   \* @return 影响的行数 
7.   \*/  
8.  **int** updateGoodsUseCAS(Goods goods);

mapper.xml

Xml代码   ![收藏代码][icon_star.png]

1.  **<****update** id="updateGoodsUseCAS" parameterType="Goods"**>**  
2.      <!\[CDATA\[ 
3.          update t\_goods 
4.          set status=\#\{status\},name=\#\{name\},version=version+1 
5.          where id=\#\{id\} and version=\#\{version\} 
6.      \]\]>  
7.  **</****update****>**

GoodsDaoTest测试类

Java代码   ![收藏代码][icon_star.png]

1.  @Test  
2.  **public** **void** goodsDaoTest()\{  
3.      **int** goodsId = 1;  
4.      //根据相同的id查询出商品信息，赋给2个对象  
5.      Goods goods1 = **this**.goodsDao.getGoodsById(goodsId);  
6.      Goods goods2 = **this**.goodsDao.getGoodsById(goodsId);  
7.        
8.      //打印当前商品信息  
9.      System.out.println(goods1);  
10.     System.out.println(goods2);  
11.       
12.     //更新商品信息1  
13.     goods1.setStatus(2);//修改status为2  
14.     **int** updateResult1 = **this**.goodsDao.updateGoodsUseCAS(goods1);  
15.     System.out.println("修改商品信息1"\+(updateResult1==1?"成功":"失败"));  
16.       
17.     //更新商品信息2  
18.     goods1.setStatus(2);//修改status为2  
19.     **int** updateResult2 = **this**.goodsDao.updateGoodsUseCAS(goods1);  
20.     System.out.println("修改商品信息2"\+(updateResult2==1?"成功":"失败"));  
21. \}

输出结果：

Shell代码   ![收藏代码][icon_star.png]

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

说明：

在GoodsDaoTest测试方法中，我们同时查出同一个版本的数据，赋给不同的goods对象，然后先修改good1对象然后执行更新操作，执行成功。然后我们修改goods2，执行更新操作时提示操作失败。此时t\_goods表中数据如下：

Sql代码   ![收藏代码][icon_star.png]

1.  mysql> **select** \* **from** t\_goods;  
2.  \+\----+--------+------+---------+  
3.  | id | status | **name** | version |  
4.  \+\----+--------+------+---------+  
5.  |  1 |      2 | 道具 |       2 |  
6.  |  2 |      2 | 装备 |       2 |  
7.  \+\----+--------+------+---------+  
8.  2 **rows** in **set**  
9.    
10. mysql>

我们可以看到 id为1的数据version已经在第一次更新时修改为2了。所以我们更新good2时update where条件已经不匹配了，所以更新不会成功，具体sql如下：

Sql代码   ![收藏代码][icon_star.png]

1.  **update** t\_goods   
2.  **set** status=2,version=version+1  
3.  **where** id=\#\{id\} and version=\#\{version\};

这样我们就实现了乐观锁

[MySQL]: http://chenzhou123520.iteye.com/blog/1860954
[22a9518f-e355-315f-8d66-d91af4fda723.jpg]: /images/20220617/03b581e57310467783fa3d9c35aaef0f.png
[icon_star.png]: /images/20220617/ee866a4c0108452b90b4554c47298dbe.png