PHP进程管理

 

这篇文章是对之前一篇文章的补充和改进, 创建一个主(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";
}