快捷導(dǎo)航

gearman中worker常駐后臺，導(dǎo)致MySQL server has gone away的解決方法

更新時間：2020年02月27日 10:40:43 作者：懷素真

這篇文章主要介紹了gearman中worker常駐后臺，導(dǎo)致MySQL server has gone away的解決方法,較為詳細(xì)的分析了造成MySQL server has gone away的原因與相關(guān)的解決方法,需要的朋友可以參考下

本文實例講述了gearman中worker常駐后臺，導(dǎo)致MySQL server has gone away的解決方法。分享給大家供大家參考，具體如下：

產(chǎn)生這個原因主要有如下幾點：

1、mysql服務(wù)宕機(jī)了
2、長時間沒有操作，超過了wait_timeout的設(shè)置，mysql自動斷開
3、mysql請求鏈接被主動kill
4、發(fā)送的請求或返回結(jié)果過大，可設(shè)置max_allowed_packet的值
5、程序中你都是通過單例來操作數(shù)據(jù)庫，如果兩個操作時間超過wait_timeout。

為了演示的方便，設(shè)置wait_timeout時間為10秒

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

worker.php代碼如下：

<?php
//創(chuàng)建一個worker
$worker = new GearmanWorker();
//添加一個job服務(wù)
$worker->addServer('127.0.0.1', 4730);
//注冊一個回調(diào)函數(shù)，用于業(yè)務(wù)處理
$worker->addFunction('longTime', function($job) {
  //workload()獲取客戶端發(fā)送來的序列化數(shù)據(jù)
  $data = json_decode($job->workload(), true);

  $db = new mysqli('192.168.1.100', 'root', '', 'test');
  if($db->connect_error) {
    die('connect error');
  }

  //等待15秒，我們設(shè)置mysql的wait_timeout為10秒
  sleep(15);

  //當(dāng)執(zhí)行到這里時，因為超時，所以mysql自動把連接斷開了
  $ret = $db->query("INSERT INTO test VALUES(NULL, {$data['title']}, {$data['content']});");
  if($ret) {
    return "插入成功\n";
  }
});

//死循環(huán)
//等待job提交的任務(wù)
while($worker->work());

client.php代碼如下：

<?php
//創(chuàng)建一個客戶端
$client = new GearmanClient();
//添加一個job服務(wù)
$client->addServer('127.0.0.1', 4730);

//doNormal同步
$ret = $client->doNormal('longTime', json_encode(array(
  'title' => '我是標(biāo)題',
  'content' => '我是內(nèi)容',
)));

echo $ret;

執(zhí)行的結(jié)果如下圖所示，出現(xiàn)了MySQL server has gone away的情況。

一般的解決方法：

1、調(diào)大wait_timeout的值(不建議)
2、每次在操作數(shù)據(jù)庫的時候，ping()一下，如果斷開就重新連。
3、在wait_timeout時間間隔之內(nèi)，我們時不時的去query('select 1+1');一下，讓mysql知道連接還活著。

修改worker.php代碼如下：

<?php
//創(chuàng)建一個worker
$worker = new GearmanWorker();
//添加一個job服務(wù)
$worker->addServer('127.0.0.1', 4730);
//注冊一個回調(diào)函數(shù)，用于業(yè)務(wù)處理
$worker->addFunction('longTime', function($job) {
  //workload()獲取客戶端發(fā)送來的序列化數(shù)據(jù)
  $data = json_decode($job->workload(), true);
  
  $db = new mysqli('192.168.1.100', 'root', '', 'test');
  if($db->connect_error) {
    die('connect error');
  }
  
  //等待15秒，我們設(shè)置mysql的wait_timeout為10秒
  sleep(15);

  //ini_set('mysqli.reconnect', 1);
  //php手冊上說，ping會嘗試重新連接，但現(xiàn)實是并不會
  //$db->ping();

  if(!$db->ping()) {
    $db->close();
    //重新連接數(shù)據(jù)庫
    $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";
  }
});

//死循環(huán)
//等待job提交的任務(wù)
while($worker->work());

運(yùn)行結(jié)果如下：