PHP網(wǎng)絡(luò)編程典型模塊與實(shí)例精講

場(chǎng)景：日常任務(wù)中，有時(shí)需要通過php腳本執(zhí)行一些日志分析，隊(duì)列處理等任務(wù)，當(dāng)數(shù)據(jù)量比較大時(shí)，可以使用多進(jìn)程來處理。

準(zhǔn)備：php多進(jìn)程需要pcntl，posix擴(kuò)展支持，可以通過 php - m 查看，沒安裝的話需要重新編譯php，加上參數(shù)--enable-pcntl，posix一般默認(rèn)會(huì)有。

創(chuàng)建子進(jìn)程的函數(shù)fork

pcntl_fork — 在當(dāng)前進(jìn)程當(dāng)前位置產(chǎn)生分支（子進(jìn)程）。譯注：fork是創(chuàng)建了一個(gè)子進(jìn)程，父進(jìn)程和子進(jìn)程 都從fork的位置開始向下繼續(xù)執(zhí)行，不同的是父進(jìn)程執(zhí)行過程中，得到的fork返回值為子進(jìn)程號(hào)，而子進(jìn)程得到的是0。

一個(gè)fork子進(jìn)程的基礎(chǔ)示例：

<?php

$pid=pcntl_fork();//父進(jìn)程和子進(jìn)程都會(huì)執(zhí)行下面代碼

if($pid== -1) {

//錯(cuò)誤處理：創(chuàng)建子進(jìn)程失敗時(shí)返回-1.die('could not fork');} elseif($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í)行的邏輯。

}

如果一個(gè)任務(wù)被分解成多個(gè)進(jìn)程執(zhí)行，就會(huì)減少整體的耗時(shí)。

比如有一個(gè)比較大的數(shù)據(jù)文件要處理，這個(gè)文件由很多行組成。如果單進(jìn)程執(zhí)行要處理的任務(wù)，量很大時(shí)要耗時(shí)比較久。這時(shí)可以考慮多進(jìn)程。

多進(jìn)程處理分解任務(wù)，每個(gè)進(jìn)程處理文件的一部分，這樣需要均分割一下這個(gè)大文件成多個(gè)小文件（進(jìn)程數(shù)和小文件的個(gè)數(shù)等同就可以）。

比如該文件file.log有10萬行數(shù)據(jù)，現(xiàn)在想分4個(gè)進(jìn)程處理。需要分割2.5萬行一個(gè)文件。命令split可以做到。

split的用法比較簡(jiǎn)單，可以man split查看下手冊(cè)。

split-l 25000-d file.log prefix_name

-l是按照行分割，-d是分割后的文件名按照數(shù)字，-a是分割后的文件個(gè)數(shù)位數(shù)（默認(rèn)是2，做多就是99個(gè)；比如超過100個(gè)，-a可以寫3）。自己嘗試分割一下就知道了。

處理代碼：

<?php

shell_exec('split -l 25000 -d file.log prefix_name');

// 3個(gè)子進(jìn)程處理任務(wù)

for($i= 0; $i< 3; $i++){

$pid=pcntl_fork();

if($pid== -1) {

die("could not fork");} elseif($pid) {

echo"I'm the Parent $in"; } else{// 子進(jìn)程處理$content= file_get_contents("prefix_name0".$i);

// 業(yè)務(wù)處理 begin// 業(yè)務(wù)處理 endexit;

// 一定要注意退出子進(jìn)程,否則pcntl_fork() 會(huì)被子進(jìn)程再fork,帶來處理上的影響。}}// 等待子進(jìn)程執(zhí)行結(jié)束

while(pcntl_waitpid(0, $status) != -1) {

$status= pcntl_wexitstatus($status);

echo"Child $statuscompletedn";}