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

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

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

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

1、基于 unix socket 的管道 pipe。

2、基于 sysvmsg 的消息队列。

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

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

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47

<?php $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 将管道设为异步，来进行通信

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55

<?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 ) 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" ;    } });

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

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51

<?php $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 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22

<?php //每隔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 "我被ctrl+c了\n" ;      //退出主进程，不然将一直无法正常退出    exit (0); });

希望本文所述对大家PHP程序设计有所帮助。

原文链接：https://www.cnblogs.com/jkko123/p/10918056.html