您好,登錄后才能下訂單哦!
這篇文章主要介紹gearman中任務(wù)的優(yōu)先級和返回狀態(tài)的示例分析,文中介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們一定要看完!
具體如下:
gearman中任務(wù)的優(yōu)先級和返回狀態(tài)
一、任務(wù)的優(yōu)先級
同步阻塞調(diào)用,等待返回結(jié)果
doLow:最低優(yōu)先 doNomal:正常優(yōu)先級 doHigh:最優(yōu)先執(zhí)行
異步派發(fā)任務(wù),不等待返回結(jié)果,返回任務(wù)句柄,通過該句柄可獲取任務(wù)運行狀態(tài)信息
doLowBackground doBackground doHighBackground
注意Task和doXXX區(qū)別,Task是一組job,派發(fā)后會分配到多個worker上并行執(zhí)行并返回結(jié)果給調(diào)用方。
而doXXX的每個任務(wù)只會在一個worker上執(zhí)行。
addTaskLow addTask addTaskHigh addTaskLowBackground addTaskBackground addTaskHighBackground
cli.php代碼如下:
<?php $client = new GearmanClient(); $client->addServer('127.0.0.1', 4730); $client->setCompleteCallback(function($task) { echo $task->data(), PHP_EOL; }); //分別添加不同優(yōu)先級的Task $client->addTaskLow('sum', json_encode(array(100, 100))); $client->addTask('sum', json_encode(array(200, 200))); $client->addTaskHigh('sum', json_encode(array(300, 300))); $client->runTasks();
worker.php代碼如下:
<?php $worker = new GearmanWorker(); $worker->addServer('127.0.0.1', 4730); $worker->addFunction('sum', function($job) { $data = json_decode($job->workload(), true); $ret = $data[0] + $data[1]; echo $ret, PHP_EOL; sleep(1); return $ret; }); while($worker->work());
注意,為了實驗效果,這里worker只需啟動一個。
二、獲取任務(wù)的狀態(tài)
cli.php代碼如下:
<?php $client = new GearmanClient(); $client->addServer('127.0.0.1', 4730); //任務(wù)排隊時的回調(diào) $client->setCreatedCallback('reverse_create'); //有任務(wù)數(shù)據(jù)包時的回調(diào) $client->setDataCallback('reverse_data'); //收集任務(wù)狀態(tài)的回調(diào) $client->setStatusCallback('reverse_status'); //任務(wù)完成時的回調(diào) $client->setCompleteCallback('reverse_complete'); //任務(wù)失敗時的回調(diào) $client->setFailCallback('reverse_fail'); //分別添加不同優(yōu)先級的Task $client->addTaskLow('reverse', '1234567'); $client->addTask('reverse', 'hello'); $client->addTaskHigh('reverse', 'world'); $client->runTasks(); function reverse_create($task) { echo '任務(wù)創(chuàng)建(', $task->jobHandle() , '): ', PHP_EOL; } function reverse_data($task) { echo '接收數(shù)據(jù)(', $task->jobHandle() , '): ', $task->data(), PHP_EOL; } function reverse_status($task) { //taskNumerator()獲取任務(wù)完成情況的分子 //taskDenominator()獲取任務(wù)完成情況的分母 echo '完成情況(', $task->jobHandle() , '): ', $task->taskNumerator(), '/', $task->taskDenominator(), PHP_EOL; } function reverse_complete($task) { echo '任務(wù)完成(', $task->jobHandle() , '): ', $task->data(), PHP_EOL; } function reverse_fail($task) { echo '任務(wù)失敗(', $task->jobHandle() , '): ', PHP_EOL; }
worker.php代碼如下:
<?php $worker = new GearmanWorker(); $worker->addServer('127.0.0.1', 4730); $worker->addFunction('reverse', function($job) { //workload()返回接收的數(shù)據(jù) $data = $job->workload(); //workloadSize()返回接收數(shù)據(jù)的字節(jié)大小 $dataSize = $job->workloadSize(); echo "worker: {$data} ({$dataSize}) \n"; $tmp = 0; $mid = $dataSize / 2; for($ix = 0; $ix < $mid; ++$ix) { $tmp = $data[$ix]; $data[$ix] = $data[$dataSize - $ix - 1]; $data[$dataSize - $ix - 1] = $tmp; //這里發(fā)送狀態(tài),會被client設(shè)置的回調(diào)reverse_status()接收到 //狀態(tài)完成情況的分子與分母 $job->sendStatus($ix + 1, $mid + 1); //發(fā)送數(shù)據(jù),被reverse_data()接收到 $job->sendData($data); sleep(1); } return $data; }); while($worker->work());
運行結(jié)果如下:
以上是“gearman中任務(wù)的優(yōu)先級和返回狀態(tài)的示例分析”這篇文章的所有內(nèi)容,感謝各位的閱讀!希望分享的內(nèi)容對大家有幫助,更多相關(guān)知識,歡迎關(guān)注億速云行業(yè)資訊頻道!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。