用AI赚第一桶💰低成本搭建一套AI赚钱工具,源码可二开。 广告
## **MySQL的锁机制** ## 本文脑图 ![](https://img.kancloud.cn/92/3b/923b1f59b2644369cf8734e60c45cffc_1080x430.png) ## 锁种类 Mysql中锁的分类按照不同类型的划分可以分成不同的锁,按照**「锁的粒度」**划分可以分成:**「表锁、页锁、行锁」**;按照**「使用的方式」**划分可以分为:**「共享锁」**和**「排它锁」**;按照思想的划分:**「乐观锁」**和**「悲观锁」**。 下面我们对着这几种划分的锁进行详细的解说和介绍,在了解设计者设计锁的概念的同时,也能深入的理解设计者的设计思想。 **「表锁」**是粒度最大的锁,开销小,加锁快,不会出现死锁,但是由于粒度太大,因此造成锁的冲突几率大,并发性能低。 Mysql的**「MyISAM储存引擎就支持表锁」**,MyISAM的表锁模式有两种:**「表共享读锁」**和**「表独占写锁」**。 当一个线程获取到MyISAM表的读锁的时候,会阻塞其他用户对该表的写操作,但是不会阻塞其它用户对该用户的读操作。 相反的,当一个线程获取到MyISAM表的写锁的时候,就会阻塞其它用户的读写操作对其它的线程具有排它性。 **「页锁」**的粒度是介于行锁和表锁之间的一种锁,因为页锁是在BDB中支持的一种锁机制,也很少没人提及和使用,所以这里制作概述,不做详解。 **「行锁」**是粒度最小的锁机制,行锁的加锁开销性能大,加锁慢,并且会出现死锁,但是行锁的锁冲突的几率低,并发性能高。 行锁是InnoDB默认的支持的锁机制,MyISAM不支持行锁,这个也是InnoDB和MyISAM的区别之一。 行锁在使用的方式上可以划分为:**「共享读锁(S锁)**「和」**排它写锁(X锁)」**。 当一个事务对MySQL中的一条数据行加上了S锁,当前事务不能修改该行数据只能执行读操作,其他事务只能对该行数据加S锁不能加X锁。 若是一个事务对一行数据加了X锁,该事务能够对该行数据执行读和写操作,其它事务不能对该行数据加任何的锁,既不能读也不能写。 **「悲观锁和乐观锁是在很多框架都存在的一种思想,不要狭义地认为它们是某一种框架的锁机制」**。 数据库管理系统中为了控制并发,保证在多个事务执行时的数据一致性以及事务的隔离性,使用悲观锁和乐观锁来解决并发场景下的问题。 Mysql的**「悲观锁的实现是基于MySQL自身的锁机制实现,而乐观锁需要程序员自己去实现的锁机制」**,最常见的乐观锁实现就锁机制是**「使用版本号实现」**。 乐观锁设计思想的在`CAS`的运用也是比较经典,之前我写过一篇关于CAS的文章,大家感兴趣的可以参考这一篇\[深入剖析AQS和CAS,看了都说好\]。 从上面的介绍中说了每一种锁的概念,但是很难说哪一种锁就是最好的,锁没有最好的,只有哪种业务场景最适合哪种锁,具体业务具体分析。 下面我们就具体基于MySQL的存储引擎详细的分析每一种锁在存储引擎中的运用和实现。 ## MyISAM MyISAM中默认支持的表级锁有两种:**「共享读锁」**和**「独占写锁」**。表级锁在MyISAM和InnoDB的存储引擎中都支持,但是InnoDB默认支持的是行锁。 MySQL中平时读写操作都是隐式的进行加锁和解锁操作,Mysql已经自动帮我们实现加锁和解锁操作了,若是想要测试锁机制,我们就要显示的自己控制锁机制。 MySQL中可以通过以下sql来显示的在事务中显式的进行加锁和解锁操作: ~~~cpp // 显式的添加表级读锁 LOCK TABLE 表名 READ // 显示的添加表级写锁 LOCK TABLE 表名 WRITE // 显式的解锁(当一个事务commit的时候也会自动解锁) unlock tables; ~~~ 下面我们就来测试一下MyISAM中的表级锁机制,首先创建一个测试表`employee` ,这里要指定存储引擎为MyISAM,并插入两条测试数据: ~~~csharp CREATE TABLE IF NOT EXISTS employee ( id INT PRIMARY KEY auto_increment, name VARCHAR(40), money INT )ENGINE MyISAM INSERT INTO employee(name, money) VALUES('黎杜', 1000); INSERT INTO employee(name, money) VALUES('非科班的科班', 2000); ~~~ 查看一下,表结果如下图所示: ![](https://img.kancloud.cn/5e/a7/5ea72d6264b6baf01e9cd354f81c552b_960x145.png) image ### MyISAM表级写锁 (1)与此同时再开启一个session窗口,然后在第一个窗口执行下面的sql,在session1中给表添加写锁: ~~~undefined LOCK TABLE employee WRITE ~~~ (2)可以在session2中进行查询或者插入、更新该表数据,可以发现都会处于等待状态,也就是session1锁住了整个表,导致session2只能等待: ![](https://img.kancloud.cn/85/6b/856b5933da2031b8573b9ef623001dca_723x53.png) (3)在session1中进行查询、插入、更新数据,都可以执行成功: ![](https://img.kancloud.cn/42/a0/42a0db11e954f137121a89e69cce7602_999x338.png) **「总结:」** 从上面的测试结果显示**「当一个线程获取到表级写锁后,只能由该线程对表进行读写操作,别的线程必须等待该线程释放锁以后才能操作」**。 ### MyISAM表级共享读锁 (1)接下来测试一下表级共享读锁,同样还是利用上面的测试数据,第一步还是在session1给表加读锁。 ![](https://img.kancloud.cn/1f/74/1f741445317d8c0c1f3052d7ab2565f2_912x58.png) (2)然后在session1中尝试进行插入、更新数据,发现都会报错,只能查询数据。 ![](https://img.kancloud.cn/5b/51/5b5147c2e9c4ce9fb8b2d2e0f090f017_965x300.png) (3)最后在session2中尝试进行插入、更新数据,程序都会进入等待状态,只能查询数据,直到session1解锁表session2才能插入、更新数据。 ![](https://img.kancloud.cn/97/93/9793dfe9edded496dc59126acc95a728_777x236.png) **「总结:」** 从上面的测试结果显示**「当一个线程获取到表级读锁后,该线程只能读取数据不能修改数据,其它线程也只能加读锁,不能加写锁」**。 ### MyISAM表级锁竞争情况 MyISAM存储引擎中,可以通过查询变量来查看并发场景锁的争夺情况,具体执行下面的sql语句: ~~~dart show status like 'table%'; ~~~ ![](https://img.kancloud.cn/af/c4/afc45fa6f9c9c93e34255510a7553373_864x236.png) 主要是查看`table_locks_waited`和`table_locks_immediate`的值的大小分析锁的竞争情况。 `Table_locks_immediate`:表示能够立即获得表级锁的锁请求次数;`Table_locks_waited`表示不能立即获取表级锁而需要等待的锁请求次数分析,**「值越大竞争就越严重」**。 ### 并发插入 通过上面的操作演示,详细的说明了表级共享锁和表级写锁的特点。但是在平时的执行sql的时候,这些**「解锁和释放锁都是Mysql底层隐式的执行的」**。 上面的演示只是为了证明显式的执行事务的过程共享锁和表级写锁的加锁和解锁的特点,实际并不会这么做的。 在我们平时执行select语句的时候就会隐式的加读锁,执行增、删、改的操作时就会隐式的执行加写锁。 MyISAM存储引擎中,虽然读写操作是串行化的,但是它也支持并发插入,这个需要设置内部变量`concurrent_insert`的值。 它的值有三个值`0、1、2`。可以通过以下的sql查看`concurrent_insert`的默认值为**「AUTO(或者1)」**。 ![](https://img.kancloud.cn/5f/86/5f8663a9dde3845eacc4ad476b842a5c_943x153.png) concurrent\_insert的值为`NEVER (or 0)`表示不支持比并发插入;值为`AUTO(或者1)`表示在MyISAM表中没有被删除的行,运行另一个线程从表尾插入数据;值为`ALWAYS (or 2)`表示不管是否有删除的行,都允许在表尾插入数据。 ### 锁调度 MyISAM存储引擎中,**「假如同时一个读请求,一个写请求过来的话,它会优先处理写请求」**,因为MyISAM存储引擎中认为写请求比读请求重要。 这样就会导致,**「假如大量的读写请求过来,就会导致读请求长时间的等待,或者"线程饿死",因此MyISAM不适合运用于大量读写操作的场景」**,这样会导致长时间读取不到用户数据,用户体验感极差。 当然可以通过设置`low-priority-updates`参数,设置请求链接的优先级,使得Mysql优先处理读请求。 ## InnoDB InnoDB和MyISAM不同的是,InnoDB支持**「行锁」**和**「事务」**,行级锁的概念前面以及说了,这里就不再赘述,事务的四大特性的概述以及实现的原理可以参考这一篇\[\]。 InnoDB中除了有**「表锁」**和**「行级锁」**的概念,还有Gap Lock(间隙锁)、Next-key Lock锁,**「间隙锁主要用于范围查询的时候,锁住查询的范围,并且间隙锁也是解决幻读的方案」**。 InnoDB中的行级锁是**「对索引加的锁,在不通过索引查询数据的时候,InnoDB就会使用表锁」**。 **「但是通过索引查询的时候是否使用索引,还要看Mysql的执行计划」**,Mysql的优化器会判断是一条sql执行的最佳策略。 若是Mysql觉得执行索引查询还不如全表扫描速度快,那么Mysql就会使用全表扫描来查询,这是即使sql语句中使用了索引,最后还是执行为全表扫描,加的是表锁。 若是对于Mysql的sql执行原理不熟悉的可以参考这一篇文章\[\]。最后是否执行了索引查询可以通过`explain`来查看,我相信这个大家都是耳熟能详的命令了。 ### InnoDB行锁和表锁 InnoDB的行锁也是分为行级**「共享读锁(S锁)**「和」**排它写锁(X锁)」**,原理特点和MyISAM的表级锁两种模式是一样的。 若想显式的给表加行级读锁和写锁,可以执行下面的sql语句: ~~~csharp // 给查询sql显示添加读锁 select ... lock in share mode; // 给查询sql显示添加写锁 select ... for update; ~~~ (1)下面我们直接进入锁机制的测试阶段,还是创建一个测试表,并插入两条数据: ~~~csharp // 先把原来的MyISAM表给删除了 DROP TABLE IF EXISTS employee; CREATE TABLE IF NOT EXISTS employee ( id INT PRIMARY KEY auto_increment, name VARCHAR(40), money INT )ENGINE INNODB; // 插入测试数据 INSERT INTO employee(name, money) VALUES('黎杜', 1000); INSERT INTO employee(name, money) VALUES('非科班的科班', 2000); ~~~ (2)创建的表中可以看出对表中的字段只有id添加了主键索引,接着就是在session1窗口执行`begin`开启事务,并执行下面的sql语句: ~~~csharp // 使用非索引字段查询,并显式的添加写锁 select * from employee where name='黎杜' for update; ~~~ (3)然后在session2中执行update语句,上面查询的是id=1的数据行,下面update的是id=2的数据行,会发现程序也会进入等待状态: ~~~bash update employee set name='ldc' where id =2; ~~~ 可见若是**「使用非索引查询,直接就是使用的表级锁」**,锁住了整个表。 ![](https://img.kancloud.cn/1a/fd/1afd0260893b1ee19182e9a554d23ff4_951x54.png) (4)若是session1使用的是id来查询,如下图所示: ![](https://img.kancloud.cn/7a/5c/7a5c35618b17333b440bcde626b751f3_1000x152.png) (5)那么session2是可以成功update其它数据行的,但是这里我建议使用数据量大的表进行测试,因为前面我说过了**「是否执行索引还得看Mysql的执行计划,对于一些小表的操作,可能就直接使用全表扫描」**。 ![](https://img.kancloud.cn/ae/5f/ae5f351ba119421f05325451e540bf8c_1025x66.png) (6)还有一种情况就是:假如我们给name字段也加上了普通索引,那么通过普通索引来查询数据,并且查询到多行数据,那它是锁这多行数据还是锁整个表呢? 下面我们来测试一下,首先给**「name字段添加普通索引」**,如下图所示: ![](https://img.kancloud.cn/c1/3f/c13f4e00fd63fe3a81f083770126fdbf_899x66.png) (6)并插入一条新的数据name值与id=2的值相同,并显式的加锁,如下若是: ![](https://img.kancloud.cn/35/58/35589c34d90bf90f3b6f2f77169879f5_978x444.png) (7)当update其它数据行name值不是ldc的也会进入等待状态,并且通过explain来查看是否name='ldc'有执行索引,可以看到sql语句是有执行索引条件的。 ![![](//upload-images.jianshu.io/upload_images/19895418-16235bef6f5f1f4c?imageMogr2/auto-orient/strip|imageView2/2/w/979/format/webp) ![](https://img.kancloud.cn/f0/a1/f0a1ada5d78cae432bc77340b5182db4_1080x114.png) 结论:从上面的测试锁机制的演示可以得出以下几个结论: 1. 执行非索引条件查询执行的是表锁。 2. 执行索引查询是否是加行锁,还得看Mysql的执行计划,可以通过explain关键字来查看。 3. 用普通键索引的查询,遇到索引值相同的,也会对其他的操作数据行的产生影响。 ### InnoDB间隙锁 当我们使用范围条件查询而不是等值条件查询的时候,InnoDB就会给符合条件的范围索引加锁,在条件范围内并不存的记录就叫做"间隙(GAP)" 大家大概都知道在事务的四大隔离级别中,不可重复读会产生幻读的现象,只能通过提高隔离级别到串行化来解决幻读现象。 但是Mysql中的不可重复是已经解决了幻读问题,它通过引入间隙锁的实现来解决幻读,通过给符合条件的间隙加锁,防止再次查询的时候出现新数据产生幻读的问题。 例如我们执行下面的sql语句,就会对id大于100的记录加锁,在id>100的记录中肯定是有不存在的间隙: ~~~csharp Select * from employee where id> 100 for update; ~~~ (1)接着来测试间隙锁,新增一个字段num,并将num添加为普通索引、修改之前的数据使得num之间的值存在间隙,操作如下sql所示: ~~~csharp alter table employee add num int not null default 0; update employee set num = 1 where id = 1; update employee set num = 1 where id = 2; update employee set num = 3 where id = 3; insert into employee values(4,'kris',4000,5); ~~~ ![](https://img.kancloud.cn/ff/bd/ffbdcadb10745412b02719a07373dd51_1080x199.png) (2)接着在session1的窗口开启事务,并执行下面操作: ![](https://img.kancloud.cn/3e/37/3e37d1b4b0e8a553d1ef28798f39e9d4_998x219.png) (3)同时打开窗口session2,并执行新增语句: ~~~csharp insert into employee values(5,'ceshi',5000,2); // 程序出现等待 insert into employee values(5,'ceshi',5000,4); // 程序出现等待 insert into employee values(5,'ceshi',5000,6); // 新增成功 insert into employee values(6,'ceshi',5000,0); // 新增成功 ~~~ **「从上面的测试结果显示在区间(1,3\]U\[3,5)之间加了锁,是不能够新增数据行,这就是新增num=2和num=4失败的原因,但是在这个区间以外的数据行是没有加锁的,可以新增数据行」**。 根据索引的有序性,而普通索引是可以出现重复值,那么当我们第一个sesson查询的时候只出现一条数据num=3,为了解决第二次查询的时候出现幻读,也就是出现两条或者更多num=3这样查询条件的数据。 Mysql在满足where条件的情况下,给`(1,3]U[3,5)`区间加上了锁不允许插入num=3的数据行,这样就解决了幻读。 这里抛出几种情况接着来测试间隙锁。主键索引(唯一索引)是否会加上间隙锁呢?范围查询是否会加上间隙锁?使用不存在的检索条件是否会加上间隙锁? 先来说说:**「主键索引(唯一索引)是否会加上间隙锁呢?」** 因为主键索引具有唯一性,不允许出现重复,那么当进行等值查询的时候id=3,只能有且只有一条数据,是不可能再出现id=3的第二条数据。 因此它只要锁定这条数据(锁定索引),在下次查询当前读的时候不会被删除、或者更新id=3的数据行,也就保证了数据的一致性,所以主键索引由于他的唯一性的原因,是不需要加间隙锁的。 再来说说第二个问题:**「范围查询是否会加上间隙锁?」** 直接在session1中执行下面的sql语句,并在session2中在这个num>=3的查询条件内和外新增数据: ~~~csharp select * from employee where num>=3 for update; insert into employee values(6,'ceshi',5000,2); // 程序出现等待 insert into employee values(7,'ceshi',5000,4); // 程序出现等待 insert into employee values(8,'ceshi',5000,1); // 新增数据成功 ~~~ 我们来分析以下原理:单查询num>=3的时候,在现有的employee表中满足条件的数据行,如下所示: | id | num | | --- | --- | | 3 | 3 | | 4 | 5 | | 5 | 6 | 那么在设计者的角度出发,我为了解决幻读的现象:在num>=3的条件下是必须加上间隙锁的。 而在小于num=3中,下一条数据行就是num=1了,为了防止在(1,3\]的范围中加入了num=3的数据行,所以也给这个间隙加上了锁,这就是添加num=2数据行出现等待的原因。 最后来说一说:**「使用不存在的检索条件是否会加上间隙锁?」** 假如是查询num>=8的数据行呢?因为employee表并不存在中num=8的数据行,num最大num=6,所以为了解决幻读(6,8\]与num>=8也会加上锁。 说到这里我相信很多人已经对间隙锁有了清晰和深入的认识,可以说是精通了,又可以和面试官互扯了。 假如你是第一次接触Mysql的锁机制,第一次肯定是懵的,建议多认真的看几遍,跟着案例敲一下自己深刻的去体会,慢慢的就懂了。 ## 死锁 死锁在InnoDB中才会出现死锁,MyISAM是不会出现死锁,因为MyISAM支持的是表锁,一次性获取了所有的锁,其它的线程只能排队等候。 而InnoDB默认支持行锁,获取锁是分步的,并不是一次性获取所有的锁,因此在锁竞争的时候就会出现死锁的情况。 虽然InnoDB会出现死锁,但是并不影响InnoDB成为最受欢迎的存储引擎,MyISAM可以理解为串行化操作,读写有序,因此支持的并发性能低下。 ### 死锁案例一 举一个例子,现在数据库表employee中六条数据,如下所示: ![](https://img.kancloud.cn/ab/fd/abfd86a8d66f726ab4d6f20e63ea2eff_1061x253.png) 其中name=ldc的有两条数据,并且name字段为普通索引,分别是id=2和id=3的数据行,现在假设有两个事务分别执行下面的两条sql语句: ~~~csharp // session1执行 update employee set num = 2 where name ='ldc'; // session2执行 select * from employee where id = 2 or id =3; ~~~ 其中session1执行的sql获取的数据行是两条数据,假设先获取到第一个id=2的数据行,然后cpu的时间分配给了另一个事务,另一个事务执行查询操作获取了第二行数据也就是id=3的数据行。 当事务2继续执行的时候获取到id=3的数据行,锁定了id=3的数据行,此时cpu又将时间分配给了第一个事务,第一个事务执行准备获取第二行数据的锁,发现已经被其他事务获取了,它就处于等待的状态。 当cpu把时间有分配给了第二个事务,第二个事务准备获取第一行数据的锁发现已经被第一个事务获取了锁,这样就行了死锁,两个事务彼此之间相互等待。 ### 死锁案例二 第二种死锁情况就是当一个事务开始并且update一条id=1的数据行时,成功获取到写锁,此时另一个事务执行也update另一条id=2的数据行时,也成功获取到写锁(id为主键)。 此时cpu将时间分配给了事务一,事务一接着也是update id=2的数据行,因为事务二已经获取到id=2数据行的锁,所以事务已处于等待状态。 事务二有获取到了时间,像执行update id=1的数据行,但是此时id=1的锁被事务一获取到了,事务二也处于等待的状态,因此形成了死锁。 | session1 | session2 | | --- | --- | | begin;update t set name='测试' where id=1; | begin | | update t set name='测试' where id=2; | | update t set name='测试' where id=2; | | 等待..... | update t set name='测试' where id=1; | | 等待..... | 等待...... | ### 死锁的解决方案 首先要解决死锁问题,在程序的设计上,当发现程序有高并发的访问某一个表时,尽量对该表的执行操作串行化,或者锁升级,一次性获取所有的锁资源。 然后也可以设置参数`innodb_lock_wait_timeout`,超时时间,并且将参数`innodb_deadlock_detect` 打开,当发现死锁的时候,自动回滚其中的某一个事务。 ## 总结 上面详细的介绍了MyISAM和InnoDB两种存储引擎的锁机制的实现,并进行了测试。 MyISAM的表锁分为两种模式:**「共享读锁」**和**「排它写锁」**。获取的读锁的线程对该数据行只能读,不能修改,其它线程也只能对该数据行加读锁。 获取到写锁的线程对该数据行既能读也能写,对其他线程对该数据行的读写具有排它性。 MyISAM中默认写优先于去操作,因此MyISAM一般不适合运用于大量读写操作的程序中。 InnoDB的行锁虽然会出现死锁的可能,但是InnoDB的支持的并发性能比MyISAM好,行锁的粒度最小,一定的方法和措施可以解决死锁的发生,极大的发挥InnoDB的性能。 InnoDB中引入了间隙锁的概念来决解出现幻读的问题,也引入事务的特性,通过事务的四种隔离级别,来降低锁冲突,提高并发性能。 作者:码农小光 链接:https://www.jianshu.com/p/3d4044f87fdb 来源:简书 著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。