PHP swoole的process模块创建和使用子进程操作示例
本文实例讲述了PHPswoole的process模块创建和使用子进程操作。分享给大家供大家参考,具体如下:
swoole中为我们提供了一个进程管理模块Process,替换PHP的pcntl扩展,方便我们创建进程,管理进程,和进程间的通信。
swoole提供了2种进程间的通信:
1、基于unixsocket的管道pipe。
2、基于sysvmsg的消息队列。
我们可以通过newswoole_process()快速的创建一个进程,默认会创建一个SOCK_DGRAM类型的管道,用于进程间的通信,当然可以设置成其他类型,也可以不创建。
一、通过同步阻塞管道进行进程间通信
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(SIGCHLD,function($sig){ //必须为false,非阻塞模式 while($ret=swoole_process::wait(false)){ echo"子进程PID:{$ret['pid']}退出\n"; } });
二、通过swoole_event_add将管道设为异步,来进行通信
pipe,function($pipe)use($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)use($worker){ $result=$worker->read(); echo"子进程:{$worker->pid}计算结果{$result}\n"; swoole_event_del($worker->pipe); }); } //父进程监听子进程退出信号,回收子进程,防止出现僵尸进程 swoole_process::signal(SIGCHLD,function($sig){ //必须为false,非阻塞模式 while($ret=swoole_process::wait(false)){ echo"子进程PID:{$ret['pid']}退出\n"; } });
三、使用消息队列来完成进程间通信
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(); },false,false); //使用消息队列,作为进程间的通信 //注意,消息队列是共享的 $worker->useQueue(); $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){ //必须为false,非阻塞模式 while($ret=swoole_process::wait(false)){ echo"子进程PID:{$ret['pid']}退出\n"; } });
四、进程可以通过signal监听信号,和alarm设置定时器。
我们可以在父进程上设置监听信号,当子进程退出时,重新挂起子进程。
也可以设置定时器,通过swoole_process::kill($pid,0);定时检测进程是否存活。
10){ //清除定时器 swoole_process::alarm(-1); } }); swoole_process::signal(SIGINT,function($signo){ echo"我被ctrl+c了\n"; //退出主进程,不然将一直无法正常退出 exit(0); });
更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP网络编程技巧总结》、《phpsocket用法总结》、《php面向对象程序设计入门教程》、《PHP数据结构与算法教程》及《php程序设计算法总结》
希望本文所述对大家PHP程序设计有所帮助。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。