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";
}