2020-10-29
PHP 多进程与信号中断实现多任务常驻内存管理实例方法

PHP 多进程与信号中断实现多任务常驻内存管理实例方法

本文章基于 pcntl 扩展做的多进程测试。 进程调度策略 父子进程的调度由操作系统来负责,具体先调度子进程还是父进程由系统的调度算法决定,当然可以在父进程加上延时或是调用进程回收函数 pcntl_wait 可以先让子进程先运行,进程回收的目的是释放进程创建时占用的内存空间,防止变成僵尸进程。 信号: 信号称为软中断系统或是叫软中断,功能是向进程发送异步事件通知。 信号编号: 【源码基于 SIGINT,SIGTERM,SIGUSR1 信号,含义请自行查看 kill 命令手册,不在描述】 linux 支持 64 个,有一半为实时信号,一半为非时实信号,这些信号都有自己的编号和对应的整数值。每个信号的编号含义读者可以参阅 linux 相关手册【man 手册看看就知道了】 信号处理函数: 信号一般会绑定相应的功能,有的是默认动作如 SIGKILL,SIGTERM,SIGINT 操作默认操作就是干掉进程,当然我们可以重写覆盖掉,就是通过 pcntl_signal 来覆盖掉。 信号的概念:与硬件中断一个道理,请读者自行参考本人前面撸过的文章或是查看芯片硬件中断原理。 信号的发送: kill 信号编号 进程 或是按键产品的中断信号或是在源码里可以使用 posix_kill 等函数。 进程是相互隔离的,拥有自己的堆栈空间,除了一些公用的正文【代码区】,同时也有自己的可执行代码,进程运行时,将占用 cpu 的资源,其它进程将无权运行,此时其它进程将为阻塞状态【比如前面撸过的 tcp 服务】,当进程运行结束后【运行到代码的最后一句或是遇到 return 或是遇到 exit 退出进程函数或是遇到信号事件时将会退出】让出权限并释放掉内存,其它进程就有机会运行了。 进程拥有的自己进程描述符,其中比较常用的是进程号 PID,进程运行时会在系统 /proc/PID 下生成相应的进程文件,用户可以自行查看。 每个进程都拥有所属的进程组【进程的集合】,多个进程组集合则是一个会话,创建一个会话是通过一个进程进行创建的,并且此进程不可以为组长进程,此进程将成为会话期的会话首进程,也会成为进程组的进程组长,同时将会脱离控制终端,即使之前的进程绑定了控制终端也会脱离【守护进程的创建】。 文件描述权限掩码【权限屏蔽字】: umask () 你可以在 linux 运行这个命令,然后创建文件,并查看它的权限【如果你跑完啥也没有发现,说明你还是训练不够 ^_^】<?php/** * Created by PhpStorm. * User: [email protected] * Date: 2018/3/26 * Time: 14:19 */namespace Chen\Worker;class Server{ public $workerPids = []; public $workerJob = []; public $master_pid_file = "master_pid"; public $state_file = "state_file.txt"; function run() { $this->daemon(); $this->worker(); $this->setMasterPid(); $this->installSignal(); $this->showState(); $this->wait(); } function wait() { while (1){ pcntl_signal_dispatch(); $pid = pcntl_wait($status); if ($pid>0){ unset($this->workerPids[$pid]); }else{ if (count($this->workerPids)==0){ exit(); } } usleep(100000); } } function showState() { $state = "\nMaster 信息\n"; $state.=str_pad("master pid",25); $state.=str_pad("worker num",25); $state.=str_pad("job pid list",10)."\n"; $state.=str_pad($this->getMasterPid(),25); $state.=str_pad(count($this->workerPids),25); $state.=str_pad(implode(",",array_keys($this->workerPids)),10); echo $state.PHP_EOL; } function getMasterPid() { if (file_exists($this->master_pid_file)){ return file_get_contents($this->master_pid_file); }else{ exit("服务未运行\n"); } } function setMasterPid() { $fp = fopen($this->master_pid_file,"w"); @fwrite($fp,posix_getpid()); @fclose($fp); } function daemon() { $pid = pcntl_fork(); if ($pid<0){ exit("fork进程失败\n"); }else if ($pid >0){ exit(0); }else{ umask(0); $sid = posix_setsid(); if ($sid<0){ exit("创建会话失败\n"); } $pid = pcntl_fork(); if ($pid<0){ exit("进程创建失败\n"); }else if ($pid >0){ exit(0); } //可以关闭标准输入输出错误文件描述符【守护进程不需要】 } } function worker() { if (count($this->workerJob)==0)exit("没有工作任务\n"); foreach($this->workerJob as $job){ $pid = pcntl_fork(); if ($pid<0){ exit("工作进程创建失败\n"); }else if ($pid==0){ /***************子进程工作范围**********************/ //给子进程安装信号处理程序 $this->workerInstallSignal(); $start_time = time(); while (1){ pcntl_signal_dispatch(); if ((time()-$start_time)>=$job->job_run_time){ break; } $job->run(posix_getpid()); } exit(0);//子进程运行完成后退出 /***************子进程工作范围**********************/ }else{ $this->workerPids[$pid] = $job; } } } function workerInstallSignal() { pcntl_signal(SIGUSR1,[__CLASS__,'workerHandleSignal'],false); } function workerHandleSignal($signal) { switch ($signal){ case SIGUSR1: $state = "worker pid=".posix_getpid()."接受了父进程发来的自定义信号\n"; file_put_contents($this->state_file,$state,FILE_APPEND); break; } } function installSignal() { pcntl_signal(SIGINT,[__CLASS__,'handleMasterSignal'],false); pcntl_signal(SIGTERM,[__CLASS__,'handleMasterSignal'],false); pcntl_signal(SIGUSR1,[__CLASS__,'handleMasterSignal'],false); } function handleMasterSignal($signal) { switch ($signal){ case SIGINT: //主进程接受到中断信号ctrl+c foreach ($this->workerPids as $pid=>$worker){ posix_kill($pid,SIGINT);//向所有的子进程发出 } exit("服务平滑停止\n"); break; case SIGTERM://ctrl+z foreach ($this->workerPids as $pid=>$worker){ posix_kill($pid,SIGKILL);//向所有的子进程发出 } exit("服务停止\n"); break; case SIGUSR1://用户自定义信号 if (file_exists($this->state_file)){ unlink($this->state_file); } foreach ($this->workerPids as $pid=>$worker){ posix_kill($pid,SIGUSR1); } $state = "master pid\n".$this->getMasterPid()."\n"; while(!file_exists($this->state_file)){ sleep(1); } $state.= file_get_contents($this->state_file); echo $state.PHP_EOL; break; } }} <?php/**\ * Created by PhpStorm.\ * User: [email protected] * Date: 2018/3/26\ * Time: 14:37\ */\namespace Chen\Worker;class Job{ public $job_run_time = 3600; function run($pid) {\sleep(3); echo "worker pid = $pid job 没事干,就在这里job\n"; }} <?php/** * Created by PhpStorm.\ * User: [email protected]om * Date: 2018/3/26\ * Time: 14:37\ */\namespace Chen\Worker;class Talk{ public $job_run_time = 3600; function run($pid) {\sleep(3); echo "worker pid = $pid job 没事干,就在这里talk\n"; }}<?php/** * Created by PhpStorm.\ * User: [email protected] * Date: 2018/3/26\ * Time: 15:45\ */require_once 'vendor/autoload.php';$process = new \Chen\Worker\Server();$process->workerJob = [new \Chen\Worker\Talk(),new \Chen\Worker\Job()];$process->run(); 以上就是PHP 多进程与信号中断实现多任务常驻内存管理【Master/Worker 模型】的详细内容,感谢大家的学习和对梦主博客的支持。...
2020-10-28
PHP多进程简单实例小结

PHP多进程简单实例小结

本文实例讲述了PHP多进程。分享给大家供大家参考,具体如下:PHP创建多进程需要使用到pcntl模块 在编译时加上--enable-pcntl打开进程控制支持,不是Unix类系统不支持此模块php官网介绍http://php.net/manual/zh/book.pcntl.php,创建子进程需要使用到pcntl_fork(),文档上介绍该函数说 ,pcntl_fork — 在当前进程当前位置产生分支(子进程)。译注:fork是创建了一个子进程,父进程和子进程 都从fork的位置开始向下继续执行,不同的是父进程执行过程中,得到的fork返回值为子进程号,而子进程得到的是0。失败时,在 父进程上下文返回-1,不会创建子进程,并且会引发一个PHP错误。<?php $pid = pcntl_fork(); var_dumP($pid);?>运行上面面代码,会返回两个值,一个是0和子进程的PID;<?php $i=0; while($i!=5){ $pid = pcntl_fork(); echo "进程ID:".$pid."==".$i++.PHP_EOL; } ?>运行上面程序发现进程数指数增长 刚好是2^5=32个;原因是每一条都执行了while循环,到最后成了进程的指数增长——也就是说fork的时候把while循环也带了进去,父进程在执行fork的过程中;会得到子进程的进程号而子进程会的得到是0;意味着0就是子进程标志;改正后代码是这样的<?php $i=0; while($i!=5){   $pid = pcntl_fork();   echo "进程ID:".$pid."==".$i++.PHP_EOL;   if ($pid == 0) {     //code     exit(0);   } }?>更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》希望本文所述对大家PHP程序设计有所帮助。...
2020-10-28
php实现的简单多进程服务器类完整示例

php实现的简单多进程服务器类完整示例

本文实例讲述了php实现的简单多进程服务器类。分享给大家供大家参考,具体如下:php写的一个简单的多进程服务器。<?phpclass server{ public $port; public $ip; protected $server; public function __construct($ip = '0.0.0.0', $port) { $this->ip = $ip; $this->port = $port; $this->createSocket(); //创建一个通讯节点 } public function listen($callback) { if(!is_callable($callback)){ throw new Exception('不是闭包,请传递正确的参数'); } //只要我们接收到客户端的数据,就fork一个子进程处理 while ($client = socket_accept($this->server)) { //等待客户端接入,返回的是客户端的连接 $buf = socket_read($client, 1024); //读取客户端内容 $pid=pcntl_fork(); //创建子进程 //父进程和子进程都会执行下面代码 if ($pid == -1) { //错误处理:创建子进程失败时返回-1. die('could not fork'); } else if ($pid) { //父进程会得到子进程号,所以这里是父进程执行的逻辑 var_dump('父进程',$pid); pcntl_wait($status); //等待子进程中断,防止子进程成为僵尸进程。 } else { //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。 //睡眠 if($this->checkRule("/sleep/i",$buf)){ sleep(10); $this->response('休眠10S',$client); socket_close($client); return; } //请求过滤 if(empty($this->checkRule("/GET\s(.*?)\sHTTP\/1.1/i",$buf))){ socket_close($client); return; } //响应 $response= call_user_func($callback,$buf); //回调$callback函数 $this->response($response,$client); usleep(1000); //微妙为单位,1000000 微妙等于1秒 socket_close($client); exit(); //直接退出 } }// while (true) {// $client = socket_accept($this->server); //等待客户端接入,返回的是客户端的连接// $buf = socket_read($client, 1024); //读取客户端内容//// //睡眠// if($this->checkRule("/sleep/i",$buf)){// sleep(10);// $this->response('休眠10S',$client);// socket_close($client);// return;// }// //请求过滤// if(empty($this->checkRule("/GET\s(.*?)\sHTTP\/1.1/i",$buf))){// socket_close($client);// return;// }//// //响应// $response= call_user_func($callback,$buf); //回调$callback函数// $this->response($response,$client);// usleep(1000); //微妙为单位,1000000 微妙等于1秒// socket_close($client);//// } socket_close($this->server); } //io 复用 //epoll 模型 //多进程 protected function createSocket() { $this->server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); //bind socket_set_option($this->server, SOL_SOCKET, SO_REUSEADDR, 1); //复用还处于 TIME_WAIT socket_bind($this->server, $this->ip, $this->port); //细节性的处理自行完成 socket_listen($this->server); //开始监听 } /** * 协议过滤 * @param $reg * @param $buf * @return mixed */ protected function checkRule($reg,$buf){ if(preg_match($reg,$buf,$matchs)){ return $matchs; } return false; } //请求处理类 public function request($buf){ //1.只允许http协议访问// if(preg_match("GET\s(.*?)\sHTTP/1.1",$buf,$matchs)){ //匹配到http协议// return true;// }else{// return false;// } //2.过滤掉/favicon.ico //3.获取请求信息 } protected function response($content,$client){ //返回数据给客户端,响应处理 $string="HTTP/1.1 200 OK\r\n"; $string.="Content-Type: text/html;charset=utf-8\r\n"; $string.="Content-Length: ".strlen($content)."\r\n\r\n"; socket_write($client,$string.$content); }}更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》希望本文所述对大家PHP程序设计有所帮助。...
2020-10-28
php 多进程编程父进程的阻塞与非阻塞实例分析

php 多进程编程父进程的阻塞与非阻塞实例分析

本文实例讲述了php 多进程编程父进程的阻塞与非阻塞。分享给大家供大家参考,具体如下: php中进程的阻塞,主要是父进程等待子进程退出。 1.php代码如下:<?php//定义进程数量define('FORK_NUMS', 5);//用于保存进程pid$pids = array();//我们创建5个子进程for ($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if ($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { //这里是父进程空间,也就是主进程 //我们的for循环第一次进入到这里时,pcntl_wait会挂起当前主进程,等待第一个子进程执行完毕退出 //注意for循环的代码是在主进程的,挂起主进程,相当于当前的for循环也阻塞在这里了 //第一个子进程退出后,然后再创建第二个子进程,到这里后又挂起,等待第二个子进程退出,继续创建第三个,等等。。 pcntl_wait($status); } else { //这里是子进程空间 echo "父进程ID: ", posix_getppid(), " 进程ID : ", posix_getpid(), " {$i} \r\n"; //我们让子进程等待3秒,再退出 sleep(3); exit; }} 上面代码结果如下: 如果我们把pcntl_wait拿到for循环外,会是个什么结果? 2.php代码如下:<?php//定义进程数量define('FORK_NUMS', 5);//用于保存进程pid$pids = array();//我们创建5个子进程for ($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if ($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { } else { //这里是子进程空间 echo "父进程ID: ", posix_getppid(), " 进程ID : ", posix_getpid(), " {$i} \r\n"; //我们让子进程等待3秒,再退出 sleep(3); exit; }}//我们把pcntl_waitpid放到for循环外面,那样在for循环里创建子进程就不会阻塞了//但是在这里仍会阻塞,主进程要等待5个子进程都退出后,才退出。foreach ($pids as $pid) { pcntl_waitpid($pid, $status);} 上面代码结果如下: pcntl_wait的第二个参数可以用来设置主进程不等待子进程退出,继续执行后续代码。 3.php代码如下:<?php//定义进程数量define('FORK_NUMS', 5);//用于保存进程pid$pids = array();//我们创建5个子进程for ($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if ($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { //这里是父进程空间,也就是主进程 //这里与1.php的代码只有一点不同,就是加了第二个参数WNOHANG //for循环到这里时,就不会挂起主进程,而是继续执行后续代码 pcntl_wait($status, WNOHANG); } else { //这里是子进程空间 echo "父进程ID: ", posix_getppid(), " 进程ID : ", posix_getpid(), " {$i} \r\n"; //我们让子进程等待3秒,再退出 sleep(3); exit; }}//在这里我们等待10秒,不然子进程还没执行完,主进程就退出了,看不出效果sleep(10); 上面代码结果如下: 代码3.php与2.php效果一样,pcntl_wait()函数的作用只是用来让父进程等待子进程退出,默认情况下会阻塞主进程。 更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》 希望本文所述对大家PHP程序设计有所帮助。...
2020-10-28
php 的多进程操作实践案例分析

php 的多进程操作实践案例分析

本文实例讲述了php 的多进程操作。分享给大家供大家参考,具体如下:php的多进程处理依赖于pcntl扩展,通过pcntl_fork创建子进程来进行并行处理。例1如下:<?php$pid = pcntl_fork();if($pid == -1) { //错误处理:创建子进程失败时返回-1. die('fork error');} else if ($pid) { //父进程会得到子进程号,所以这里是父进程执行的逻辑 echo "parent \n"; //等待子进程中断,防止子进程成为僵尸进程。 pcntl_wait($status);} else { //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。 echo "child \n"; exit;}pcntl_fork创建了子进程,父进程和子进程都继续向下执行,而不同是父进程会获取子进程的$pid也就是$pid不为零。而子进程会获取$pid为零。通过if else语句判断$pid我们就可以在指定位置写上不同的逻辑代码。上述代码会分别输出parent和child。那么输出的parent和child是否会有顺序之分?是父进程会先执行?例2如下:<?php$pid = pcntl_fork();if($pid == -1) { die('fork error');} else if ($pid) { sleep(3); echo "parent \n"; pcntl_wait($status);} else { echo "child \n"; exit;}我们在父进程中通过sleep来延缓执行,看看效果。结果是,很快输出了child,等待了接近3秒后,才输出parent。所以父进程和子进程的执行是相对独立的,没有先后之分。那么问题又来了?pcntl_wait是做什么用的?会挂起当前进程,直到子进程退出,如果子进程在调用此函数之前就已退出,此函数会立刻返回。子进程使用的资源将被释放。例3如下:<?php$pid = pcntl_fork();if($pid == -1) { die('fork error');} else if ($pid) { pcntl_wait ($status); echo "parent \n";} else { sleep(3); echo "child \n"; exit;}上述代码,我们可以看到,父进程执行pcntl_wait时就已经挂起,直到等待3秒后输出child,子进程退出后。父进程继续执行,输出parent。例4如下:<?phpdefine('FORK_NUMS', 3);$pids = array();for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { pcntl_waitpid($pids[$i], $status); echo "pernet \n"; } else { sleep(3); echo "child id:" . getmypid() . " \n"; exit; }}上述代码,我们创建3个子进程,父进程分别挂起等待子进程结束后,输出parent。输出结果如下:child id:19090pernetchild id:19091pernetchild id:19092pernet例5如下:<?phpdefine('FORK_NUMS', 3);$pids = array();for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { } else { sleep(3); echo "child id:" . getmypid() . " \n"; exit; }}foreach($pids as $k => $v) { if($v) { pcntl_waitpid($v, $status); echo "parent \n"; }}输出结果如下:child id:19118child id:19119child id:19120parentparentparent为什么上述代码跟例4的输出结果不一样?我们可以看到例5的pcntl_waitpid函数放在了foreach中,foreach代码是在主进程中,也就是父进程的代码中。当执行foreach时,可能子进程已经全部执行完毕并退出。pcntl_waitpid会立刻返回,连续输出三个parent。(*在子进程中,需通过exit来退出,不然会产生递归多进程,父进程中不需要exit,不然会中断多进程。)例6如下:<?phpdefine('FORK_NUMS', 3);$pids = array();$fp = fopen('./test.log', 'wb');$num = 1;for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { } else { for($i = 0; $i < 5; ++$i) { flock($fp, LOCK_EX); fwrite($fp, getmypid() . ' : ' . date('Y-m-d H:i:s') . " : {$num} \r\n"); flock($fp, LOCK_UN); echo getmypid(), ": success \r\n"; ++$num; } exit; }}foreach($pids as $k => $v) { if($v) { pcntl_waitpid($v, $status); }}fclose($fp);代码如上:我们创建三个子进程,来同时向test.log文件写入内容,test.log内容如下:19507 : 2016-03-16 20:40:52 : 119507 : 2016-03-16 20:40:52 : 219507 : 2016-03-16 20:40:52 : 319507 : 2016-03-16 20:40:52 : 419507 : 2016-03-16 20:40:52 : 519509 : 2016-03-16 20:40:52 : 119509 : 2016-03-16 20:40:52 : 219509 : 2016-03-16 20:40:52 : 319509 : 2016-03-16 20:40:52 : 419509 : 2016-03-16 20:40:52 : 519508 : 2016-03-16 20:40:52 : 119508 : 2016-03-16 20:40:52 : 219508 : 2016-03-16 20:40:52 : 319508 : 2016-03-16 20:40:52 : 419508 : 2016-03-16 20:40:52 : 5我们可以看到三个子进程的pid,它们分别执行了5次,时间几乎是在同时。但是$num的值并没像我们期望的那样从1-15进行递增。子进程中的变量是各自独立的,互不影响。子进程会自动复制父进程空间里的变量。如何在进程中共享数据?我们通过php的共享内存函数shmop来实现。<?phpdefine('FORK_NUMS', 3);$pids = array();$fp = fopen('./test.log', 'wb');$num = 1;//共享内存段的key$shmKey = 123;//创建共享内存段$shmId = shmop_open($shmKey, 'c', 0777, 64);//写入数据到共享内存段shmop_write($shmId, $num, 0);for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { //阻塞,等待子进程退出 //注意这里,如果是非阻塞的话,$num的计数会出现问题。 pcntl_waitpid($pids[$i], $status); } else { //读取共享内存段中的数据 $num = shmop_read($shmId, 0, 64); for($i = 0; $i < 5; ++$i) { fwrite($fp, getmypid() . ' : ' . date('Y-m-d H:i:s') . " : {$num} \r\n"); echo getmypid(), ": success \r\n"; //递增$num $num = intval($num) + 1; } //写入到共享内存段中 shmop_write($shmId, $num, 0); exit; }}//shmop_delete不会实际删除该内存段,它将该内存段标记为删除。shmop_delete($shmId);shmop_close($shmId);fclose($fp);上述代码的运行结果如下:19923 : 2016-03-17 00:05:18 : 119923 : 2016-03-17 00:05:18 : 219923 : 2016-03-17 00:05:18 : 319923 : 2016-03-17 00:05:18 : 419923 : 2016-03-17 00:05:18 : 519924 : 2016-03-17 00:05:18 : 619924 : 2016-03-17 00:05:18 : 719924 : 2016-03-17 00:05:18 : 819924 : 2016-03-17 00:05:18 : 919924 : 2016-03-17 00:05:18 : 1019925 : 2016-03-17 00:05:18 : 1119925 : 2016-03-17 00:05:18 : 1219925 : 2016-03-17 00:05:18 : 1319925 : 2016-03-17 00:05:18 : 1419925 : 2016-03-17 00:05:18 : 15这样我们就在进程间共享了$num的数据。更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》希望本文所述对大家PHP程序设计有所帮助。...
2020-10-28
php多进程并发编程防止出现僵尸进程的方法分析

php多进程并发编程防止出现僵尸进程的方法分析

本文实例讲述了php多进程并发编程防止出现僵尸进程的方法。分享给大家供大家参考,具体如下:对于用PHP进行多进程并发编程,不可避免要遇到僵尸进程的问题。僵尸进程是指的父进程已经退出,而该进程dead之后没有进程接受,就成为僵尸进程(zombie)进程。任何进程在退出前(使用exit退出) 都会变成僵尸进程(用于保存进程的状态等信息),然后由init进程接管。如果不及时回收僵尸进程,那么它在系统中就会占用一个进程表项,如果这种僵尸进程过多,最后系统就没有可以用的进程表项,于是也无法再运行其它的程序。 方法一:父进程通过pcntl_wait和pcntl_waitpid等函数等待子进程结束$pid = pcntl_fork();if($pid == -1) { die('fork error');} else if ($pid) { //父进程阻塞着等待子进程的退出 //pcntl_wait($status); //pcntl_waitpid($pid, $status); //非阻塞方式 //pcntl_wait($status, WNOHANG); //pcntl_waitpid($pid, $status, WNOHANG);} else { sleep(3); echo "child \r\n"; exit;}方法二:可以用signal函数为SIGCHLD安装handler,因为子进程结束后,父进程会收到该信号,可以在handler中调用pcntl_wait或pcntl_waitpid来回收。<?phpdeclare(ticks = 1);//信号处理函数function sig_func() { echo "SIGCHLD \r\n"; pcntl_wait($status); //pcntl_waitpid(-1, $status); //非阻塞 //pcntl_wait($status, WNOHANG); //pcntl_waitpid(-1, $status, WNOHANG);}pcntl_signal(SIGCHLD, 'sig_func');$pid = pcntl_fork();if($pid == -1) { die('fork error');} else if ($pid) { sleep(10);} else { sleep(3); echo "child \r\n"; exit;}如果子进程还没有结束时,父进程就结束了,那么init进程会自动接手这个子进程,进行回收。如果父进程是循环,又没有安装SIGCHLD信号处理函数调用wait或waitpid()等待子进程结束。那么子进程结束后,没有回收,就产生僵尸进程了。 例如:<?php$pid = pcntl_fork();if($pid == -1) { die('fork error');} else if ($pid) { for(;;) { sleep(3); }} else { echo "child \r\n"; exit;}父进程是个死循环,也没有安装SIGCHLD信号处理函数,子进程结束后。我们通过如下命令查看> ps -A -o stat,ppid,pid,cmd | grep -e '^[Zz]'会发现一个僵尸进程。 代码改进一下:<?phpdeclare(ticks = 1);//信号处理函数function sig_func() { echo "SIGCHLD \r\n"; pcntl_waitpid(-1, $status, WNOHANG);}pcntl_signal(SIGCHLD, 'sig_func');$pid = pcntl_fork();if($pid == -1) { die('fork error');} else if ($pid) { for(;;) { sleep(3); }} else { echo "child \r\n"; exit;}当子进程结束后,再通过命令查看时,我们发现这时就没有僵尸进程了,这说明父进程对它进行了回收。 方法三:如果父进程不关心子进程什么时候结束,那么可以用pcntl_signal(SIGCHLD, SIG_IGN)通知内核,自己对子进程的结束不感兴趣,那么子进程结束后,内核会回收,并不再给父进程发送信号。<?phpdeclare(ticks = 1);pcntl_signal(SIGCHLD, SIG_IGN);$pid = pcntl_fork();if($pid == -1) { die('fork error');} else if ($pid) { for(;;) { sleep(3); }} else { echo "child \r\n"; exit;}当子进程结束后,SIGCHLD信号并不会发送给父进程,而是通知内核对子进程进行了回收。 方法四:通过pcntl_fork两次,也就是父进程fork出子进程,然后子进程中再fork出孙进程,这时子进程退出。那么init进程会接管孙进程,孙进程退出后,init会回收。不过子进程还是需要父进程进行回收。我们把业务逻辑放到孙进程中执行,父进程就不需要pcntl_wait或pcntl_waitpid来等待孙进程(即业务进程)。<?php$pid = pcntl_fork();if($pid == -1) { die('fork error');} else if ($pid) { //父进程等待子进程退出 pcntl_wait($status); echo "parent \r\n";} else { //子进程再fork一次,产生孙进程 $cpid = pcntl_fork(); if($cpid == -1) { die('fork error'); } else if ($cpid) { //这里是子进程,直接退出 echo "child \r\n"; exit; } else { //这里是孙进程,处理业务逻辑 for($i = 0; $i < 10; ++$i) { echo "work... \r\n"; sleep(3); } }}子进程退出后,父进程回收子进程,孙进程继续业务逻辑的处理。当孙进程也执行完毕退出后,init回收孙进程。更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》希望本文所述对大家PHP程序设计有所帮助。...
2020-10-28
php多进程中的阻塞与非阻塞操作实例分析

php多进程中的阻塞与非阻塞操作实例分析

本文实例讲述了php多进程中的阻塞与非阻塞操作。分享给大家供大家参考,具体如下:我们通过pcntl_fork来创建子进程,使用pcntl_wait和pcntl_waitpid来回收子进程。子进程退出后,父进程没有及时回收,就会产生僵尸进程。例1:<?phpdefine('FORK_NUMS', 5);$pids = array(); //我们创建5个子进程for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { pcntl_wait($status); } else { echo getmypid() , " {$i} \r\n"; exit; }}我们通过for循环fork出5个子进程,父进程会阻塞着等待子进程退出,然后创建下一个子进程。上述代码输出结果如下:20081 020082 120083 220084 320085 4但我们创建多进程的目的,就是为了能够并行的处理任务,阻塞的方式并不是我们想看到的。例2:<?phpdefine('FORK_NUMS', 5); $pids = array(); //我们创建5个子进程for($i = 0; $i < FORK_NUMS; ++$i) { $pids[$i] = pcntl_fork(); if($pids[$i] == -1) { die('fork error'); } else if ($pids[$i]) { pcntl_wait($status, WNOHANG); } else { echo getmypid() , " {$i} \r\n"; exit; }}我们可以通过设置pcntl_wait的第二个参数为WNOHANG来控制进程是否阻塞。该函数可以在没有子进程退出的情况下立刻跳出执行后续代码。 pcntl_wait等同于以pid为-1调用pcntl_waitpid函数。 pcntl_waitpid函数可以等待指定pid的进程。更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》希望本文所述对大家PHP程序设计有所帮助。...
技术教程 1480次浏览0条评论
微信二维码