数据库中的乐观锁与悲观锁详解

系统管理员 2022-10-31 00:45 112阅读 0赞

**目录**

悲观锁

乐观锁

悲观锁实现方式

乐观锁实现方式

如何选择

--------------------

## 悲观锁 ##

当我们要对一个数据库中的一条数据进行修改的时候，为了避免同时被其他人修改，最好的办法就是直接对该数据进行加锁以防止并发。

这种借助数据库锁机制在修改数据之前先锁定，再修改的方式被称之为悲观并发控制（又名“悲观锁”，Pessimistic Concurrency Control，缩写“PCC”）。

**之所以叫做悲观锁，是因为这是一种对数据的修改抱有悲观态度的并发控制方式。我们一般认为数据被并发修改的概率比较大，所以需要在修改之前先加锁。**

悲观并发控制实际上是**“先取锁再访问”的保守策略**，**为数据处理的安全提供了保证**。

但是在效率方面，处理加锁的机制会**让数据库产生额外的开销**，还有增加**产生死锁**的机会；

另外，还会**降低并行性**，一个事务如果锁定了某行数据，其他事务就必须等待该事务处理完才可以处理那行数据。

## 乐观锁 ##

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

**相对于悲观锁，在对数据库进行处理的时候，乐观锁并不会使用数据库提供的锁机制。一般的实现乐观锁的方式就是记录数据版本。**

乐观并发控制相信事务之间的数据竞争(data race)的概率是比较小的，因此**尽可能直接做下去，直到提交的时候才去锁定，所以不会产生任何锁和死锁**。

## 悲观锁实现方式 ##

悲观锁的实现，往往依靠数据库提供的锁机制。在数据库中，悲观锁的流程如下：

*  在对记录进行修改前，先尝试为该记录加上排他锁（exclusive locking）。
 *  如果加锁失败，说明该记录正在被修改，那么当前查询可能要等待或者抛出异常。具体响应方式由开发者根据实际需要决定。
 *  如果成功加锁，那么就可以对记录做修改，事务完成后就会解锁了。
 *  其间如果有其他事务对该记录做加锁的操作，都要等待当前事务解锁或直接抛出异常。

我们拿比较常用的MySql Innodb引擎举例，来说明一下在SQL中如何使用悲观锁。

> 注意：要使用悲观锁，我们必须关闭mysql数据库中自动提交的属性，命令set autocommit=0;即可关闭，因为MySQL默认使用autocommit模式，也就是说，当你执行一个更新操作后，MySQL会立刻将结果进行提交。

我们举一个简单的例子，如淘宝下单过程中扣减库存的需求说明一下如何使用悲观锁：

//0.开始事务
    begin; 
    //1.查询出商品库存信息
    select quantity from items where id=1 for update;
    //2.修改商品库存为2
    update items set quantity=2 where id = 1;
    //3.提交事务
    commit;

以上，在对id = 1的记录修改前，先通过for update的方式进行加锁，然后再进行修改。这就是比较典型的悲观锁策略。

如果以上修改库存的代码发生并发，同一时间只有一个线程可以开启事务并获得id=1的锁，其它的事务必须等本次事务提交之后才能执行。这样我们可以保证当前的数据不会被其它事务修改。

> 上面我们提到，使用select…for update会把数据给锁住，不过我们需要注意一些锁的级别，MySQL InnoDB默认行级锁。行级锁都是基于索引的，如果一条SQL语句用不到索引是不会使用行级锁的，会使用表级锁把整张表锁住，这点需要注意。

## 乐观锁实现方式 ##

使用乐观锁就不需要借助数据库的锁机制了。

乐观锁的概念中其实已经阐述了他的具体实现细节：主要就是两个步骤：冲突检测和数据更新。其实现方式有一种比较典型的就是**Compare and Swap(CAS)技术**。

CAS是项乐观锁技术，当多个线程尝试使用CAS同时更新同一个变量时，只有其中一个线程能更新变量的值，而其它线程都失败，**失败的线程并不会被挂起，而是被告知这次竞争中失败，并可以再次尝试。**

比如前面的扣减库存问题，通过乐观锁可以实现如下：

//查询出商品库存信息，quantity = 3
    select quantity from items where id=1
    //修改商品库存为2
    update items set quantity=2 where id=1 and quantity = 3;

以上，我们在更新之前，先查询一下库存表中当前库存数（quantity），然后在做update的时候，以库存数作为一个修改条件。当我们提交更新的时候，判断数据库表对应记录的当前库存数与第一次取出来的库存数进行比对，如果数据库表当前库存数与第一次取出来的库存数相等，则予以更新，否则认为是过期数据。

但是以上更新语句存在一个比较重要的问题，即**ABA问题。**

比如说一个线程1从数据库中取出库存数3，这时候另一个线程2也从数据库中库存数3，并且线程2进行了一些操作将库存数变成了2，紧接着又将库存数变成3，这时候线程1进行CAS操作发现数据库中仍然是3，然后线程1操作成功。尽管线程1的CAS操作成功，但是不代表这个过程就是没有问题的。