gearman中任務(wù)的優(yōu)先級(jí)和返回狀態(tài)實(shí)例分析
本文實(shí)例講述了gearman中任務(wù)的優(yōu)先級(jí)和返回狀態(tài)。分享給大家供大家參考,具體如下:
gearman中任務(wù)的優(yōu)先級(jí)和返回狀態(tài)
一、任務(wù)的優(yōu)先級(jí)
同步阻塞調(diào)用,等待返回結(jié)果
doLow:最低優(yōu)先 doNomal:正常優(yōu)先級(jí) doHigh:最優(yōu)先執(zhí)行
異步派發(fā)任務(wù),不等待返回結(jié)果,返回任務(wù)句柄,通過該句柄可獲取任務(wù)運(yùn)行狀態(tài)信息
doLowBackground doBackground doHighBackground
注意Task和doXXX區(qū)別,Task是一組job,派發(fā)后會(huì)分配到多個(gè)worker上并行執(zhí)行并返回結(jié)果給調(diào)用方。
而doXXX的每個(gè)任務(wù)只會(huì)在一個(gè)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)先級(jí)的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());
注意,為了實(shí)驗(yàn)效果,這里worker只需啟動(dòng)一個(gè)。

二、獲取任務(wù)的狀態(tài)
cli.php代碼如下:
<?php
$client = new GearmanClient();
$client->addServer('127.0.0.1', 4730);
//任務(wù)排隊(duì)時(shí)的回調(diào)
$client->setCreatedCallback('reverse_create');
//有任務(wù)數(shù)據(jù)包時(shí)的回調(diào)
$client->setDataCallback('reverse_data');
//收集任務(wù)狀態(tài)的回調(diào)
$client->setStatusCallback('reverse_status');
//任務(wù)完成時(shí)的回調(diào)
$client->setCompleteCallback('reverse_complete');
//任務(wù)失敗時(shí)的回調(diào)
$client->setFailCallback('reverse_fail');
//分別添加不同優(yōu)先級(jí)的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),會(huì)被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());
運(yùn)行結(jié)果如下:


更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《PHP進(jìn)程與線程操作技巧總結(jié)》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《PHP基本語法入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫操作入門教程》及《php常見數(shù)據(jù)庫操作技巧匯總》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
- php使用gearman進(jìn)行任務(wù)分發(fā)操作實(shí)例詳解
- python基于json文件實(shí)現(xiàn)的gearman任務(wù)自動(dòng)重啟代碼實(shí)例
- gearman中worker常駐后臺(tái),導(dǎo)致MySQL server has gone away的解決方法
- PHP使用gearman進(jìn)行異步的郵件或短信發(fā)送操作詳解
- gearman + mysql方式實(shí)現(xiàn)持久化操作示例
- gearman管理工具GearmanManager的安裝與php使用方法示例
- PHP并發(fā)多進(jìn)程處理利器Gearman使用介紹
- Gearman::XS在Centos下的編譯安裝方法
- gearman隊(duì)列持久化引發(fā)的問題及解決方法
- gearman的安裝啟動(dòng)及python API使用實(shí)例
- rhel5.7下安裝gearmand及啟動(dòng)的方法
相關(guān)文章
php實(shí)現(xiàn)過濾表單提交中html標(biāo)簽的方法
這篇文章主要介紹了php實(shí)現(xiàn)過濾表單提交中html標(biāo)簽的方法,并以<br/>標(biāo)簽為例演示了過濾的方法,非常實(shí)用,需要的朋友可以參考下2014-10-10
將二維數(shù)組轉(zhuǎn)為一維數(shù)組的2種方法
在開發(fā)過程中,我們經(jīng)常需要將二維數(shù)組轉(zhuǎn)為一維數(shù)組,個(gè)人總結(jié)了2種方法,分享給大家2014-05-05
利用PHP計(jì)算有多少小于當(dāng)前數(shù)字的數(shù)字方法示例
這篇文章主要給大家介紹了關(guān)于利用PHP計(jì)算有多少小于當(dāng)前數(shù)字的數(shù)字的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
解決phpmyadmin 亂碼,支持gb2312和utf-8
解決phpmyadmin 亂碼,支持gb2312和utf-8...2006-11-11

