gearman中worker常駐后臺(tái),導(dǎo)致MySQL server has gone away的解決方法
本文實(shí)例講述了gearman中worker常駐后臺(tái),導(dǎo)致MySQL server has gone away的解決方法。分享給大家供大家參考,具體如下:
產(chǎn)生這個(gè)原因主要有如下幾點(diǎn):
1、mysql服務(wù)宕機(jī)了2、長(zhǎng)時(shí)間沒(méi)有操作,超過(guò)了wait_timeout的設(shè)置,mysql自動(dòng)斷開(kāi)3、mysql請(qǐng)求鏈接被主動(dòng)kill4、發(fā)送的請(qǐng)求或返回結(jié)果過(guò)大,可設(shè)置max_allowed_packet的值5、程序中你都是通過(guò)單例來(lái)操作數(shù)據(jù)庫(kù),如果兩個(gè)操作時(shí)間超過(guò)wait_timeout。
為了演示的方便,設(shè)置wait_timeout時(shí)間為10秒
> set global wait_timeout=10;> show global variables like ’wait_timeout’;
worker.php代碼如下:
<?php//創(chuàng)建一個(gè)worker$worker = new GearmanWorker();//添加一個(gè)job服務(wù)$worker->addServer(’127.0.0.1’, 4730);//注冊(cè)一個(gè)回調(diào)函數(shù),用于業(yè)務(wù)處理$worker->addFunction(’longTime’, function($job) { //workload()獲取客戶端發(fā)送來(lái)的序列化數(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秒,我們?cè)O(shè)置mysql的wait_timeout為10秒 sleep(15); //當(dāng)執(zhí)行到這里時(shí),因?yàn)槌瑫r(shí),所以mysql自動(dòng)把連接斷開(kāi)了 $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)建一個(gè)客戶端$client = new GearmanClient();//添加一個(gè)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ù)庫(kù)的時(shí)候,ping()一下,如果斷開(kāi)就重新連。3、在wait_timeout時(shí)間間隔之內(nèi),我們時(shí)不時(shí)的去query(’select 1+1’);一下,讓mysql知道連接還活著。
修改worker.php代碼如下:
<?php//創(chuàng)建一個(gè)worker$worker = new GearmanWorker();//添加一個(gè)job服務(wù)$worker->addServer(’127.0.0.1’, 4730);//注冊(cè)一個(gè)回調(diào)函數(shù),用于業(yè)務(wù)處理$worker->addFunction(’longTime’, function($job) { //workload()獲取客戶端發(fā)送來(lái)的序列化數(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秒,我們?cè)O(shè)置mysql的wait_timeout為10秒 sleep(15); //ini_set(’mysqli.reconnect’, 1); //php手冊(cè)上說(shuō),ping會(huì)嘗試重新連接,但現(xiàn)實(shí)是并不會(huì) //$db->ping(); if(!$db->ping()) { $db->close(); //重新連接數(shù)據(jù)庫(kù) $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é)果如下:
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《PHP進(jìn)程與線程操作技巧總結(jié)》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《PHP基本語(yǔ)法入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫(kù)操作入門教程》及《php常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
