以下是【金聰采編】分享的內(nèi)容全文:
這篇文章是對之前一篇文章的補(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)行重定向
<?phpdefine('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)站的支持!
1.軟件源碼推廣展示:目的展示軟件相關(guān)功能,接收技術(shù)學(xué)習(xí)者測試、測評;
2.教程課程信息展示:展示課程信息,傳授課程各階段內(nèi)容;
3.設(shè)計素材圖片展示:展示素材設(shè)計理念、思維方式、傳播設(shè)計理念;
4.福利優(yōu)惠信息展示:分享各類最新的福利信息,各種優(yōu)惠信息展示;
以上分享目的僅供學(xué)習(xí)、參考使用,請勿用于其他用途,如果想商業(yè)使用或者代理,請自行聯(lián)系版權(quán)方獲取授權(quán)。任何未獲取授權(quán)的商業(yè)使用與本站無關(guān),請自行承擔(dān)相應(yīng)責(zé)任。
本站不存儲任何資源文件,敬請周知!
如果您認(rèn)為本頁信息內(nèi)容侵犯了您的相關(guān)權(quán)益(包含但不限于:著作權(quán)、首發(fā)權(quán)、隱私權(quán)等權(quán)利),或者您認(rèn)為自己是此信息的權(quán)利人但是此信息不是自己發(fā)布的,可以直接版權(quán)舉報投訴,我們會根據(jù)網(wǎng)站注冊協(xié)議、資源分享協(xié)議等協(xié)議處理,以保護(hù)您的合法權(quán)益。
本網(wǎng)站采用 BY-NC-SA 協(xié)議進(jìn)行授權(quán) 轉(zhuǎn)載請注明原文鏈接:淺談PHP進(jìn)程管理

侵權(quán)舉報/版權(quán)申訴



