🔥码云GVP开源项目 12k star Uniapp+ElementUI 功能强大 支持多语言、二开方便! 广告
# Process swoole-1.7.2增加了一个进程管理模块,用来替代PHP的pcntl扩展。 需要注意Process进程在系统是非常昂贵的资源,创建进程消耗很大。另外创建的进程过多会导致进程切换开销大幅上升。可以使用`vmstat`指令查看操作系统每秒进程切换的次数。 ```shell 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提供了如下特性: ---- * swoole_process提供了基于unixsock的进程间通信,使用很简单只需调用write/read或者push/pop即可 * swoole_process支持重定向标准输入和输出,在子进程内echo不会打印屏幕,而是写入管道,读键盘输入可以重定向为管道读取数据 * 配合swoole_event模块,创建的PHP子进程可以异步的事件驱动模式 * swoole_process提供了exec接口,创建的进程可以执行其他程序,与原PHP父进程之间可以方便的通信 一个同步实例: ---- * 子进程异常退出时,自动重启 * 主进程异常退出时,子进程在干完手头活后退出 ```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; } } } }); ```