一个Kill不掉的MySQL会话

作者：秦广飞

爱可生 DBA 团队成员，负责项目日常问题处理及公司平台问题排查，对数据库有兴趣，对技术有想法。一入 IT 深似海，从此节操是路人。

本文来源：爱可生开源社区

1背景

照例要先讲下本文档背景的，不过在介绍背景之前，先简单说下 MySQL 主从切换的过程。

正常来说，当要发生主从切换时，主库要做下面几个动作：

断开流量入口（解绑 VIP）

设置只读

Kill 掉数据库残留连接

而从库，要做下面几个动作：

补全与主库差异的 binlog 日志

关闭只读

清除复制信息

开启流量入口（绑定 VIP）

我们公司自研的数据库集群管理平台 云树 DMP[1] 大概也是这么个切换过程，而这个切换过程跟本文的关联点，就在主库 Kill 掉残留连接上。

偶然间发现，DMP 在切换过程中 Kill 残留连接时，日志中有时会出现 warn 信息：[warn] kill process warning：Error 1094：Unknown thread id：4

后来观察到，MySQL 5.7 的主从切换时，就不会出现这个 warning 信息，而 MySQL 8.0 就会稳定复现。进一步测试验证后，终于发现了这个 Unknown thread id 的真面目，就是 USER 为 event_scheduler 的这个"连接"。

2什么是 event_scheduler？

event_scheduler 到底是什么呢？毕竟从 processlist 信息中可以看到，它与普通的会话似乎不太一样。

其实它是 MySQL 中的一个特殊线程，主要负责执行 MySQL 事件调度器所创建的事件。我们知道 MySQL 是有 event 的，可以像 Linux 中 crontab 一样，定时执行一些任务。

The MySQL Event Scheduler manages the scheduling and execution of events, that is, tasks that run according to a schedule

当 MySQL 事件调度器启用时 event_scheduler=ON，MySQL 就会在后台启动一个 event_scheduler 线程，并且 event_scheduler 线程将一直运行，直到 MySQL 服务停止。该线程会负责检查当前时间和已定义的事件，如果事件需要执行，则 event_scheduler 线程将启动一个新的会话来执行事件。

需要注意的是，在 MySQL 5.7中，event_scheduler 默认是关闭的，而 MySQL 8.0 中则默认打开了，而这也就是为什么在 MySQL 5.7 的切换过程中没有发现 warning 信息的原因。

3为什么 Kill 不掉？

了解 event_scheduler 大概是什么之后，我们再来看看，为什么 Kill 时，会报 Unknown thread id。

注意看 processlist 信息，我们发现 event_scheduler 的 COMMAND 值为 Daemon。从字面意思上看，Daemon 为后台守护的意思，其实在 MySQL 中，当在后台运行一些特殊的功能时，会话 COMMAND 可能被标记为 Daemon（实际工作场景中，只注意到过 event_scheduler）。

因为这类会话并不是由用户直接发起的连接，而是 MySQL 内部的线程，所以无法像普通会话一样被 Kill 掉。

官方文档中，给出的信息较少，大家有兴趣的可以自己翻下代码。

4如何使用定时任务？

具体如何使用定时任务，其实网上也有很多资料，如果真有需要使用的，建议最好参考官方文档。下面我们简单使用下 event 看看效果。

启用/关闭/禁用

--修改变量event_scheduler来动态启用或者关闭event
mysql>showvariableslike'%event_scheduler%';
+-----------------+-------+
|Variable_name|Value|
+-----------------+-------+
|event_scheduler|ON|
+-----------------+-------+
1rowinset(0.00sec)

mysql>

--关闭
mysql>SETGLOBALevent_scheduler=0;

--启用
mysql>SETGLOBALevent_scheduler=1;

--禁用event_scheduler，只能在配置文件中设置event_scheduler为disable并重启服务，而不能动态修改
[mysqld]
event_scheduler=DISABLED

创建

--准备测试表和数据
mysql>CREATETABLElogs(idINT(11)primarykeyAUTO_INCREMENT,log_messageVARCHAR(255)NOTNULL,log_timeTIMESTAMPNOTNULL);
QueryOK,0rowsaffected,1warning(0.02sec)

