mysql日常锁表之flush_tables详解

海婉然 · 发表于 2024-11-14 18:13:20

1. Flush tables简介
2. Flush tables的影响
- 2.1 Flush tables
- 2.2 Flush tables with read lock
3. 一致性备份的问题
- 解决
总结

1. Flush tables简介

官方手册中关于Flush tables的介绍

Closes all open tables, forces all tables in use to be closed, and flushes the query cache.
FLUSH TABLES also removes all query results from the query cache, like the RESET QUERY CACHE statement.

复制代码

其解析就是关闭所有已打开的表对象，同时将查询缓存中的结果清空。就是说Flush tables的一个效果就是会等待所有正在运行的SQL请求结束。
因为，语句在执行前，都会打开相应的表对象，如select * from t1语句，会找到t1表的frm文件，并打开表内存对象。
为了控制表对象使用的内存空间和其他资源，MySQL会隐式（后台表对象管理线程）或显式（flush tables等）来关闭已打开但并没有使用的表对象。
然而，正在使用的表对象是不能关闭的（如SQL请求仍在运行），因此，Flush Tables操作会被正在运行的SQL请求阻塞。

2. Flush tables的影响

2.1 Flush tables

由于Flush tables会等待所有正在运行的SQL请求，那么，该操作会阻塞其他会话吗？
下面，我们通过一个例子来说明。

会话1：

Select sleep(50) from t1 limit 1;
--阻塞，执行时间是50s
+-----------+
| sleep(50) |
+-----------+
| 0 |
+-----------+
1 row in set (50.13 sec)

复制代码

会话2：

Flush tables;
--阻塞，直到会话1结束
Query OK, 0 rows affected (48.27 sec)

复制代码

会话3：

Select c1 from t1 limit 1;
--阻塞，直到会话1和会话2结束
+------+
| c1 |
+------+
| 1 |
+------+
1 row in set (47.23 sec)

复制代码

会话4：

Select c1 from t2 limit 1;
--无阻塞
+------+
| c1 |
+------+
| 1 |
+------+
1 row in set (0.00 sec)

复制代码

执行4个会话的并发测试，并且4会话语句依次执行。

1 会话1通过sleep(50)构造一个执行时间为50秒的SQL请求，操作表是t1
2 会话2执行flush tables
3 会话3同样对t1执行一个普通查询
4 会话4对t2执行一个普通查询

由测试现象知，会话4无阻塞，会话2和会话3等待会话1的完成，因此，
1）flush tables会等待正在运行的所有语句执行结束，即使运行的是查询请求；
2）如果flush tables等待SQL请求操作的表集合为{tables}，这里的tables组合应该是当前正在有sql在运行的，已经打开的表，同一个库中，没有sql运行的表是不计算在内，因此若库star中有3张表，tx1和tx2被打开了，，的若有新请求操作{tables}中的任意一表，这些请求都会阻塞（即使是普通查询），如会话3；
3）如果其他会话新请求操作{tables}外的其他表，不会被阻塞，如会话4。
从此可知，flush tables操作可认为是{tables}所有表的表级排他锁，会阻塞其他会话关于{tables}表上的所有操作。假设一个大查询或长事务过程中（如会话1）执行flush tables操作，那么flush tables会等待长事务的结束（如会话1），同时阻塞关于{tables}的新请求。

2.2 Flush tables with read lock

Flush tables with read lock是另一个常见的操作，与Flush tables的作用是一样的，同样会等待所有正在运行的SQL请求结束，只是增加了一个全局读锁，即阻塞所有库所有表的写操作，直到unlock tables操作完成。
通过一个例子来说明它们的区别：

会话1：

Select sleep(50) from t1 limit 1;
--阻塞，执行时间是50s
+-----------+
| sleep(50) |
+-----------+
| 0 |
+-----------+
1 row in set (50.13 sec)

复制代码

会话2：

Flush tables with read lock;
--阻塞，直到会话1结束
Query OK, 0 rows affected (48.27 sec)
Unlock tables;
Query OK, 0 rows affected (0.01 sec)

复制代码

会话3：

