向女朋友解释乐观锁与悲观锁的小妙招！



微信搜索【BGM7756】免费获取java基础原理分析、实战技术、微服务架构、分布式系统构建
等资料！





并发控制



当程序中可能出现并发的情况时，我们就需要通过一定的手段来保证在并发情况下数据的准确性，通过这种手段保证了当用户和其他用户一起操作时，所得到的结果和他单独操作时的祷告的结果是一样的。



这种手段就叫做并发控制。并发控制的目的是保证一个用户的工作不会对另一个用户的工作产生不合理的影响。



没有做好并发控制，就可能导致脏读、幻读和不可重复读等问题。



我们常说的并发控制，一般都和数据库管理系统(DBMS)有关，在 DBMS 中的并发控制的任务是确保在多个事务同时存取数据库中同一数据时不破坏事务的隔离性和统一性以及数据库的统一性。

在开始介绍之前要明确一下：无论是悲观锁还是乐观锁，都是人们定义出来的概念，可以认为是一种思想。



其实不仅仅是关系型数据库系统中有乐观锁和悲观锁的概念，像 Memcache、Hibernate、Tair 等都有类似的概念。所以，不应该拿乐观锁、悲观锁和其他的数据库锁等进行对比。



悲观锁



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



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



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



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





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



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







乐观锁



乐观锁( Optimistic Locking ) 是相对悲观锁而言的，乐观锁假设数据一般情况下不会造成冲突。



所以在数据进行提交更新的时候，才会正式对数据的冲突与否进行检测，如果发现冲突了，则让返回用户错误的信息，让用户决定如何去做。



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





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











悲观锁实现方式



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



• 在对记录进行修改前，先尝试为该记录加上排他锁(exclusive locking)。

• 如果加锁失败，说明该记录正在被修改，那么当前查询可能要等待或者抛出异常。具体响应方式由开发者根据实际需要决定。

• 如果成功加锁，那么就可以对记录做修改，事务完成后就会解锁了。

• 其间如果有其他对该记录做修改或加排他锁的操作，都会等待我们解锁或直接抛出异常。



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



要使用悲观锁，我们必须关闭 MySQL 数据库的自动提交属性，因为 MySQL 默认使用 Autocommit 模式。



也就是说，当你执行一个更新操作后，MySQL 会立刻将结果进行提交。set autocommit=0。



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



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



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



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



上面我们提到，使用 select…for update 会把数据给锁住，不过我们需要注意一些锁的级别，MySQL InnoDB 默认行级锁。



行级锁都是基于索引的，如果一条 SQL 语句用不到索引是不会使用行级锁的，会使用表级锁把整张表锁住，这点需要注意。







乐观锁实现方式



使用乐观锁就不需要借助数据库的锁机制了。乐观锁的概念中其实已经阐述了它的具体实现细节，主要就是两个步骤：冲突检测和数据更新。其实现方式有一种比较典型的就是 Compare and Swap(CAS)。



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



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



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



以上，我们在更新之前，先查询一下库存表中当前库存数(quantity)，然后在做 update 的时候，以库存数作为一个修改条件。



当我们提交更新的时候，判断数据库表对应记录的当前库存数与***次取出来的库存数进行比对，如果数据库表当前库存数与***次取出来的库存数相等，则予以更新，否则认为是过期数据。







以上更新语句存在一个比较重要的问题，即传说中的 ABA 问题。



比如说一个线程 one 从数据库中取出库存数 3，这时候另一个线程 two 也从数据库中取出库存数 3，并且 two 进行了一些操作变成了 2。



然后 two 又将库存数变成 3，这时候线程 one 进行 CAS 操作发现数据库中仍然是 3，然后 one 操作成功。尽管线程 one 的 CAS 操作成功，但是不代表这个过程就是没有问题的。





有一个比较好的办法可以解决 ABA 问题，那就是通过一个单独的可以顺序递增的 version 字段。



改为以下方式即可





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



乐观锁每次在执行数据的修改操作时，都会带上一个版本号，一旦版本号和数据的版本号一致就可以执行修改操作并对版本号执行 +1 操作，否则就执行失败。



因为每次操作的版本号都会随之增加，所以不会出现 ABA 问题，因为版本号只会增加不会减少。



除了 version 以外，还可以使用时间戳，因为时间戳天然具有顺序递增性。









以上 SQL 其实还是有一定的问题的，就是一旦发生高并发的时候，就只有一个线程可以修改成功，那么就会存在大量的失败。



对于像淘宝这样的电商网站，高并发是常有的事，总让用户感知到失败显然是不合理的。所以，还是要想办法减少乐观锁的力度的。



有一条比较好的建议，可以减小乐观锁力度，***程度的提升吞吐率，提高并发能力!如下：



17. //修改商品库存 18. update item  19. set quantity=quantity - 1  20. where id = 1 and quantity - 1 > 0 



以上 SQL 语句中，如果用户下单数为 1，则通过 quantity - 1 > 0 的方式进行乐观锁控制。



以上 update 语句，在执行过程中，会在一次原子操作中自己查询一遍 quantity 的值，并将其扣减掉 1。



高并发环境下锁粒度把控是一门重要的学问，选择一个好的锁，在保证数据安全的情况下，可以大大提升吞吐率，进而提升性能。













如何选择



在乐观锁与悲观锁的选择上面，主要看下两者的区别以及适用场景就可以了：



• 乐观锁并未真正加锁，效率高。一旦锁的力度掌握不好，更新失败的概率就会比较高，容易发生业务失败。

• 悲观锁依赖数据库锁，效率低。更新失败的概率比较低。



随着互联网三高架构(高并发、高性能、高可用)的提出，悲观锁已经越来越少的被使用到生产环境中了，尤其是并发量比较大的业务场景。









微信搜索【BGM7756】免费获取java基础原理分析、实战技术、微服务架构、分布式系统构建

等资料！