mysql>INSERTINTOlogs(log_message,log_time)VALUES
->('君不见黄河之水天上来，奔流到海不复回','2023-06-070900'),
->('君不见高堂明镜悲白发，朝如青丝暮成雪','2023-06-072300'),
->('人生得意须尽欢，莫使金樽空对月','2023-06-080100'),
->('天生我材必有用，千金散尽还复来','2023-06-081800'),
->('烹羊宰牛且为乐，会须一饮三百杯','2023-06-092300'),
->('钟鼓馔玉不足贵，但愿长醉不复醒','2023-06-091100'),
->('古来圣贤皆寂寞，惟有饮者留其名','2023-06-102300'),
->('陈王昔时宴平乐，斗酒十千恣欢谑','2023-06-110100'),
->('主人何为言少钱，径须沽取对君酌','2023-06-121800'),
->('五花马、千金裘','2023-06-132300'),
->('呼儿将出换美酒，与尔同销万古愁','2023-06-141100');
QueryOK,11rowsaffected(0.01sec)
Records:11Duplicates:0Warnings:0

mysql>

--创建event，实现定时将该日志表中7天之前的数据删除
--为了快速看到效果，我们每分钟执行一次，一次删除1行
mysql>CREATEEVENTdelete_logs_event
->ONSCHEDULEEVERY1MINUTESTARTS'2023-06-190000'
->DO
->DELETEFROMlogs
->WHERElog_time< DATE_SUB(NOW(), INTERVAL 7 DAY) limit 1;
Query OK, 0 rows affected (0.01 sec)

查看

--执行showevents查看，需要先进到event所在的schema
mysql>useuniverse
mysql>showeventsG
***************************1.row***************************
Db:universe
Name:delete_logs_event
Definer:root@localhost
Timezone:SYSTEM
Type:RECURRING
Executeat:NULL
Intervalvalue:1
Intervalfield:MINUTE
Starts:2023-06-190000
Ends:NULL
Status:ENABLED
Originator:1862993913
character_set_client:utf8mb4
collation_connection:utf8mb4_0900_ai_ci
DatabaseCollation:utf8mb4_bin
1rowinset(0.00sec)

mysql>

--通过information_schema.events可以看到更详细的信息
mysql>select*frominformation_schema.eventsG
***************************1.row***************************
EVENT_CATALOG:def
EVENT_SCHEMA:universe
EVENT_NAME:delete_logs_event
DEFINER:root@localhost
TIME_ZONE:SYSTEM
EVENT_BODY:SQL
EVENT_DEFINITION:DELETEFROMlogs
WHERElog_time< DATE_SUB(NOW(), INTERVAL 7 DAY) limit 1
          EVENT_TYPE: RECURRING
          EXECUTE_AT: NULL
      INTERVAL_VALUE: 1
      INTERVAL_FIELD: MINUTE
            SQL_MODE: ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
              STARTS: 2023-06-19 0000
                ENDS: NULL
              STATUS: ENABLED
       ON_COMPLETION: NOT PRESERVE
             CREATED: 2023-06-18 2323
        LAST_ALTERED: 2023-06-18 2323
       LAST_EXECUTED: 2023-06-19 0000
       EVENT_COMMENT: 
          ORIGINATOR: 1862993913
CHARACTER_SET_CLIENT: utf8mb4
COLLATION_CONNECTION: utf8mb4_0900_ai_ci
  DATABASE_COLLATION: utf8mb4_bin
1 row in set (0.00 sec)

mysql>

--查看表中是否被定时删除
mysql>select*fromlogs;
+----+--------------------------------------------------------+---------------------+
|id|log_message|log_time|
+----+--------------------------------------------------------+---------------------+
|2|君不见高堂明镜悲白发，朝如青丝暮成雪|2023-06-072300|
|3|人生得意须尽欢，莫使金樽空对月|2023-06-080100|
|4|天生我材必有用，千金散尽还复来|2023-06-081800|
|5|烹羊宰牛且为乐，会须一饮三百杯|2023-06-092300|
|6|钟鼓馔玉不足贵，但愿长醉不复醒|2023-06-091100|
|7|古来圣贤皆寂寞，惟有饮者留其名|2023-06-102300|
|8|陈王昔时宴平乐，斗酒十千恣欢谑|2023-06-110100|
|9|主人何为言少钱，径须沽取对君酌|2023-06-121800|
|10|五花马、千金裘|2023-06-132300|
|11|呼儿将出换美酒，与尔同销万古愁|2023-06-141100|
+----+--------------------------------------------------------+---------------------+
10rowsinset(0.00sec)

mysql>