Select c1 from t1 limit 1;
--阻塞，直到会话1和会话2结束
+------+
| c1 |
+------+
| 1 |
+------+
1 row in set (47.23 sec)

复制代码

会话4：

Select c1 from t2 limit 1;
--无阻塞
+------+
| c1 |
+------+
| 1 |
+------+
1 row in set (0.00 sec)

复制代码

会话5：

Insert into t2(c1) values(10);
--阻塞，直到会话2中执行unlock tables
Query OK, 1 row affected (50.23 sec)

复制代码

与第一个例子类似，依次执行多个会话。不同的是会话2执行Flush tables with read lock，同时增加会话5对t2表插入记录。
由测试现象知，该操作有以下特点：
1）与flush tables一样，flush tables with read lock会等待正在运行的所有语句执行结束（如会话1）；
2）如果flush tables with read lock等待SQL请求操作的表集合为{tables}，若有新请求操作{tables}中的任意一表，这些请求都会阻塞

a) 如果是查询请求，在flush tables with read lock结束后就可执行，如会话3;
b) 如果是插入、更新等写请求，必须等待unlock tables释放读锁，跟会话5类似
3) 如果其他会话新请求操作{tables}外的其他表，则
a) 如果是查询请求，不会被阻塞，如会话4;
b) 如果是写请求，必须等待unlock tables释放读锁，如会话5

因此，flush tables with read lock操作是{tables}所有表的表级排他锁，同时是库级读锁，会阻塞库上所有写操作，直到执行unlock tables。其影响面比flush tables更大。
也就是比flush tables多一点影响，阻塞了｛tables}之外的表的写操作，不影响其读操作，只有unlock tables之后，释放了这个对库的全局读锁之后，才可以写

3. 一致性备份的问题

一般情况下，很少会主动使用flush tables和flush tables with read lock操作。
更多使用这两个命令是mysqldump进行数据备份的时候。
如果使用mysqldump进行一致性备份时，一般指定了--master-data和--single-transaction这两个参数，那么在备份操作执行前，先执行flush tables和flush tables with read lock这两个命令，以获得此一致性读的binlog位置。
获得binlog位置的过程为：

1) flush tables操作是等待正在运行的所有操作结束;
2) flush tables with read locks是为了加库级全局读锁，禁止写操作;
3) 通过show master status获得此时binlog位置;
4) unlock tables释放全局读锁，允许写请求。

先执行flush tables而不是直接执行flush tables with read locks的原因是，flush tables阻塞其他请求的可能性更少。假设flush tables的过程中出现大查询，从前面的分析知道，仅影响其他会话关于{tables}表的请求，而不像flush tables with read locks会阻塞所有写操作。
然而，以上操作只是大大减少了全局读锁的影响范围，如果在flush tables和flush tables with read locks之间出现大事务，还是有可能会出现所有写操作hang住的情况。因此，必须谨慎使用一致性备份的功能。
另外，经测试，如果出现flush tables阻塞其他会话的情况，如会话3、会话5的操作，是不会记录慢查询日志的，但事实上，应用程序可能是得不到迅速的响应了。

解决

1：show open tables where in_use >=1;
2：找到阻塞该表的查询语句

SELECT * FROM information_schema.`PROCESSLIST`
WHERE info IS NOT NULL
AND state NOT LIKE 'Waiting for table flush'
AND info NOT LIKE 'SELECT * FROM information_schema.`PROCESSLIST`%'
AND INFO LIKE '%处于打开状态的表名%'
ORDER BY TIME DESC

复制代码

3：kill id 杀死该sql进程
备注：还可以杀死flush tables的进程，该操作慎用，可能在执行一致性备份

SELECT * FROM information_schema.`PROCESSLIST`
WHERE info LIKE '%flush tables%'
AND info NOT LIKE 'SELECT * FROM information_schema.`PROCESSLIST`%'

复制代码

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持晓枫资讯。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

袁丝萝 · 发表于 2025-2-26 18:21:01

路过，支持一下

勤和 · 发表于 2025-10-16 07:21:57

感谢楼主分享。

朱建平1 · 发表于 3 天前

感谢楼主，顶。

		自动登录	找回密码
密码			立即注册