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() 方法获取错误信息。