最近在跑一套系统时碰到一个头大的问题,laravel的队列任务(通过另一个原生系统读取数据库)在执行时,会出现数据库连接断开的问题,导致队列任务刚启动时可以正常运行,有一段时间没有执行再执行就会报错。这次解决问题过程中,又重新了解了一些以前模糊的概念,在这里记录一下。
[2022-04-15 21:40:18] local.ERROR: PDOStatement::execute(): MySQL server has gone away {"exception":"[object] (ErrorException(code: 0): PDOStatement::execute(): MySQL server has gone away at E:\\www\\***\\vendor\\catfan\\medoo\\src\\Medoo.php:375)
[2022-04-15 22:36:45] local.ERROR: Error while sending QUERY packet. PID=13928 {"exception":"[object] (ErrorException(code: 0): Error while sending QUERY packet. PID=13928 at E:\www\***\vendor\catfan\medoo\src\Medoo.php:375)
这种不定时的报错简直不能忍,网上的解决方案是设置延长mysql的等待超时时间。但是,这种解决方案治标不治本,因为系统访问量大的话,数据库连接长时间不断开,数据库的连资源可能会耗尽。
如果能在使用时判断,数据库连接是否可用,不可用就断开重连,则不需要修改数据库连接等待超时时间。于是去看最终执行的数据库类,了解执行顺序。
数据库执行代码结构(简化伪代码)
//最终执行数据库操作的类
class baseDB {
protected static $database;
public static function initialize(){
self::$database = new pdo(baseDBInfo);
}
public static function get($table, $columns = "*", $where = [], $join =[]){
return static::$database->get($table, $columns, $where);
}
}
//中间数据库类
class middleDB extends baseDB {
protected static $database;
public static function initialize(){
self::$database = new pdo(middleDBInfo);
}
public static function get($table, $columns = "*", $where = [], $join =[]){
return parent::get($table, $columns, $where, $join);
}
}
//终端数据库类,主要是调用不用的数据库初始化信息
class userDB extends middleDB {
protected static $database;
public static function initialize(){
self::$database = new pdo(userDBInfo);
}
}
//终端数据库类,主要是调用不用的数据库初始化信息
class orderDB extends middleDB {
protected static $database;
public static function initialize(){
self::$database = new pdo(orderDBInfo);
}
}
//实际调用的位置
class User{
public static function IssueAdminAccount($params){
userDB::get($table,$select_feild,$where);
}
}
这里 User 类查询信息时,最终执行的get方法是 baseDB::get() 用到的是 userDBInfo 数据库,这里用到的知识是:php后期静态绑定。
一、php后期静态绑定
PHP 增加了一个叫做后期静态绑定的功能,用于在继承范围内引用静态调用的类。
准确说,后期静态绑定工作原理是存储了在上一个“非转发调用”(non-forwarding call)的类名。当进行静态方法调用时,该类名即为明确指定的那个(通常在 ::
运算符左侧部分);当进行非静态方法调用时,即为该对象所属的类。所谓的“转发调用”(forwarding call)指的是通过以下几种方式进行的静态调用:self::
,parent::
,static::
以及 forward_static_call()。可用 get_called_class() 函数来得到被调用的方法所在的类名,static::
则指出了其范围。
该功能从语言内部角度考虑被命名为“后期静态绑定”。“后期绑定”的意思是说,static::
不再被解析为定义当前方法所在的类,而是在实际运行时计算的。也可以称之为“静态绑定”,因为它可以用于(但不限于)静态方法的调用。
self::
的限制
使用 self::
或者 __CLASS__
对当前类的静态引用,取决于定义当前方法所在的类:
示例 #1 self::
用法
<?php
class A {
public static function who() {
echo __CLASS__;
}
public static function test() {
self::who();
}
}
class B extends A {
public static function who() {
echo __CLASS__;
}
}
B::test();
?>
以上例程会输出:
A
后期静态绑定的用法
后期静态绑定本想通过引入一个新的关键字表示运行时最初调用的类来绕过限制。简单地说,这个关键字能在上述例子中调用 test()
时引用的类是 B
而不是 A
。最终决定不引入新的关键字,而是使用已经预留的 static
关键字。
示例 #2 static::
简单用法
<?php
class A {
public static function who() {
echo __CLASS__;
}
public static function test() {
static::who(); // 后期静态绑定从这里开始
}
}
class B extends A {
public static function who() {
echo __CLASS__;
}
}
B::test();
?>
以上例程会输出:
B
注意:
在非静态环境下,所调用的类即为该对象实例所属的类。由于
$this->
会在同一作用范围内尝试调用私有方法,而static::
则可能给出不同结果。另一个区别是static::
只能用于静态属性。
示例 #3 非静态环境下使用 static::
<?php
class A {
private function foo() {
echo "success!\n";
}
public function test() {
$this->foo();
static::foo();
}
}
class B extends A {
/* foo() 将复制给 B,因此它的作用域将是 A 并调用成功 */
}
class C extends A {
private function foo() {
/* 替换原来的方法;新的作用域是 C */
}
}
$b = new B();
$b->test();
$c = new C();
$c->test(); //fails
?>
以上例程会输出:
success! success! success! Fatal error: Call to private method C::foo() from context 'A' in /tmp/test.php on line 9
注意:
后期静态绑定的解析会一直到取得一个完全解析了的静态调用为止。另一方面,如果静态调用使用 parent::
或者 self::
将转发调用信息。
示例 #4 转发和非转发调用
<?php
class A {
public static function foo() {
static::who();
}
public static function who() {
echo __CLASS__."\n";
}
}
class B extends A {
public static function test() {
A::foo();
parent::foo();
self::foo();
}
public static function who() {
echo __CLASS__."\n";
}
}
class C extends B {
public static function who() {
echo __CLASS__."\n";
}
}
C::test();
?>
以上例程会输出:
A C C
二、 魔术方法 __callStatic()
本来想着将 class userDB不再继承 class middleDB 类,然后再 class userDB 中添加一个__callStatic()方法,在__callStatic()方法中执行数据库连接是否可用的判断并重新创建数据库连接,这样调用 class userDB 的各种操作就能实现断线重连。
public static function __callStatic($method, $args) {
Log(self::$database,'database');
$databaseInfo = self::$database->info();
Log('******************* userdatabase-callStatic-null-befo**************','database');
Log(get_called_class(),'database');
Log($databaseInfo,'database');
if (!$databaseInfo || !$databaseInfo['server']){
self::initialize();
$databaseInfo = self::$database->info();
Log('******************* userdatabase-callStatic-restart**************','database');
Log($databaseInfo,'database');
}
Log('----触发了callStatic-----','database');
Log(self::$database,'database');
Log($method,'database');
Log($args,'database');
Log('----这里是userDatabase的get-----','database');
return forward_static_call_array([__NAMESPACE__ .'\Database', $method], $args);
}
这里通过forward_static_call_array()调用 class middleDB::get()方法,可以重载相关静态方法。但是 class userDB 不继承 class middleDB ,最终 class baseDB::get()中调用的数据库 middleDB 中的数据库信息。这里就形成了死循环,这个方案也不给力。
三、在最终执行数据库操作的类中添加判断
在class baseDB类中增加一个判断方法,然后在
//最终执行数据库操作的类
class baseDB {
protected static $database;
public static function initialize(){
self::$database = new pdo(baseDBInfo);
}
/**
* 判断是否数据库链接是否断开
* @return void
*/
private static function pdoIsReconnect(){
$databaseInfo = static::getDatabaseInfo();
if (!$databaseInfo || !$databaseInfo['server']){
static::initialize();
$databaseInfo = static::getDatabaseInfo();
Log('******************* database-restart**************','database');
Log($databaseInfo,'database');
}
}
public static function get($table, $columns = "*", $where = [], $join =[]){
static::pdoIsReconnect();
return static::$database->get($table, $columns, $where);
}
}
参考资料
写的有点乱,只能自己看了。
1.后期静态绑定:https://www.php.net/manual/zh/language.oop5.late-static-bindings.php
2.PHP后期静态绑定分析与应用:https://www.php.cn/blog/detail/23541.html
3.PDO之MySql持久化自动重连导致内存溢出:http://t.zoukankan.com/liuyublog-p-11585865.html
原创文章,作者:Zeyu,如若转载,请注明出处:https://jinzhijun.cn/develop/1058