首页 > 作文

PHP swoole的process模块创建和使用子进程操作示例

更新时间:2023-04-08 15:17:20 阅读: 评论:0

本文实例讲述了php swoole的process模块创建和使用子进程操作。分享给大家供大家参考,具体如下:

swoole中为我们提供了一个进程管理模块 process,替换php的 pcntl 扩展,方便我们创建进程,管理进程,和进程间的通信。

swoole提供了2种进程间的通信:

1、基于 unix socket 的管道 pipe。

2、基于 sysvmsg 的消息队列。

我们可以通过 new swoole_process() 快速的创建一个进程,默认会创建一个 sock_dgram 类型的管道,用于进程间的通信,当然可以设置成其他类型,也可以不创建。

一、通过同步阻塞管道进行进程间通信

<?php$worker_process_nums = 5;$worker_process = []; for ($i = 0; $i < $worker_process_nums; $i++) {  //创建子进程  //默认为每个子进程创建一个管道,如果不想创建设置$pipe_type参数为fal  //注意管道默认是同步阻塞,半双工,如果读取不到数据就会阻塞  $worker = new swoole_process(function (swoole_process $worker) {    //注意,如果主进程中不写数据write(),那么子进程这里read()就会阻塞    $task = json_decode($台风 莫兰蒂worker->read(), true);     //进行计算任务    $tmp = 0;    for ($i = $task['start']; $i < $task['end']; $i++) {      $tmp += $i;    }     echo '子进程 pid : ', $worker->pid, ' 计算 ', $task['start'], ' - ', $task['end'], ' 结果 : ', $tmp, php_eol;    //往管道中写入计算的结果    $worker->write($tmp);    //子进程退出    $worker->exit();  });   //保存子进程  $worker_process[$i] = $worker;   //启动子进程  $worker->start();} //往每个子进程管道中投递任务for ($i = 0; $i < $worker_process_nums; $i+巨人街头篮球手游官网+) {  $worker_process[$i]->write(json_encode([    'start' => mt_rand(1, 10),    'end' => mt_rand(50, 100),  ]));} //父进程监听子进程退出信号,回收子进程,防止出现僵尸进程swoole_process::signal(sigc绿水青山就是金山银山hld, function ($sig) {  //必须为fal,非阻塞模式  while ($ret = swoole_process::wait(fal)) {    echo "子进程 pid : {$ret['pid']} 退出\n";  }});

二、通过 swoole_event_add 将管道设为异步,来进行通信

<?php$worker_process_nums = 5;$worker_process = []; for ($i = 0; $i < $worker_process_nums; $i++) {  $worker = new swoole_process(function ($worker) {    //在子进程中给管道添加事件监听    //底层会自动将该管道设置为非阻塞模式    //参数二,是可读事件回调函数,表示管道可以读了    swoole_event_add($worker->pipe, function ($pipe) u ($worker) {      $task = json_中小学教资考试decode($worker->read(), true);       $tmp = 0;      for ($i = $task['start']; $i < $task['end']; $i++) {        $tmp += $i;      }      echo "子进程 : {$worker->pid} 计算 {$task['start']} - {$task['end']} \n";      //子进程把计算的结果,写入管道      $worker->write($tmp);      //注意,swoole_event_add与swoole_event_del要成对使用      swoole_event_del($worker->pipe);      //退出子进程      $worker->exit();    });  });   $worker_process[$i] = $worker;   //启动子进程  $worker->start();} for ($i = 0; $i < $worker_process_nums; $i++) {  $worker = $worker_process[$i];   $worker->write(json_encode([    'start' => mt_rand(1, 10),    'end' => mt_rand(50, 100),  ]));   //主进程中,监听子进程管道事件  swoole_event_add($worker->pipe, function ($pipe) u ($worker) {    $result = $worker->read();    echo "子进程 : {$worker->pid} 计算结果 {$result} \n";    swoole_event_del($worker->pipe);  });} //父进程监听子进程退出信号,回收子进程,防止出现僵尸进程swoole_process::signal(sigchld, function ($sig) {  //必须为fal,非阻塞模式  while ($ret = swoole_process::wait(fal)) {    echo "子进程 pid : {$ret['pid']} 退出\n";  }});

三、使用消息队列来完成进程间通信

<?php$worker_process_nums = 5;$worker_process = []; for ($i = 0; $i < $worker_process_nums; $i++) {  //注意,这里将参数$pipe_type设为fal,表示不创建管道  $worker = new swoole_process(function ($worker) {    $task = json_decode($worker->pop(), true);     $tmp = 0;    for ($i = $task['start']; $i < $task['end']; $i++) {      $tmp += $i;    }    echo "子进程 : {$worker->pid} 计算 {$task['start']} - {$task['end']} \n";    $worker->push($tmp);    $worker->exit();  }, fal, fal);   //使用消息队列,作为进程间的通信  //注意,消息队列是共享的  $worker->uqueue();   $worker_process[$i] = $worker;   //启动子进程  $worker->start();} for ($i = 0; $i < $worker_process_nums; $i++) {  //只需用一个子进程发送消息即可,因为消息队列是共享的  $worker_process[0]->push(json_encode([    'start' => mt_rand(1, 10),    'end' => mt_rand(50, 100),  ]));} //注意,这里要暂停,防止加入队列的任务,立刻被主进程读出来。sleep(1); for ($i = 0; $i < $worker_process_nums; $i++) {  $result = $worker_process[0]->pop();  echo "计算结果 : {$result} \n";} //父进程监听子进程退出信号,回收子进程,防止出现僵尸进程swoole_process::signal(sigchld, function ($sig) {  //必须为fal,非阻塞模式  while ($ret = swoole_process::wait(fal)) {    echo "子进程 pid : {$ret['pid']} 退出\n";  }});

四、进程可以通过 signal 监听信号,和 alarm 设置定时器。

我们可以在父进程上设置监听信号,当子进程退出时,重新挂起子进程。

也可以设置定时器,通过 swoole_process::kill($pid, 0); 定时检测进程是否存活。

<?php//每隔1秒触发sigalam信号//注意,alarm不能和timer同时使用bangbangtangswoole_process::alarm(1000 * 1000, 0); swoole_process::signal(sigalrm, function ($signo) {  static $cnt = 0;  $cnt++;  echo "时钟定时信号\n";   if ($cnt > 10) {    //清除定时器    swoole_process::alarm(-1);  }}); swoole_process::signal(sigint, function ($signo) {  echo "我被ctrl+c了\n";   //退出主进程,不然将一直无法正常退出  exit(0);});

本文发布于:2023-04-08 15:17:18,感谢您对本站的认可!

本文链接:https://www.wtabcd.cn/fanwen/zuowen/7501dbe38b069c25519ed44b145ccd07.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

本文word下载地址:PHP swoole的process模块创建和使用子进程操作示例.doc

本文 PDF 下载地址:PHP swoole的process模块创建和使用子进程操作示例.pdf

标签:进程   管道   队列   信号
相关文章
留言与评论(共有 0 条评论)
   
验证码:
Copyright ©2019-2022 Comsenz Inc.Powered by © 专利检索| 网站地图