欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

gearman中任务的优先级和返回状态实例分析

程序员文章站 2022-10-10 20:46:24
本文实例讲述了gearman中任务的优先级和返回状态。分享给大家供大家参考,具体如下:gearman中任务的优先级和返回状态一、任务的优先级同步阻塞调用,等待返回结果dolow:最低优先donomal...

本文实例讲述了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只需启动一个。

gearman中任务的优先级和返回状态实例分析

二、获取任务的状态

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中任务的优先级和返回状态实例分析

gearman中任务的优先级和返回状态实例分析