如何将 GearmanJob 与 GearmanWorker 和 GearmanClient 联系起来？

Question

public GearmanTask GearmanClient::addTask  ( string $function_name  , string $workload  [, mixed &$context  [, string $unique  ]] )
public bool GearmanWorker::addFunction  ( string $function_name  , callback $function  [, mixed &$context  [, int $timeout  ]] )

这些是可用于集成两者的类方法。 有了这些，您如何将工作负载与被调用的函数联系起来？

Answer 1

GearmanClient 用于提交任务。通常，这是通过网页或用于读取要提交的任务列表的脚本来完成的。

GearmanWorker 的设置方式是让许多并行“工作线程”可以同时运行。从逻辑上讲，工人所做的任何事情都应该代表单个原子工作单元。这可能意味着将一个对象转换为另一个对象并将其保存回数据库，或者为单个用户组装并发送 HTML 电子邮件。 $function_name 是一个采用单个参数的函数，该参数是一个 GearmanJob 对象。

因此，您的控制器脚本可能如下所示。

 $gearman_params = json_encode( 数组(
      'id'=> 77、
      '选项' =>数组（'推' => true），
  ) );
  $client = new GearmanClient();
  $client->doBackground( "widgetize", $gearman_params );

然后，你的工人会做这样的事情。

$gmworker  = GearmanWorker;
$gmworker->addFunction( "widgetize", "widgetize" );
while( $gmworker->work() ) {  

if ( $gmworker->returnCode() !== GEARMAN_SUCCESS ) {
    echo "Worker Terminated." . PHP_EOL ;
    break;
  }

} // while *working*

function widgetize( $job ) {
    $workload = json_decode( $job->workload() );

    /* do stuff */
}

需要记住的一些事情：

• 工作脚本被设计为长时间运行的脚本，因此需要 while 循环。确保正确设置超时和内存限制。
• 给工人一个运行限制也是一个好习惯。例如，只允许工作程序运行几次，然后exit; PHP 的内存使用情况仍然很糟糕，并且很难判断工作程序何时会因为内存不足而被杀死。
• 同样，最好将工作人员设计为幂等的，这样，如果工作人员失败，可以将工作重新提交给工作人员。
• 客户端可以向工作人员提交具有不同优先级的作业，并且它们不一定必须在后台运行，如上面的示例。它们可以运行以便客户端阻塞。