做直播网站要多大带宽,如何策划一个网站,网站建设方案报价,wordpress主题sleo本文实例讲述了PHP swoole的process模块创建和使用子进程操作。分享给大家供大家参考#xff0c;具体如下#xff1a;swoole中为我们提供了一个进程管理模块 Process#xff0c;替换PHP的 pcntl 扩展#xff0c;方便我们创建进程#xff0c;管理进程#xff0c;和进程间的…本文实例讲述了PHP swoole的process模块创建和使用子进程操作。分享给大家供大家参考具体如下swoole中为我们提供了一个进程管理模块 Process替换PHP的 pcntl 扩展方便我们创建进程管理进程和进程间的通信。swoole提供了2种进程间的通信1、基于 unix socket 的管道 pipe。2、基于 sysvmsg 的消息队列。我们可以通过 new swoole_process() 快速的创建一个进程默认会创建一个 SOCK_DGRAM 类型的管道用于进程间的通信当然可以设置成其他类型也可以不创建。一、通过同步阻塞管道进行进程间通信$worker_process_nums 5;$worker_process [];for ($i 0; $i $worker_process_nums; $i) {//创建子进程//默认为每个子进程创建一个管道如果不想创建设置$pipe_type参数为false//注意管道默认是同步阻塞半双工如果读取不到数据就会阻塞$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(SIGCHLD, function ($sig) {//必须为false非阻塞模式while ($ret swoole_process::wait(false)) {echo 子进程 PID : {$ret[pid]} 退出\n;}});二、通过 swoole_event_add 将管道设为异步来进行通信$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) 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;}});三、使用消息队列来完成进程间通信$worker_process_nums 5;$worker_process [];for ($i 0; $i $worker_process_nums; $i) {//注意这里将参数$pipe_type设为false表示不创建管道$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();}, 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); 定时检测进程是否存活。//每隔1秒触发SIGALAM信号//注意alarm不能和Timer同时使用swoole_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 我被ctrlc了\n;//退出主进程不然将一直无法正常退出exit(0);});希望本文所述对大家PHP程序设计有所帮助。
