這篇文章是對之前一篇文章的補(bǔ)充和改進(jìn), 創(chuàng)建一個主(master)進(jìn)程，主進(jìn)程安裝定時器，每隔5分鐘檢測一次隊(duì)列長度，根據(jù)隊(duì)列長度計算需要的worker進(jìn)程，
然后創(chuàng)建或者殺掉子進(jìn)程。這樣做的好處是防止隊(duì)列堆積，任務(wù)得不到及時處理。更新業(yè)務(wù)代碼，只需要reload操作即可。
整個流程有以下知識點(diǎn)：
創(chuàng)建守護(hù)進(jìn)程的步驟:
- 設(shè)置默認(rèn)文件權(quán)限
- fork一個進(jìn)程，父進(jìn)程退出
- 調(diào)用setsid創(chuàng)建一個新的會話
- 將當(dāng)前工作目錄更改為根目錄
- 關(guān)閉不再需要的文件描述符
使用信號實(shí)現(xiàn)定時器
上一篇定時器依賴于系統(tǒng)的定時任務(wù)，這次使用鬧鐘信號實(shí)現(xiàn)，php 5.3.0以下的版本依賴于ticks，5.3.0及以上版本可使用pcntl_signal_dispatch
信號：提供了一種異步事件處理的方法，在某個信號出現(xiàn)時，進(jìn)程有以下三種方式對信號進(jìn)行處理
- 忽略此信號
- 捕捉信號
- 執(zhí)行系統(tǒng)默認(rèn)動作，大多數(shù)信號的默認(rèn)動作是終止該進(jìn)程
常見信號
SIGKILL，SIGSTOP是兩種不能被用戶忽略和捕捉的信號
SIGINT(2):程序終止信號,通常是Ctrl-C)時發(fā)出，用于通知前臺進(jìn)程組終止進(jìn)程
SIGQUIT(3):和SIGINT類似, 但由QUIT字符(通常是Ctrl+/)來控制. 進(jìn)程收到該消息退出時會產(chǎn)生core文件
SIGKILL(9):立即終止進(jìn)程,不可被忽略捕捉或阻塞
SIGUSR1(10):用戶定義信號
SIGUSR2(12):留給用戶使用
SIGALRM(14):鬧鐘信號
SIGTERM(15):終止進(jìn)程,可被程序捕捉，使得進(jìn)程可以執(zhí)行完清理操作。
SIGSTOP(19):停止一個進(jìn)程,該進(jìn)程還未結(jié)束, 只是暫停執(zhí)行
防止產(chǎn)生僵尸進(jìn)程
所有的進(jìn)程在退出的時候都會成為僵尸進(jìn)程，這時候如果父進(jìn)程還在運(yùn)行，沒有調(diào)用wait或者waitpid，則僵尸進(jìn)程占用的資源不會被清理，如果父進(jìn)程已終止，僵尸進(jìn)程由init進(jìn)程進(jìn)行清理。
抽調(diào)業(yè)務(wù)代碼，主要代碼如下
其中要注意的一點(diǎn)，創(chuàng)建守護(hù)進(jìn)程關(guān)閉輸入輸出，錯誤輸出流的時候，如果代碼后面有echo等輸出字符，將出現(xiàn)致命錯誤，需要在php代碼中重定向輸出流到/dev/null。或者在終端啟動進(jìn)程的時候進(jìn)行重定向
?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;
}
//設(shè)置默認(rèn)文件權(quán)限
umask(022);
//fork
$pid = pcntl_fork();
if($pid 0){
exit('fork error!');
}else if($pid > 0){
exit;
}
//脫離當(dāng)前終端
posix_setsid();
//將當(dāng)前工作目錄更改為根目錄
chdir('/');
//關(guān)閉文件描述符
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);//此處檢測你需要的進(jìn)程數(shù)
$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進(jìn)程管理詳解整合，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！
您可能感興趣的文章:- PHP如何限制定時任務(wù)的進(jìn)程數(shù)量
- PHP基于進(jìn)程控制函數(shù)實(shí)現(xiàn)多線程
- PHP程序守護(hù)進(jìn)程化實(shí)現(xiàn)方法詳解
- 一文看懂PHP進(jìn)程管理器php-fpm
- php多進(jìn)程中的阻塞與非阻塞操作實(shí)例分析
- php多進(jìn)程并發(fā)編程防止出現(xiàn)僵尸進(jìn)程的方法分析
- PHP多進(jìn)程通信-消息隊(duì)列使用
- php多進(jìn)程模擬并發(fā)事務(wù)產(chǎn)生的問題小結(jié)
- 淺談并發(fā)處理PHP進(jìn)程間通信之外部介質(zhì)
