• Process
    • 使用实例

    Process

    1.7.2版本增加了一个进程管理模块，用来替代PHP的pcntl。

    需要注意Process进程在系统是非常昂贵的资源，创建进程消耗很大。另外创建的进程过多会导致进程切换开销大幅上升。可以使用vmstat指令查看操作系统每秒进程切换的次数。

    1. vmstat 1 1000
    2. procs -----------memory---------- ---swap-- -----io---- -system-- ------cpu-----
    3.  r  b   swpd   free   buff  cache   si   so    bi    bo   in   cs us sy id wa st
    4.  0  0      0 8250028 509872 4061168    0    0    10    13   88   86  1  0 99  0  0
    5.  0  0      0 8249532 509872 4061936    0    0     0     0  451 1108  0  0 100  0  0
    6.  0  0      0 8249532 509872 4061884    0    0     0     0  684 1855  1  3 95  0  0
    7.  0  0      0 8249532 509880 4061876    0    0     0    16  492 1332  0  0 99  0  0
    8.  0  0      0 8249532 509880 4061844    0    0     0     0  379  893  0  0 100  0  0
    9.  0  0      0 8249532 509880 4061844    0    0     0     0  440 1116  0  0 99  0  0

    PHP自带的pcntl，存在很多不足，如：

    • pcntl没有提供进程间通信的功能
    • pcntl不支持重定向标准输入和输出
    • pcntl只提供了fork这样原始的接口，容易使用错误

    • swoole_process提供了比pcntl更强大的功能，更易用的API，使PHP在多进程编程方面更加轻松。
      Swoole\Process提供了如下特性：

    • 基于Unix Socket和sysvmsg消息队列的进程间通信，只需调用write/read或者push/pop即可

    • 支持重定向标准输入和输出，在子进程内echo不会打印屏幕，而是写入管道，读键盘输入可以重定向为管道读取数据
    • 配合Event模块，创建的PHP子进程可以异步的事件驱动模式
    • 提供了exec接口，创建的进程可以执行其他程序，与原PHP父进程之间可以方便的通信

    使用实例

    • 子进程异常退出时，自动重启
    • 主进程异常退出时，子进程会继续执行，完成所有任务后退出
    1. (new class{
    2.     public $mpid=0;
    3.     public $works=[];
    4.     public $max_precess=1;
    5.     public $new_index=0;
    7.     public function __construct(){
    8.         try {
    9.             swoole_set_process_name(sprintf('php-ps:%s', 'master'));
    10.             $this->mpid = posix_getpid();
    11.             $this->run();
    12.             $this->processWait();
    13.         }catch (\Exception $e){
    14.             die('ALL ERROR: '.$e->getMessage());
    15.         }
    16.     }
    18.     public function run(){
    19.         for ($i=0; $i < $this->max_precess; $i++) {
    20.             $this->CreateProcess();
    21.         }
    22.     }
    24.     public function CreateProcess($index=null){
    25.         $process = new swoole_process(function(swoole_process $worker)use($index){
    26.             if(is_null($index)){
    27.                 $index=$this->new_index;
    28.                 $this->new_index++;
    29.             }
    30.             swoole_set_process_name(sprintf('php-ps:%s',$index));
    31.             for ($j = 0; $j < 16000; $j++) {
    32.                 $this->checkMpid($worker);
    33.                 echo "msg: {$j}\n";
    34.                 sleep(1);
    35.             }
    36.         }, false, false);
    37.         $pid=$process->start();
    38.         $this->works[$index]=$pid;
    39.         return $pid;
    40.     }
    41.     public function checkMpid(&$worker){
    42.         if(!swoole_process::kill($this->mpid,0)){
    43.             $worker->exit();
    44.             // 这句提示,实际是看不到的.需要写到日志中
    45.             echo "Master process exited, I [{$worker['pid']}] also quit\n";
    46.         }
    47.     }
    49.     public function rebootProcess($ret){
    50.         $pid=$ret['pid'];
    51.         $index=array_search($pid, $this->works);
    52.         if($index!==false){
    53.             $index=intval($index);
    54.             $new_pid=$this->CreateProcess($index);
    55.             echo "rebootProcess: {$index}={$new_pid} Done\n";
    56.             return;
    57.         }
    58.         throw new \Exception('rebootProcess Error: no pid');
    59.     }
    61.     public function processWait(){
    62.         while(1) {
    63.             if(count($this->works)){
    64.                 $ret = swoole_process::wait();
    65.                 if ($ret) {
    66.                     $this->rebootProcess($ret);
    67.                 }
    68.             }else{
    69.                 break;
    70.             }
    71.         }
    72.     }
    73. });