当前位置: 首页 > 工具软件 > py3k-gearman > 使用案例 >

gearman-php的Net_Gearman库学习

麻鹏鹍
2023-12-01

按照这个英文帖子学习的
原文代码的备份

例子1:
像我们展示了Net_Geaman的基本架构,client端主要代码:

// 一个client对象,需要jobserver信息,一个数组
$client = new Net_Gearman_Client (gm::$servers);
// Example1就是function name
$client->Example1 (array ('date'));

worker端主要代码:

// worker对象,需要jobserver信息
$worker = new Net_Gearman_Worker (gm::$servers);
// 传入function name,给他处理Example1的能力
$worker->addAbility ('Example1');
// loop
$worker->beginWork ();

和传统的gearman api略有差别,Net_Geaman需要用户以子类形式实现function,例如Example1.php文件代码片段:


class Net_Gearman_Job_Example1 extends Net_Gearman_Job_Common
{
    // arg 是数组,与client里面的入参array对应
    public function run ($arg)
    {
        $cmd = $arg[0];
    //...
        return $result;
    }
}

例子一中的一个技巧是client调用了Example1这个不存在的方法,使用的是 _call 机制。没啥用。

例子2:
client侧引入task和set概念,这样就可以累加多个任务到一个集合,一起发出,client片段:

$set = new Net_Gearman_Set();
$task = new Net_Gearman_Task ('Example1', array ('date'));
$set->addTask ($task);
$client->runSet ($set);

例子3:
增加了完成任务后的回调功能,回调的参数有function name,句柄(包好jobserver:number,主要是唯一标识一下这次任务),还有任务的返回值。

$task->attachCallback ("complete",Net_Gearman_Task::TASK_COMPLETE);
//...
function complete ($func, $handle, $result) {
    gm::log_msg ("[gm_client] complete ($handle/$func)");
    gm::log_msg ("[gm_client] result: " . $result['result']);
}

例子4:
主要是展示通过complete回调回传数据。
例子5:
展示client端添加fail回调,当function中抛出Net_Gearman_Job_Exception异常时候,会触发 fail类型的回调,代码片段:

class Net_Gearman_Job_Example3 extends Net_Gearman_Job_Common
{       
    public function run ($arg)
    {
        if (count ($arg) != 1)
        {
            throw new Net_Gearman_Job_Exception ("must provide exactly one command to run");
        }
        //...
$task->attachCallback ("complete",Net_Gearman_Task::TASK_COMPLETE);
$task->attachCallback ("fail",Net_Gearman_Task::TASK_FAIL);
//...
function fail ($task) {
    gm::log_msg ("[gm_client] fail, task: " . print_r ($task, true));
}

但异常内容并不会回传给fail回调函数,所以还是建议使用正常的complete回调,用户可以自己捕获失败信息放到返回值里面。
例子6:
worker里面使用了monitor功能,代码片段:

    $worker->beginWork ('monitor');
// ...
function monitor ($idle, $time_of_last_job)
{
    $idle_str = ($idle) ? 'idle' : 'not idle';
    $time_of_last_job_str = date ('r', $time_of_last_job);
    gm::log_msg ("[gm_worker] status: $idle_str, time of last job: $time_of_last_job_str");
}

其触发事件有:
job开始前。
job完成后。
等待job时候,一分钟触发一次。

例子7:
主要是在worker端添加了任务的start,complete和fail回调,可以在里面做点事情,代码片段:

    $worker->attachCallback ('job_start', Net_Gearman_Worker::JOB_START);
    $worker->attachCallback ('job_complete', Net_Gearman_Worker::JOB_COMPLETE);
    $worker->attachCallback ('job_fail', Net_Gearman_Worker::JOB_FAIL);

例子8:
是一个大综合,主要有以下几点值得注意:
1. 作者虽然很喜欢php,但也认为让php承担一个daemon的worker不是很保险的事情,可能涉及异常退出啊、内存使用不合理呀什么的,有可能影响性能,所以他提供了一个策略:每个worker有个实例编号,使用文件锁来确保一个实例编号只有一个worker运行,worker在处理了一定数目的job后自动退出,使用crontab任务秒级拉起worker。
2. worker的beginWorker退出可以在monitor回调中判断,monitor回调有这种特性:回调函数返回false则worker继续loop,返回true则loop退出,这个在worker的源码中也得到证实:

if (call_user_func($monitor, $idle, $lastJob) == true) {
$working = false;
}
 类似资料: