小编给大家分享一下MySQL怎么一个杀掉数据库空闲事务,希望大家阅读完这篇文章之后都有所收获、下面让我们一起去探讨吧!
我们经常遇到一个情况,就是网络断开或程序错误导致提交/回滚语句没有传到数据库,也没有释放线程,但是线上事务锁定等待严重,连接数暴涨,尤其在测试库这种情况很多,线上也偶有发生,于是想为MySQL增加一个杀掉空闲事务的功能。下面小编来讲解下MySQ如何一个杀掉数据库空闲事务吗?
MySQ如何一个杀掉数据库空闲事务
通过MySQL服务器层有很多不确定因素,最保险还是在存储引擎层实现,我们用的几乎都是InnoDB/XtraDB,所以就基于Percona来修改了,甲骨文版的MySQL也可以照着修改。
需求:
1。一个事务启动,如果事务内最后一个语句执行完超过一个时间(innodb_idle_trx_timeout),就应该关闭链接。
2。如果事务是纯读事务,因为不加锁,所以无害,不需要关闭,保持即可。
虽然这个思路被Percona的指出Alexey Kopytov可能存在“即使SELECT查询默认不会将行锁(也有例外),他们仍然可以阻止undo日志记录被清除。”的问题,但是我们确实有场景选择是绝对不能杀死的,除非之后的插入/更新/删除发生了,所以我根据我们的业务特点来修改。
跟Percona的Yasufumi木下光男和阿列克谢Kopytov提出过纯选择事务不应被杀死,但通过一个参数控制的方案还没有被Alexey Kopytov接受,作为通用处理我提出了用两个变量分别控制纯读事务的空闲超时时间和有锁事务的空闲超时时间,还在等待Percona的回复,因为这个方案还在测试,就先不开放修改了,当然如果你很熟悉MYSQL源码,我提出这个思路你肯定知道怎么分成这两个参数控制了。
根据这两个需求我们来设计方法,首先想到这个功能肯定是放在主线程最InnoDB方便,掌握线程每秒调度一次,可以顺便检查空闲事务,然后关闭,因为在事务中操作trx→mysql_thd并不安全,所以一般来说最好在InnoDB层换成线程ID操作,并且InnoDB中除了ha_innodb。cc,其他地方不能饮用近似,所以掌握线程中需要的线程数值,都需要在ha_innodb中计算好传递整型或布尔型返回值给主线程调用。
首先,我们要增加一个参数:idle_trx_timeout,它表示事务多久没有下一条语句发生就超时关闭。
在存储/innodb_plugin/电脑/srv0srv。c的“/* */插件选项”注释下增加如下代码注册idle_trx_timeout变量。
如果srv_idle_trx_timeout,,trx_sys) {
trx_t * trx;
time_t;
rescan_idle:
现在=(NULL);
mutex_enter(及kernel_mutex);
trx=UT_LIST_GET_FIRST (trx_sys→mysql_trx_list);#从当前事务列表里获取第一个事务
,(硫氧还蛋白){#依次循环每个事务进行检查
如果trx→conc_state==TRX_ACTIVE
,,trx→mysql_thd
,,innobase_thd_is_idle (trx→mysql_thd)){#如果事务还活着并且它的状态时空闲的
ib_int64_t start_time=innobase_thd_get_start_time (trx→mysql_thd);#获取线程最后一个语句的开始时间
ulong thd_id=innobase_thd_get_thread_id (trx→mysql_thd);#获取线程ID,因为存储引擎内直接操作近似不安全
如果(trx→last_stmt_start !=start_time){#如果事务最后语句起始时间不等于线程最后语句起始时间说明事务是新起的
trx→idle_start=现在;#更新事务的空闲起始时间
trx→last_stmt_start=start_time;#更新事务的最后语句起始时间
} else if (difftime(现在,trx→idle_start) #如果事务不是新起的,已经执行了一部分则判断空闲时间有多长了
比;srv_idle_trx_timeout){#如果空闲时间超过阈值则杀掉链接
/*杀死会话*/
mutex_exit(及kernel_mutex);
thd_kill (thd_id);#杀链接
goto rescan_idle;
}
}
trx=UT_LIST_GET_NEXT (mysql_trx_list,硫氧还蛋白);#检查下一个事务
}
mutex_exit(及kernel_mutex);}
代码往下找在innobase_system_variables结构体内加上:
MySQ如何一个杀掉数据库空闲事务
如果srv_idle_trx_timeout,,trx_sys) {
trx_t * trx;
time_t;
rescan_idle:
现在=(NULL);
mutex_enter(及kernel_mutex);
trx=UT_LIST_GET_FIRST (trx_sys→mysql_trx_list);#从当前事务列表里获取第一个事务
,(硫氧还蛋白){#依次循环每个事务进行检查
如果trx→conc_state==TRX_ACTIVE
,,trx→mysql_thd
,,innobase_thd_is_idle (trx→mysql_thd)){#如果事务还活着并且它的状态时空闲的
ib_int64_t start_time=innobase_thd_get_start_time (trx→mysql_thd);#获取线程最后一个语句的开始时间
