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

函数名：GearmanWorker::register()

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

用法：GearmanWorker::register() 函数用于注册一个工作函数或回调函数到 Gearman 服务器。一旦注册成功，工作进程就可以接收到来自客户端的任务，并执行相应的处理逻辑。

语法：bool GearmanWorker::register(string $function_name [, callable $callback [, mixed &$context [, int $timeout ]]])

参数：

• $function_name：要注册的函数或回调函数的名称。
• $callback（可选）：一个回调函数，用于处理接收到的任务。如果没有指定回调函数，则默认使用工作进程中与注册的函数名称相同的函数来处理任务。
• &$context（可选）：一个引用，用于传递上下文数据给回调函数。
• $timeout（可选）：一个整数，表示任务处理的超时时间（以毫秒为单位）。默认为无限超时。

返回值：如果注册成功，则返回 true。否则，返回 false。

示例：

<?php
// 创建一个 GearmanWorker 对象
$worker = new GearmanWorker();

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

// 注册一个名为 "reverse_string" 的工作函数
$worker->register('reverse_string', function (GearmanJob $job) {
    $workload = $job->workload();
    $result = strrev($workload);
    echo "Reversed string: " . $result . PHP_EOL;
    return $result;
});

// 启动工作进程，等待任务
while ($worker->work()) {
    if ($worker->returnCode() != GEARMAN_SUCCESS) {
        echo "Worker failed: " . $worker->error() . PHP_EOL;
        break;
    }
}
?>

以上示例中，我们创建了一个 GearmanWorker 对象，并向其添加了一个 Gearman 服务器。然后，我们使用 register() 函数注册了一个名为 "reverse_string" 的工作函数，并指定了一个回调函数来处理接收到的任务。在回调函数中，我们将接收到的字符串进行反转，并输出结果。最后，我们通过调用 work() 函数启动工作进程，等待任务的到来。如果工作进程出现错误，则会打印错误信息并退出。

注意：在使用 GearmanWorker::register() 函数之前，需要先加载 Gearman 扩展，并且确保 Gearman 服务器已经正确配置和运行。