gearman中任務的優先級和返回狀態的示例分析

這篇文章主要介紹gearman中任務的優先級和返回狀態的示例分析，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

具體如下：

gearman中任務的優先級和返回狀態

一、任務的優先級

同步阻塞調用，等待返回結果

doLow:最低優先
doNomal:正常優先級
doHigh:最優先執行

異步派發任務，不等待返回結果，返回任務句柄，通過該句柄可獲取任務運行狀態信息

doLowBackground
doBackground
doHighBackground

注意Task和doXXX區別，Task是一組job，派發后會分配到多個worker上并行執行并返回結果給調用方。
而doXXX的每個任務只會在一個worker上執行。

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;
});
//分別添加不同優先級的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只需啟動一個。

二、獲取任務的狀態

cli.php代碼如下：

<?php
$client = new GearmanClient();
$client->addServer('127.0.0.1', 4730);
//任務排隊時的回調
$client->setCreatedCallback('reverse_create');
//有任務數據包時的回調
$client->setDataCallback('reverse_data');
//收集任務狀態的回調
$client->setStatusCallback('reverse_status');
//任務完成時的回調
$client->setCompleteCallback('reverse_complete');
//任務失敗時的回調
$client->setFailCallback('reverse_fail');
//分別添加不同優先級的Task
$client->addTaskLow('reverse', '1234567');
$client->addTask('reverse', 'hello');
$client->addTaskHigh('reverse', 'world');

$client->runTasks();

function reverse_create($task) {
  echo '任務創建(', $task->jobHandle() , '): ', PHP_EOL;
}
function reverse_data($task) {
  echo '接收數據(', $task->jobHandle() , '): ', $task->data(), PHP_EOL;
}
function reverse_status($task) {
  //taskNumerator()獲取任務完成情況的分子
  //taskDenominator()獲取任務完成情況的分母
  echo '完成情況(', $task->jobHandle() , '): ', $task->taskNumerator(), '/', $task->taskDenominator(), PHP_EOL;
}
function reverse_complete($task) {
  echo '任務完成(', $task->jobHandle() , '): ', $task->data(), PHP_EOL;
}
function reverse_fail($task) {
  echo '任務失敗(', $task->jobHandle() , '): ', PHP_EOL;
}

worker.php代碼如下：

<?php
$worker = new GearmanWorker();
$worker->addServer('127.0.0.1', 4730);
$worker->addFunction('reverse', function($job) {
  //workload()返回接收的數據
  $data = $job->workload();
  //workloadSize()返回接收數據的字節大小
  $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;

    //這里發送狀態，會被client設置的回調reverse_status()接收到
    //狀態完成情況的分子與分母
    $job->sendStatus($ix + 1, $mid + 1);
    //發送數據，被reverse_data()接收到
    $job->sendData($data);
    sleep(1);
  }
  return $data;
});
while($worker->work());

運行結果如下：

以上是“gearman中任務的優先級和返回狀態的示例分析”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！