--查看showprocesslist中event_scheduler的信息，可以看到stats为Waitingfornextactivation
mysql>select*frominformation_schema.processlistwhereuser='event_scheduler';
+-------+-----------------+-----------+------+---------+------+-----------------------------+------+
|ID|USER|HOST|DB|COMMAND|TIME|STATE|INFO|
+-------+-----------------+-----------+------+---------+------+-----------------------------+------+
|12869|event_scheduler|localhost|NULL|Daemon|58|Waitingfornextactivation|NULL|
+-------+-----------------+-----------+------+---------+------+-----------------------------+------+
1rowinset(0.00sec)

mysql>

--我们在从库上看下event的信息，可以看到STATUS为SLAVESIDE_DISABLED，因此不用担心从库重复执行event
mysql>select*frominformation_schema.eventsG
***************************1.row***************************
EVENT_CATALOG:def
EVENT_SCHEMA:universe
EVENT_NAME:delete_logs_event
DEFINER:root@localhost
TIME_ZONE:SYSTEM
EVENT_BODY:SQL
EVENT_DEFINITION:DELETEFROMlogs
WHERElog_time< DATE_SUB(NOW(), INTERVAL 7 DAY) limit 1
          EVENT_TYPE: RECURRING
          EXECUTE_AT: NULL
      INTERVAL_VALUE: 1
      INTERVAL_FIELD: MINUTE
            SQL_MODE: ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
              STARTS: 2023-06-19 0000
                ENDS: NULL
              STATUS: SLAVESIDE_DISABLED
       ON_COMPLETION: NOT PRESERVE
             CREATED: 2023-06-18 2323
        LAST_ALTERED: 2023-06-18 2323
       LAST_EXECUTED: NULL
       EVENT_COMMENT: 
          ORIGINATOR: 1862993913
CHARACTER_SET_CLIENT: utf8mb4
COLLATION_CONNECTION: utf8mb4_0900_ai_ci
  DATABASE_COLLATION: utf8mb4_bin
1 row in set (0.00 sec) 

修改

--使用ALTER语句修改，其他高权限用户也可以执行，且event的用户会变成最后一个ALTER的用户
mysql>ALTEREVENTdelete_logs_event
->ONSCHEDULEEVERY1DAYSTARTS'2023-06-190000'
->DO
->DELETEFROMlogs
->WHERElog_time< DATE_SUB(NOW(), INTERVAL 7 DAY);
Query OK, 0 rows affected (0.01 sec)

mysql>

--可以看到DEFINER已经变成了修改的用户，且时间间隔也修改为了1天，DELETE语句也去掉了LIMIT
mysql>select*frominformation_schema.eventsG
***************************1.row***************************
EVENT_CATALOG:def
EVENT_SCHEMA:universe
EVENT_NAME:delete_logs_event
DEFINER:qin@%
TIME_ZONE:SYSTEM
EVENT_BODY:SQL
EVENT_DEFINITION:DELETEFROMlogs
WHERElog_time< DATE_SUB(NOW(), INTERVAL 7 DAY)
          EVENT_TYPE: RECURRING
          EXECUTE_AT: NULL
      INTERVAL_VALUE: 1
      INTERVAL_FIELD: DAY
            SQL_MODE: ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION
              STARTS: 2023-06-19 0000
                ENDS: NULL
              STATUS: ENABLED
       ON_COMPLETION: NOT PRESERVE
             CREATED: 2023-06-18 2323
        LAST_ALTERED: 2023-06-19 0003
       LAST_EXECUTED: 2023-06-19 0000
       EVENT_COMMENT: 
          ORIGINATOR: 1862993913
CHARACTER_SET_CLIENT: utf8mb4
COLLATION_CONNECTION: utf8mb4_0900_ai_ci
  DATABASE_COLLATION: utf8mb4_bin
1 row in set (0.00 sec)

删除

mysql>dropeventdelete_logs_event;
QueryOK,0rowsaffected(0.01sec)

mysql>showeventsG
Emptyset(0.00sec)

切换时注意

当在主库上创建了 event，之后发生了主从切换。此时 event 并不会随着切换而变成在新主上执行，且状态也不会发生改变。

即原主 event 的状态还是 ENABLED，而新主 event 的状态还是 DISABLED。

5总结

show processlist 中看到的 User 为 event_scheduler 的会话为 MySQL 内部线程，无法被 Kill 掉。

在主库上创建的 event，定时执行的 SQL 语句，在从库上会正常随着复制回放，但不会被重复执行。

主从切换后，原主上的 event 不会在新主上执行。

审核编辑：汤梓红