关于数据库重连相关解决方案一二

by: lumen 陆贤芳 2020-06-09

保护私人版权，尊重他人版权。转载请注明出处并附带页面链接

常驻内存的PHP程序mysql报错　mysql has gone away

背景

在lumen/laravel项目中使用hprose rpc，当长时间不请求rpc接口，再重新请求会报错 “mysql has gone away”，目前我们使用的orm有两种一个是pairs orm，一个是eloquent orm,两个orm对于重连的表示有所区别，pairs orm经过我们自己修改后支持了重连，eloquent orm查看源码后表明是支持重连的，但是依然看到 “mysql has gone away”报错，会导致没有正确返回结果。

分析原因

在cli环境下，PHP程序需要长时间运行，客户端与MySQL服务器之间的TCP连接是不稳定的。
不稳定的原因有以下可能：

MySQL-Server会在一定时间内自动切断连接
PHP程序遇到空闲期时长时间没有MySQL查询，MySQL-Server也会切断连接回收资源
在MySQL服务器中执行kill process杀掉某个连接
MySQL服务器重启
网络抖动

这时PHP程序中的MySQL连接就失效了。如果仍然执行mysql_query，就会报一个“MySQL server has gone away”的错误。程序处理不到就直接遇到致命错误并退出了。所以PHP程序中需要断线重连。

如果有不支持重连，解决方案如下

mysql_ping

有很多人提出了mysql_ping的方案，每次mysql_query进行连接检测或者定时连接检测。这个方案不是最好的。原因是:
mysql_ping需要主动侦测连接，带来了额外的消耗
定时执行mysql_ping不能解决问题，如刚刚执行过mysql_ping检测之后，连接就关闭了;

捕获错误码，进行断线重连

它的原理是：mysql_query执行后检测返回值
如果mysql_query返回失败，检测错误码发现为2006/2013（这2个错误表示连接失败），再执行一次mysql_connect
执行mysql_connect后，重新执行mysql_query
如果mysql_query返回成功，那么连接是有效的，这是一次正常的调用
众多知名的PHP常驻进程框架均采用第二种方案
例如：
swoole_framework中query方法
workerman中数据库连接类execute方法
很明显第二种方式是高可靠低消耗的方案，推荐大家在常驻环境里使用

使用的hprose 2.0的包

里面是自己做的错误捕获，已经被上层捕获的错误也会被hprose获取，所以自己下载下来并修改 src/Hprose/Service.php这个文件的下面的方法

 public function errorHandler($errno, $errstr, $errfile, $errline) {
        if (self::$trackError) {
            if (error_reporting() !== 0 && $errstr != 'PDO::prepare(): MySQL server has gone away') {
                self::$lastError = new ErrorException($errstr, 0, $errno, $errfile, $errline);
            }
        }
        else if (self::$lastErrorHandler){
            call_user_func(self::$lastErrorHandler, $errno, $errstr, $errfile, $errline);
        }
    }
//这个函数增加了
//&& $errstr != 'PDO::prepare(): MySQL server has gone away' 这段代码，处理当mysql的错误被传递到这里的时候。

pairs orm修改

//在idiorm.php增加下面方法
    /*
     * Reconnect DB
     */
    public static function reconnect_db($connection_name)
    {
        self::close_db($connection_name);
        self::connect_db($connection_name);
    }
//修改下面方法
    protected static function _execute($query, $parameters = array(), $connection_name = self::DEFAULT_CONNECTION, $retryTimes = 0)
    {
        try {
            $statement = self::get_db($connection_name);
            $statement = $statement->prepare($query);
            self::$_last_statement = $statement;
            $time = microtime(true);

            foreach ($parameters as $key => &$param) {
                if (is_null($param)) {
                    $type = PDO::PARAM_NULL;
                } elseif (is_bool($param)) {
                    $type = PDO::PARAM_BOOL;
                } elseif (is_int($param)) {
                    $type = PDO::PARAM_INT;
                } else {
                    $type = PDO::PARAM_STR;
                }
                $statement->bindParam(is_int($key) ? ++$key : $key, $param, $type);
            }

            $q = $statement->execute();
        } catch (PDOException $e) {
            /*
             * When execute return false, it need to check errorCode, if mysql has gone away reconnect.
             */
            $err_code = $statement->errorInfo()[1] ?? 0;
            $err_msg = $statement->errorInfo()[2] ?? '';

            $driver_name = self::get_db($connection_name)->getAttribute(PDO::ATTR_DRIVER_NAME);

            \Log::info('jidiorm error:', ['code' => $err_code, 'message' => $err_msg, 'driverName' => $driver_name]);
            if (($err_code == 2006 || $err_code == 2013) && $retryTimes == 0 && $driver_name == 'mysql') {
                self::reconnect_db($connection_name);
                self::_execute($query, $parameters, $connection_name, 1);
            } else {
                throw $e;
            }
        }

        self::_log_query($query, $parameters, $connection_name, (microtime(true) - $time));

        return $q;
    }

常驻内存的PHP程序mysql报错 mysql has gone away

背景