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（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。