PHP swoole中使用task进程异步的处理耗时任务应用案例分析

<?php
$server = new swoole_server('0.0.0.0', 6666);
 
$server->set([
  'worker_num' => 2,
  'task_worker_num' => 16,
]);
 
$server->on('WorkerStart', function ($server, $worker_id) {
  //注意这里，我们通过taskworker来判断是task进程还是worker进程
  //需要在worker进程中调用task()，不然会报出警告
  //这里会执行两遍，因为我们设置了worker_num数为2
  if (!$server->taskworker) {
    echo '投递任务开始...', PHP_EOL;
    //投递32个累加计算任务给16个task进程
    for ($ix = 0; $ix < 32; $ix++) {
      //注意这里的投递是异步的
      $server->task([mt_rand(1, 100), mt_rand(1000, 9999)]);
    }
    echo '投递任务结束...', PHP_EOL;
  }
});
 
//server服务必须要有onReceive回调
$server->on('Receive', function ($server, $fd, $reactor_id, $data) {
 
});
 
//注意，task进程完全是同步阻塞模式的
$server->on('Task', function ($server, $task_id, $src_worker_id, $data) {
  echo "task {$task_id} 进程正在工作...", PHP_EOL;
  $start = $data[0];
  $end = $data[1];
  $total = 0;
  for (; $start <= $end; $start++) {
    $total += $start;
  }
  echo "task {$task_id} 进程完成工作...", PHP_EOL;
  return $total;
});
 
$server->on('Finish', function ($server, $task_id, $data) {
  echo "task {$task_id} 进程处理完成, 结果为 {$data}", PHP_EOL;
});
 
$server->start();