浅谈PHP进程管理

这篇文章是对之前一篇文章的补充和改进,创建一个主(master)进程，主进程安装定时器，每隔

这篇文章是对之前一篇文章的补充和改进, 创建一个主(master)进程，主进程安装定时器，每隔5分钟检测一次队列长度，根据队列长度计算需要的worker进程，

然后创建或者杀掉子进程。这样做的好处是防止队列堆积，任务得不到及时处理。更新业务代码，只需要reload操作即可。

整个流程有以下知识点：

创建守护进程的步骤:

1. 设置默认文件权限
2. fork一个进程，父进程退出
3. 调用setsid创建一个新的会话
4. 将当前工作目录更改为根目录
5. 关闭不再需要的文件描述符

使用信号实现定时器 上一篇定时器依赖于系统的定时任务，这次使用闹钟信号实现，php 5.3.0以下的版本依赖于ticks，5.3.0及以上版本可使用pcntl_signal_dispatch

信号：提供了一种异步事件处理的方法，在某个信号出现时，进程有以下三种方式对信号进行处理

1. 忽略此信号
2. 捕捉信号
3. 执行系统默认动作，大多数信号的默认动作是终止该进程

常见信号 SIGKILL，SIGSTOP是两种不能被用户忽略和捕捉的信号

SIGINT(2):程序终止信号,通常是Ctrl-C)时发出，用于通知前台进程组终止进程

SIGQUIT(3):和SIGINT类似, 但由QUIT字符(通常是Ctrl+/)来控制. 进程收到该消息退出时会产生core文件

SIGKILL(9):立即终止进程,不可被忽略捕捉或阻塞

SIGUSR1(10):用户定义信号

SIGUSR2(12):留给用户使用

SIGALRM(14):闹钟信号

SIGTERM(15):终止进程,可被程序捕捉，使得进程可以执行完清理操作。

SIGSTOP(19):停止一个进程,该进程还未结束, 只是暂停执行

防止产生僵尸进程 所有的进程在退出的时候都会成为僵尸进程，这时候如果父进程还在运行，没有调用wait或者waitpid，则僵尸进程占用的资源不会被清理，如果父进程已终止，僵尸进程由init进程进行清理。

抽调业务代码，主要代码如下

其中要注意的一点，创建守护进程关闭输入输出，错误输出流的时候，如果代码后面有echo等输出字符，将出现致命错误，需要在php代码中重定向输出流到/dev/null。或者在终端启动进程的时候进行重定向

<?php
define('PROC_MAX', 10);
define('PROC_MIN', 5);
 
$cmd = $argv[1];
$aPid = [];
$pidFile = __DIR__ . '/pid.pid';
$pid = file_get_contents($pidFile);
 
switch($cmd){
 case 'start' :
 if(posix_kill($pid, 0)){
 echo "gamelog process is already exsits!\n";
 return false;
 }
 //设置默认文件权限
 umask(022);
 //fork
 $pid = pcntl_fork();
 if($pid < 0){
 exit('fork error!');
 }else if($pid > 0){
 exit;
 }
 //脱离当前终端
 posix_setsid();
 //将当前工作目录更改为根目录
 chdir('/');
 //关闭文件描述符
 fclose(STDIN);
 fclose(STDOUT);
 fclose(STDERR);
 //重定向输入输出
 global $STDOUT, $STDERR;
 $STDOUT = fopen('/dev/null', 'a');
 $STDERR = fopen('/dev/null', 'a');
 
 cli_set_process_title('gamelog:master');
 $pid = posix_getpid();
 file_put_contents($pidFile, $pid);
 //闹钟信号
 pcntl_signal(SIGALRM, function() use (&$aPid) {
 pcntl_alarm(300);
 $workerNum = mt_rand(1, 20);//此处检测你需要的进程数
 $daemonNum = count($aPid);
 
 ($workerNum > PROC_MAX) && ($workerNum = PROC_MAX);
 if($daemonNum < $workerNum){
 $procNum = $workerNum - $daemonNum;
 $procNum = max(PROC_MIN, $procNum);
 for($p = 1; $p <= $procNum; $p++){
 $pid = pcntl_fork();
 if ($pid < 0) {
 exit('fork error!');
 } else if ($pid == 0) {
 cli_set_process_title('gamelog:worker');
 while (true) {
 //do your work
 usleep(100);
 }
 exit();
 } else {
 $aPid[] = $pid;
 }
 }
 }else if($daemonNum > $workerNum){
 $wokerNum = max($wokerNum, PROC_MIN);
 $killNum = $daemonNum - $workerNum;
 foreach($aPid as $key=>$pid){
 if(posix_kill($pid, SIGKILL)){
 unset($aPid[$key]);
 if(--$killNum <= 0){
 break;
 }
 }
 }
 }
 }, false);
 
 pcntl_signal(SIGUSR1, function() use (&$aPid, $pid){
 foreach($aPid as $key=>$chpid){
 if(!posix_kill($chpid, SIGKILL)){
 echo "kill child $chpid faild\n";
 }
 }
 posix_kill($pid, SIGKILL);
 }, false);
 
 pcntl_signal(SIGUSR2, function() use (&$aPid, $pid){
 foreach($aPid as $key=>$chpid){
 if(!posix_kill($chpid, SIGKILL)){
 echo "kill child $chpid faild\n";
 }
 }
 if(!posix_kill($pid, SIGALRM)){
 echo "restart gamelog faild\n";
 }
 }, false);
 
 posix_kill($pid, SIGALRM);
 while (true) {
 pcntl_signal_dispatch();
 $pid = pcntl_wait($status, WUNTRACED);//不阻塞
 }
 break;
 
 case 'stop' :
 if(!posix_kill($pid, SIGUSR1)){
 exit('stop gamelog process error!');
 }
 break;
 case 'reload' :
 if(!posix_kill($pid, SIGUSR2)){
 exit('restop gamelog process error!');
 }
 break;
 default :
 echo "Useage php signal.php start|stop|reload\n";
}

以上所述是小编给大家介绍的PHP进程管理详解整合，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持！

PHP进程 PHP进程管理