ThinkPHP解决数据库连接超时中断_自动重连机制兼容方案
ThinkPHP默认不处理数据库连接中断,需主动应对。可通过查询前调用PDO的ping()检测连接,失败后执行reconnect()。更优方案是自定义Connection类,拦截查询异常,仅对HY000/2006/2013错误码且非事务内重连一次。根治需调整MySQL的wait_timeout、启用PDO的MYSQL_ATTR_KEEPALIVE及Linux
说到ThinkPHP,大家都知道它默认是不管数据库连接是否还活着的。一旦MySQL那边因为设置了wait_timeout或者网络抖了那么一下,连接断了,你后面的查询直接就给你个MySQL server has gone away的异常,框架是不会帮你自动重连的,它就那么直挺挺地给你报错。
这个问题在定时任务里特别常见,跑着跑着就崩了;还有就是那种低频接口,隔个十几二十分钟首次访问,大概率就撞上了。如果你用的是云数据库,比如阿里云RDS,有些托管环境甚至把wait_timeout设成了300秒,那简直是防不胜防。
这里有几个核心判断,可以作为你行动的出发点:
- 别指望框架自动恢复:ThinkPHP的
Connection类在执行查询前只检查连接是否“初始化过”,不会管这个连接是不是“还活着”。 - 必须主动干预:你要么在执行查询前用
ping探一下,要么在捕获到连接中断的异常后手动重连。 - 一个常见的误解:
mysql.ping这个配置项,它只是在初始化连接时发一次PING,不是运行时的保活机制,别搞混了。
最直接的急救方案:在查询前加ping
这招特别适合那些对延迟不敏感、但也别太高的业务场景。虽然不优雅,但能快速止血,让你先把问题解决了再说。
关键点其实就几个:
ping()是PDO扩展提供的,你通过getPdo()拿到原生PDO实例就能调用。- 它不发SQL,就是一个轻量级的握手验证。失败了就说明连接断了,这时候安全调用
reconnect()就行。 - 千万别在每个
Db::table()->where()->find()前面都加,性能损耗太大。建议只用在那些可能长时间闲置后的首次操作,比如命令行任务的开头,或者HTTP请求的入口。
举个命令行任务里的例子:
$connection = Db::getConnection();
if (!$connection->getPdo()->ping()) {
$connection->reconnect();
}
Db::table('user')->where('id', 1)->find(); // 这回就安全了
更优雅的方案:自定义Connection实现透明重试
如果你希望这个机制全局生效,又不想到处手动加ping,那就得动点真格的了。核心思路是拦截查询失败,判断错误码,然后重连并重试一次。
有几个需要特别注意的地方:
- 只重试非事务内的查询:事务中断后重连,状态会乱掉,直接放弃比较靠谱。
- 严格过滤错误码:只对
HY000+2006(MySQL server has gone away)或2013(Lost connection)才触发重连。 - 只重试一次:避免出现死循环。如果重连后还是失败,那就让它异常透出,把问题暴露给开发者。
这里给一个重写query方法的示例片段:
public function query($sql, $bind = [], $master = false, $pdo = null)
{
try {
return parent::query($sql, $bind, $master, $pdo);
} catch (\PDOException $e) {
if ($this->inTransaction()) {
throw $e;
}
if (in_array($e->getCode(), ['2006', '2013']) && strpos($e->getMessage(), 'MySQL server has gone away') !== false) {
$this->reconnect();
return parent::query($sql, $bind, $master, $pdo);
}
throw $e;
}
}
根治之道:从云环境和网络层下手
说句实在话,光靠PHP层面的重连,治标不治本。很多时候,超时是因为中间的网络设备,比如SLB、NAT网关,它们会自动把空闲的连接给干掉。这时候,就算PDO自己觉得还连着,你一发包,人家直接给你丢了。
所以必须从下往上,把配置对齐:
- MySQL侧:确认
wait_timeout和interactive_timeout的值。推荐设为600到1800秒,具体多少看你的业务场景。可以用SHOW VARIABLES LIKE '%timeout%'来核对。 - PHP PDO:在DSN里加
PDO::MYSQL_ATTR_KEEPALIVE => true。这才是真正启用TCP keepalive的配置。 - Linux内核:确保
/proc/sys/net/ipv4/tcp_keepalive_time的值小于MySQL的wait_timeout。否则连接在TCP层面就被断了,PDO根本来不及反应。
DSN示例(含keepalive):
mysql:host=127.0.0.1;port=3306;dbname=test;charset=utf8mb4;unix_socket=/tmp/mysql.sock
连接后立即启用:
$pdo = new \PDO($dsn, $user, $pass, [
\PDO::MYSQL_ATTR_KEEPALIVE => true,
]);
最麻烦的其实是混合场景:Swoole长连接池 + 云数据库 + 自动扩缩容。这个时候,判断连接是否有效就不能光靠ping了,得结合连接创建时间戳、上次使用时间,甚至是不是跨Worker共享的等上下文信息。这些细节,框架不会替你决定,只能靠你自己去封装了。


































