本文實(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)kill
4、發(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()獲取客戶(hù)端發(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è)客戶(hù)端
$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()獲取客戶(hù)端發(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)容感興趣的讀者可查看本站專(zhuān)題：《PHP進(jìn)程與線程操作技巧總結(jié)》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《PHP基本語(yǔ)法入門(mén)教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫(kù)操作入門(mén)教程》及《php常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
您可能感興趣的文章:- php使用gearman進(jìn)行任務(wù)分發(fā)操作實(shí)例詳解
- python基于json文件實(shí)現(xiàn)的gearman任務(wù)自動(dòng)重啟代碼實(shí)例
- PHP使用gearman進(jìn)行異步的郵件或短信發(fā)送操作詳解
- gearman + mysql方式實(shí)現(xiàn)持久化操作示例
- gearman管理工具GearmanManager的安裝與php使用方法示例
- PHP并發(fā)多進(jìn)程處理利器Gearman使用介紹
- Gearman::XS在Centos下的編譯安裝方法
- gearman隊(duì)列持久化引發(fā)的問(wèn)題及解決方法
- gearman的安裝啟動(dòng)及python API使用實(shí)例
- rhel5.7下安裝gearmand及啟動(dòng)的方法
- gearman中任務(wù)的優(yōu)先級(jí)和返回狀態(tài)實(shí)例分析
