PHP程序管理

PHP · 發表 2018-11-04 16:21:00

摘要：這篇文章是對之前一篇文章的補充和改進, 建立一個主(master)程序，主程序安裝定時器，每隔5分鐘檢測一次佇列長度，根據佇列長度計算需要的worker程序，然後建立或者殺掉子程序。這樣做的好處是防止佇列堆積，任務得不到及時處理。更新業務程式碼，只需要reload操作即可。整個流程...

這篇文章是對之前一篇文章的補充和改進, 建立一個主(master)程序，主程序安裝定時器，每隔5分鐘檢測一次佇列長度，根據佇列長度計算需要的worker程序，

然後建立或者殺掉子程序。這樣做的好處是防止佇列堆積，任務得不到及時處理。更新業務程式碼，只需要reload操作即可。

整個流程有以下知識點：

建立守護程序的步驟:

設定預設檔案許可權
fork一個程序，父程序退出
呼叫setsid建立一個新的會話
將當前工作目錄更改為根目錄
關閉不再需要的檔案描述符

使用訊號實現定時器

上一篇定時器依賴於系統的定時任務，這次使用鬧鐘訊號實現，php 5.3.0以下的版本依賴於ticks，5.3.0及以上版本可使用pcntl_signal_dispatch

訊號：提供了一種非同步事件處理的方法，在某個訊號出現時，程序有以下三種方式對訊號進行處理

忽略此訊號
捕捉訊號
執行系統預設動作，大多數訊號的預設動作是終止該程序

常見訊號

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程序管理

您可能也會喜歡…