我們都知道PHP是單進(jìn)程執(zhí)行的，PHP處理多并發(fā)主要是依賴服務(wù)器或PHP-FPM的多進(jìn)程及它們進(jìn)程的復(fù)用，但PHP實(shí)現(xiàn)多進(jìn)程也意義重大，尤其是在后臺(tái)Cli模式下處理大量數(shù)據(jù)或運(yùn)行后臺(tái)DEMON守護(hù)進(jìn)程時(shí)，多進(jìn)程的優(yōu)勢 :?一個(gè)任務(wù)被分解成多個(gè)進(jìn)程執(zhí)行，就會(huì)減少整體的耗時(shí)。
1.多開幾個(gè)進(jìn)程，這種方式簡單實(shí)用，推薦，比如說使用shell腳本:
| 1 2 3 4 5 6 7 8 |
#!/bin/bash
for((i=1;i<=8;i++))
do
????/usr/bin/php?multiprocessTest.php?&
done
wait
|
2.php多進(jìn)程
php多進(jìn)程需要pcntl，可以通過 php -m 查看，而且多進(jìn)程實(shí)現(xiàn)只能在cli模式下。
注：php多進(jìn)程一般應(yīng)用在php_cli命令行中執(zhí)行php腳本，做進(jìn)程任務(wù)時(shí)要檢查php是否開啟了pcntl擴(kuò)展，（pcntl是process control進(jìn)程管理的縮寫。PHP的進(jìn)程控制支持實(shí)現(xiàn)了Unix方式的進(jìn)程創(chuàng)建, 程序執(zhí)行, 信號(hào)處理以及進(jìn)程的中斷（此擴(kuò)展在 Windows 平臺(tái)上不可用）。該擴(kuò)展在PHP中進(jìn)程控制支持默認(rèn)是關(guān)閉的。
1)、安裝pcntl擴(kuò)展
a)、未安裝php7時(shí)添pcntl擴(kuò)展
在配置編譯中增加代碼 --enable-pcntl :
| 1 |
./configure?--enable-pcntl
|
b)、已安裝php7添加pcntl擴(kuò)展
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
###1、進(jìn)入php源碼包里??擴(kuò)展庫目錄
[root@localhost?~]#?cd?/usr/local/src/php-7.1.22
[root@localhost?php-7.1.22]#?cd?ext/pcntl/
###2、用phpize生成配置文件
[root@localhost?pcntl]#?/usr/local/php/bin/phpize
###3、指定配置文件進(jìn)行配置
[root@localhost?pcntl]#./configure?--enable-pcntl?--with-php-config=/usr/local/php/bin/php-config
###4、編譯安裝
[root@localhost?pcntl]#?make?&&?make?install
.....
Installing?shared?extensions:?????/usr/local/php/lib/php/extensions/no-debug-non-zts-20170718/
[root@localhost?pcntl]#
###5、切換到?extensions?目錄：
[root@localhost?~]#?cd?/usr/local/php/lib/php/extensions/no-debug-non-zts-20170718/
[root@localhost?no-debug-non-zts-20170718]#?ls
opcache.a??opcache.so??pcntl.so
###6、查看?php.ini?實(shí)際位置，編輯?php.ini文件
[root@localhost?etc]#?vim?php.ini
添加：
extension=/usr/local/php/lib/php/extensions/no-debug-non-zts-20170718/pcntl.so
###7、添加后?重新啟動(dòng)?php-fpm.service?生效
[root@localhost?~]#?systemctl?restart??php-fpm.service
###8、查看?phpinfo()?信息。
|
2)、創(chuàng)建子進(jìn)程
創(chuàng)建PHP子進(jìn)程是多進(jìn)程的開始，我們需要 pcntl_fork() 函數(shù)；
pcntl_fork() — 在當(dāng)前進(jìn)程當(dāng)前位置產(chǎn)生分支（子進(jìn)程）。此函數(shù)創(chuàng)建了一個(gè)新的子進(jìn)程后，子進(jìn)程會(huì)繼承父進(jìn)程當(dāng)前的上下文，和父進(jìn)程一樣從pcntl_fork()函數(shù)處繼續(xù)向下執(zhí)行，只是獲取到的pcntl_fork()的返回值不同，我們便能從判斷返回值來區(qū)分父進(jìn)程和子進(jìn)程，分配父進(jìn)程和子進(jìn)程去做不同的邏輯處理。
pcntl_fork()函數(shù)成功執(zhí)行時(shí)會(huì)在父進(jìn)程返回子進(jìn)程的進(jìn)程id(pid)。fork是創(chuàng)建了一個(gè)子進(jìn)程，父進(jìn)程和子進(jìn)程 都從fork的位置開始向下繼續(xù)執(zhí)行，不同的是父進(jìn)程執(zhí)行過程中，得到的fork返回值為子進(jìn)程 號(hào)，而子進(jìn)程得到的是0。
而pcntl_fork()函數(shù)在執(zhí)行失敗時(shí)，會(huì)在父進(jìn)程返回-1,當(dāng)然也不會(huì)有子進(jìn)程產(chǎn)生。
| 1 2 3 4 5 6 7 8 9 10 11 12 13 |
<?php
$pid?=?pcntl_fork();
//父進(jìn)程和子進(jìn)程都會(huì)執(zhí)行下面代碼
if?($pid?==?-1)?{
????//錯(cuò)誤處理：創(chuàng)建子進(jìn)程失敗時(shí)返回-1.
?????die('could?not?fork');
}?else?if?($pid)?{
?????//父進(jìn)程會(huì)得到子進(jìn)程號(hào)，所以這里是父進(jìn)程執(zhí)行的邏輯
?????pcntl_wait($status);?//等待子進(jìn)程中斷，防止子進(jìn)程成為僵尸進(jìn)程。
}?else?{
?????//子進(jìn)程得到的$pid為0,?所以這里是子進(jìn)程執(zhí)行的邏輯。
}
|
| 1 2 3 4 5 |
getmypid();?????????//?返回當(dāng)前?PHP?進(jìn)程?ID，或在錯(cuò)誤時(shí)返回?FALSE。
pcntl_fork();???????//?成功時(shí)，在父進(jìn)程執(zhí)行線程內(nèi)返回產(chǎn)生的子進(jìn)程的PID，在子進(jìn)程執(zhí)行線程內(nèi)返回0。
????????????????????//?失敗時(shí)，在?父進(jìn)程上下文返回-1，不會(huì)創(chuàng)建子進(jìn)程，并且會(huì)引發(fā)一個(gè)PHP錯(cuò)誤。
posix_getpid();?????//?獲取當(dāng)前進(jìn)程的pid;
|
以下是fork子進(jìn)程的一個(gè)簡單的小例子：
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
<?php
foreach?(range(1,?5)?as?$index)?{
????$pid?=?pcntl_fork();????
????if?($pid?===?-1)?{????????
????????echo?"failed?to?fork!n";????????
????????exit;
????}?elseif?($pid)?{
????????pcntl_wait($status);?//父進(jìn)程必須等待一個(gè)子進(jìn)程退出后，再創(chuàng)建下一個(gè)子進(jìn)程。
????????echo?"I?am?the?parent,?pid:?$pidn";
????}?else?{
????????$cid?=?posix_getpid();????????
????????echo?"fork?the?{$index}th?child,?pid:?$cidn";????????
????????exit;?//必須
????}
}
|
這個(gè)例子非常簡單，循環(huán)創(chuàng)建5個(gè)進(jìn)程，在各個(gè)進(jìn)程里面打印一句話，主要使用的方法就是函數(shù) pcntl_fork，一次調(diào)用兩次返回，在父進(jìn)程中返回子進(jìn)程pid，在子進(jìn)程中返回0，出錯(cuò)返回-1。
執(zhí)行結(jié)果如下：
| 1 2 3 4 5 6 7 8 9 10 |
fork?the?1th?child,?pid:?7326
I?am?the?parent,?pid:?7326
fork?the?2th?child,?pid:?7327
I?am?the?parent,?pid:?7327
fork?the?3th?child,?pid:?7328
I?am?the?parent,?pid:?7328
fork?the?4th?child,?pid:?7329
I?am?the?parent,?pid:?7329
fork?the?5th?child,?pid:?7330
I?am?the?parent,?pid:?7330
|
先解釋一下為什么會(huì)產(chǎn)生10條打印結(jié)果，第一條結(jié)果是子進(jìn)程打印的，第二條是在父進(jìn)程打印的！
1、如果是在循環(huán)中創(chuàng)建子進(jìn)程,那么子進(jìn)程中最后要exit,防止子進(jìn)程進(jìn)入循環(huán)!
2、必須等待子進(jìn)程執(zhí)行完任務(wù), 有一個(gè)簡單方法是使用 pcntl_wait，如果不加這個(gè)你會(huì)發(fā)現(xiàn)一個(gè)是執(zhí)行的順序不固定，第二個(gè)就是創(chuàng)建的進(jìn)程會(huì)少于5個(gè),但是加了你會(huì)發(fā)現(xiàn)這個(gè)完全變成并行了...上面的結(jié)果就是
然后找了找，發(fā)現(xiàn)下面這種寫法：
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 |
<?php
????$ids?=?[];
????
????foreach?(range(1,?5)?as?$index)?{
????????$ids[]?=?$pid?=?pcntl_fork();????
????????if?($pid?===?-1)?{????????
????????????echo?"failed?to?fork!n";????????
????????????exit;
????????}?
????????elseif?($pid)?
????????{????????
????????????echo?"I?am?the?parent,?pid:?$pidn";
????????}?
????????else
????????{
????????????$cid?=?posix_getpid();????????
????????????echo?"fork?the?{$index}th?child,?pid:?$cidn";????????
????????????exit;
????????}
????}
????
????foreach?($ids?as?$i?=>?$pid)?{????
????????if?($pid)?{
????????????pcntl_waitpid($pid,?$status);
????????}
????}
????
????
結(jié)果如下：
I?am?the?parent,?pid:?19054
fork?the?1th?child,?pid:?19054
I?am?the?parent,?pid:?19055
fork?the?2th?child,?pid:?19055
I?am?the?parent,?pid:?19056
fork?the?3th?child,?pid:?19056
I?am?the?parent,?pid:?19057
I?am?the?parent,?pid:?19058
fork?the?5th?child,?pid:?19058
fork?the?4th?child,?pid:?19057
|
找了一張圖,大體解釋了總體流程：
幾行代碼就可以寫出一個(gè)多進(jìn)程程序，實(shí)現(xiàn)并行編程。
管理子進(jìn)程：
創(chuàng)建好了進(jìn)程，那么怎么對子進(jìn)程進(jìn)行管理呢？使用信號(hào)。
在計(jì)算機(jī)科學(xué)中，信號(hào)是Unix、類Unix以及其他POSIX兼容的操作系統(tǒng)中進(jìn)程間通訊的一種有限制的方式。它是一種異步的通知機(jī)制，用來提醒進(jìn)程一個(gè)事件已經(jīng)發(fā)生。
分發(fā)信號(hào)處理器：
我們通過在父進(jìn)程接收子進(jìn)程傳來的信號(hào)，判斷子進(jìn)程狀態(tài)，來對子進(jìn)程進(jìn)行管理。
我們需要在父進(jìn)程里使用pcntl_signal()函數(shù)和pcntl_signal_dispatch()函數(shù)來給各個(gè)子進(jìn)程安裝信號(hào)處理器。
| 1 2 3 4 |
pcntl_signal?(int?$signo?,?callback?$handler)?安裝一個(gè)信號(hào)處理器；
????????$signo是待處理的信號(hào)常量，callback是其處理函數(shù)
pcntl_signal_dispatch?()?調(diào)用每個(gè)等待信號(hào)通過pcntl_signal()安裝的處理器
|
PHP內(nèi)常見的信號(hào)常量有：
| 1 2 3 4 |
????????SIGCHLD?????子進(jìn)程退出成為僵尸進(jìn)程會(huì)向父進(jìn)程發(fā)送此信號(hào)
????????SIGHUP??????進(jìn)程掛起
????????SIGTEM??????進(jìn)程終止
????????...?????????//?其他請?jiān)谑謨灾胁榭?/code>
|
安裝并調(diào)用信號(hào)處理器后，一旦子進(jìn)程有相應(yīng)的信號(hào)返回給父進(jìn)程，父進(jìn)程就可以調(diào)用相應(yīng)的callback函數(shù)對子進(jìn)程處理；
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
<?php
????//ctrl+cp
????cntl_signal(SIGINT,?function?()?{
????????fwrite(STDOUT,?"receive?signal:?"?.?SIGINT?.?"?do?nothing?...n");
????});
????
????//kill
????pcntl_signal(SIGTERM,?function?()?{
????????fwrite(STDOUT,?"receive?signal:?"?.?SIGTERM?.?"?I?will?exit!n");????
????????exit;
????});
????
????while?(true)?{
????pcntl_signal_dispatch();????
????echo?"do?something。。。n";
????sleep(5);
}
|
Linux進(jìn)程信號(hào)分為很多種，kill -l 可以查看，PHP里面定義了43種，咱就說說常用的幾種：
SIGINT 2 這個(gè)其實(shí)相對于 ctrl+c
SIGTERM 15 就是 kill 默認(rèn)的參數(shù)，表示終止信號(hào)，但是你發(fā)了信號(hào)程序不一定響應(yīng)
SIGKILL 9 就是 kill -9, 表示立馬終止，這個(gè)信號(hào)在PHP里面是無法注冊的，所以一定能成功
看明白了這個(gè)就可以讀懂上面的例子了，其中 pcntl_signal 是注冊信號(hào)處理handler，第一個(gè)參數(shù)是你需要注冊的信號(hào)，第二個(gè)是處理操作，可以是匿名函數(shù)或者一個(gè)函數(shù)名，可以注冊多個(gè)信號(hào)。pcntl_signal_dispatch 調(diào)用每個(gè)等待信號(hào)通過pcntl_signal() 安裝的處理器。早期PHP還有一種寫法是使用 ticks，性能非常差，php5.3之后建議都使用 pcntl_signal_dispatch。
說明一下：pcntl_signal()函數(shù)僅僅是注冊信號(hào)和它的處理方法，真正接收到信號(hào)并調(diào)用其處理方法的是pcntl_signal_dispatch()函數(shù)必須在循環(huán)里調(diào)用，為了檢測是否有新的信號(hào)等待dispatching。
上面的例子執(zhí)行結(jié)果就是當(dāng)你使用 ctrl+c 的話是無法終止程序的，只有使用 kill pid 這種形式才可以，但是并不是立馬就退出，它是代碼執(zhí)行到循環(huán)頂部 pcntl_signal_dispatch 地方的時(shí)候才會(huì)退出，這就保證了你使用kill殺掉進(jìn)程的時(shí)候并不會(huì)丟失數(shù)據(jù)，說好聽點(diǎn)這也算是平滑重啟吧！
處理子進(jìn)程：
對子進(jìn)程的處理方法有:
posix_kill()：此函數(shù)并不能顧名思義，它通過向子進(jìn)程發(fā)送一個(gè)信號(hào)來操作子進(jìn)程，在需要要時(shí)可以選擇給子進(jìn)程發(fā)送進(jìn)程終止信號(hào)來終止子進(jìn)程；
pcntl_waitpid()：等待或返回fork的子進(jìn)程狀態(tài)，如果指定的子進(jìn)程在此函數(shù)調(diào)用時(shí)已經(jīng)退出（俗稱僵尸進(jìn)程），此函數(shù)將立刻返回，并釋放子進(jìn)程的所有系統(tǒng)資源，此進(jìn)程可以避免子進(jìn)程變成僵尸進(jìn)程，造成系統(tǒng)資源浪費(fèi)；
下面是兩個(gè)函數(shù)的函數(shù)原型：
| 1 2 3 4 5 |
//?向進(jìn)程id為$pid的進(jìn)程發(fā)送$sig信號(hào)，$sig常見信號(hào)如上；
bool?posix_kill?(?int?$pid?,?int?$sig?)?
//?掛起當(dāng)前進(jìn)程的執(zhí)行直到進(jìn)程號(hào)為$pid的進(jìn)程退出(如果$pid為-1，則等待任意一個(gè)子進(jìn)程);?
int?pcntl_waitpid?(?int?$pid?,?int?&$status?[,?int?$options?=?0?]?)
|
PHP多進(jìn)程優(yōu)點(diǎn)：
1.使用多進(jìn)程, 子進(jìn)程結(jié)束以后, 內(nèi)核會(huì)負(fù)責(zé)回收資源；
2.使用多進(jìn)程,子進(jìn)程異常退出不會(huì)導(dǎo)致整個(gè)進(jìn)程Thread退出. 父進(jìn)程還有機(jī)會(huì)重建流程.
3.一個(gè)常駐主進(jìn)程, 只負(fù)責(zé)任務(wù)分發(fā), 邏輯更清楚.
【標(biāo)準(zhǔn)版】400元/年/5用戶/無限容量
【外貿(mào)版】500元/年/5用戶/無限容量
其它服務(wù)：網(wǎng)站建設(shè)、企業(yè)郵箱、數(shù)字證書ssl、400電話、
聯(lián)系方式：電話:13714666846 微信同號(hào)
聲明：本站所有作品（圖文、音視頻）均由用戶自行上傳分享，或互聯(lián)網(wǎng)相關(guān)知識(shí)整合，僅供網(wǎng)友學(xué)習(xí)交流，若您的權(quán)利被侵害，請聯(lián)系 管理員 刪除。
本文鏈接：http://www.goalq.com.cn/article_32741.html