gearman中worker常驻后台,导致MySQL server has gone away的解决方法
这篇文章主要介绍了gearman中worker常驻后台,导致MySQL server has gone away的解决方法,较为详细的分析了造成MySQL server has gone away的原因与相关的解决方法,需要的朋友可以参考下
本文实例讲述了gearman中worker常驻后台,导致MySQL server has gone away的解决方法。分享给大家供大家参考,具体如下:
产生这个原因主要有如下几点:
1 2 3 4 5 | 1、mysql服务宕机了 2、长时间没有操作,超过了wait_timeout的设置,mysql自动断开 3、mysql请求链接被主动kill 4、发送的请求或返回结果过大,可设置max_allowed_packet的值 5、程序中你都是通过单例来操作数据库,如果两个操作时间超过wait_timeout。 |
为了演示的方便,设置wait_timeout时间为10秒
1 2 | > set global wait_timeout=10; > show global variables like 'wait_timeout' ; |
worker.php代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 | <?php //创建一个worker $worker = new GearmanWorker(); //添加一个job服务 $worker ->addServer( '127.0.0.1' , 4730); //注册一个回调函数,用于业务处理 $worker ->addFunction( 'longTime' , function ( $job ) { //workload()获取客户端发送来的序列化数据 $data = json_decode( $job ->workload(), true); $db = new mysqli( '192.168.1.100' , 'root' , '' , 'test' ); if ( $db ->connect_error) { die ( 'connect error' ); } //等待15秒,我们设置mysql的wait_timeout为10秒 sleep(15); //当执行到这里时,因为超时,所以mysql自动把连接断开了 $ret = $db ->query( "INSERT INTO test VALUES(NULL, {$data['title']}, {$data['content']});" ); if ( $ret ) { return "插入成功\n" ; } }); //死循环 //等待job提交的任务 while ( $worker ->work()); |
client.php代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 | <?php //创建一个客户端 $client = new GearmanClient(); //添加一个job服务 $client ->addServer( '127.0.0.1' , 4730); //doNormal同步 $ret = $client ->doNormal( 'longTime' , json_encode( array ( 'title' => '我是标题' , 'content' => '我是内容' , ))); echo $ret ; |
执行的结果如下图所示,出现了MySQL server has gone away的情况。
一般的解决方法:
1、调大wait_timeout的值(不建议)
2、每次在操作数据库的时候,ping()一下,如果断开就重新连。
3、在wait_timeout时间间隔之内,我们时不时的去query('select 1+1');一下,让mysql知道连接还活着。
修改worker.php代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 | <?php //创建一个worker $worker = new GearmanWorker(); //添加一个job服务 $worker ->addServer( '127.0.0.1' , 4730); //注册一个回调函数,用于业务处理 $worker ->addFunction( 'longTime' , function ( $job ) { //workload()获取客户端发送来的序列化数据 $data = json_decode( $job ->workload(), true); $db = new mysqli( '192.168.1.100' , 'root' , '' , 'test' ); if ( $db ->connect_error) { die ( 'connect error' ); } //等待15秒,我们设置mysql的wait_timeout为10秒 sleep(15); //ini_set('mysqli.reconnect', 1); //php手册上说,ping会尝试重新连接,但现实是并不会 //$db->ping(); if (! $db ->ping()) { $db ->close(); //重新连接数据库 $db = new mysqli( '192.168.1.100' , 'root' , '' , 'test' ); } $ret = $db ->query( "INSERT INTO test VALUES(NULL, '{$data['title']}', '{$data['content']}');" ); if ( $ret ) { return "插入成功\n" ; } }); //死循环 //等待job提交的任务 while ( $worker ->work()); |
运行结果如下: