GearmanWorker::addFunction()函数—用法及示例

函数名称：GearmanWorker::addFunction()

适用版本：GearmanWorker::addFunction() 函数在 PHP 5 >= 5.3.0 版本中可用。

用法：GearmanWorker::addFunction() 函数用于向 Gearman worker 注册一个处理函数，该处理函数将在 Gearman 服务器上的任务队列中有对应的任务时被调用。

语法：bool GearmanWorker::addFunction ( string $function_name , callable $function [, mixed $context [, int $timeout ]] )

参数：

• $function_name：要注册的处理函数的名称，是一个字符串类型的参数。
• $function：要注册的处理函数，可以是一个可调用的函数，也可以是一个匿名函数。该函数接受一个 GearmanJob 对象作为参数，用于处理任务。注意：该函数必须返回一个布尔类型的值，表示任务是否成功处理。
• $context（可选）：传递给处理函数的上下文数据，可以是任何类型的数据。
• $timeout（可选）：任务处理的超时时间，以毫秒为单位。默认为无限制。

返回值：成功时返回 TRUE，失败时返回 FALSE。

示例：

// 创建 Gearman worker 对象
$worker = new GearmanWorker();

// 添加处理函数
$worker->addFunction('reverse_string', function (GearmanJob $job) {
    // 获取任务数据
    $workload = $job->workload();

    // 反转字符串
    $reversed = strrev($workload);

    // 处理结果返回给 Gearman 服务器
    $job->sendComplete($reversed);

    // 返回处理结果
    return true;
});

// 添加 Gearman 服务器的连接
$worker->addServer('127.0.0.1', 4730);

// 开始处理任务
while ($worker->work()) {
    if ($worker->returnCode() != GEARMAN_SUCCESS) {
        echo "Worker failed: " . $worker->error() . PHP_EOL;
        break;
    }
}

在上面的示例中，我们创建了一个 Gearman worker 对象，并使用 addFunction() 函数注册了一个名为 reverse_string 的处理函数。当 Gearman 服务器上的任务队列中有 reverse_string 类型的任务时，该处理函数将会被调用。在处理函数中，我们获取任务数据，将字符串进行反转，并使用 $job->sendComplete() 方法将处理结果返回给 Gearman 服务器。最后，我们使用 addServer() 方法添加 Gearman 服务器的连接，并使用 work() 方法开始处理任务。如果处理过程中出现错误，我们使用 returnCode() 方法获取错误代码，并使用 error() 方法获取错误信息。