gearman中worker常驻后台，导致MySQL server has gone away的解决方法

Chloe ·

更新时间:2024-11-14

· 690 次阅读

本文实例讲述了gearman中worker常驻后台，导致MySQL server has gone away的解决方法。分享给大家供大家参考，具体如下：

产生这个原因主要有如下几点：


1、mysql服务宕机了
2、长时间没有操作，超过了wait_timeout的设置，mysql自动断开
3、mysql请求链接被主动kill
4、发送的请求或返回结果过大，可设置max_allowed_packet的值
5、程序中你都是通过单例来操作数据库，如果两个操作时间超过wait_timeout。

为了演示的方便，设置wait_timeout时间为10秒


> set global wait_timeout=10;
> show global variables like 'wait_timeout';

worker.php代码如下：


<?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代码如下：


<?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代码如下：


<?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());

运行结果如下：

更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。

您可能感兴趣的文章:php使用gearman进行任务分发操作实例详解python基于json文件实现的gearman任务自动重启代码实例PHP使用gearman进行异步的邮件或短信发送操作详解gearman + mysql方式实现持久化操作示例gearman管理工具GearmanManager的安装与php使用方法示例PHP并发多进程处理利器Gearman使用介绍Gearman::XS在Centos下的编译安装方法gearman队列持久化引发的问题及解决方法gearman的安装启动及python API使用实例rhel5.7下安装gearmand及启动的方法gearman中任务的优先级和返回状态实例分析

worker has gearman 方法 Mysql

1024 个赞