# Process [TOC] `1.7.2`版本增加了一个进程管理模块，用来替代`PHP`的`pcntl`。 需要注意`Process`进程在系统是非常昂贵的资源，创建进程消耗很大。另外创建的进程过多会导致进程切换开销大幅上升。可以使用`vmstat`指令查看操作系统每秒进程切换的次数。 ~~~ vmstat 1 1000 procs -----------memory---------- ---swap-- -----io---- -system-- ------cpu----- r b swpd free buff cache si so bi bo in cs us sy id wa st 0 0 0 8250028 509872 4061168 0 0 10 13 88 86 1 0 99 0 0 0 0 0 8249532 509872 4061936 0 0 0 0 451 1108 0 0 100 0 0 0 0 0 8249532 509872 4061884 0 0 0 0 684 1855 1 3 95 0 0 0 0 0 8249532 509880 4061876 0 0 0 16 492 1332 0 0 99 0 0 0 0 0 8249532 509880 4061844 0 0 0 0 379 893 0 0 100 0 0 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`父进程之间可以方便的通信 ## 使用实例 * 子进程异常退出时，自动重启 * 主进程异常退出时，子进程会继续执行，完成所有任务后退出 ~~~ (new class{ public $mpid=0; public $works=[]; public $max_precess=1; public $new_index=0; public function __construct(){ try { swoole_set_process_name(sprintf('php-ps:%s', 'master')); $this->mpid = posix_getpid(); $this->run(); $this->processWait(); }catch (\Exception $e){ die('ALL ERROR: '.$e->getMessage()); } } public function run(){ for ($i=0; $i < $this->max_precess; $i++) { $this->CreateProcess(); } } public function CreateProcess($index=null){ $process = new swoole_process(function(swoole_process $worker)use($index){ if(is_null($index)){ $index=$this->new_index; $this->new_index++; } swoole_set_process_name(sprintf('php-ps:%s',$index)); for ($j = 0; $j < 16000; $j++) { $this->checkMpid($worker); echo "msg: {$j}\n"; sleep(1); } }, false, false); $pid=$process->start(); $this->works[$index]=$pid; return $pid; } public function checkMpid(&$worker){ if(!swoole_process::kill($this->mpid,0)){ $worker->exit(); // 这句提示,实际是看不到的.需要写到日志中 echo "Master process exited, I [{$worker['pid']}] also quit\n"; } } public function rebootProcess($ret){ $pid=$ret['pid']; $index=array_search($pid, $this->works); if($index!==false){ $index=intval($index); $new_pid=$this->CreateProcess($index); echo "rebootProcess: {$index}={$new_pid} Done\n"; return; } throw new \Exception('rebootProcess Error: no pid'); } public function processWait(){ while(1) { if(count($this->works)){ $ret = swoole_process::wait(); if ($ret) { $this->rebootProcess($ret); } }else{ break; } } } }); ~~~