快捷導(dǎo)航

PHP使用pcntl_fork實(shí)現(xiàn)多進(jìn)程下載圖片的方法

更新時(shí)間：2014年12月16日 10:38:25 投稿：shichen2014

這篇文章主要介紹了PHP使用pcntl_fork實(shí)現(xiàn)多進(jìn)程下載圖片的方法,較為詳細(xì)的分析了pcntl_fork的原理與用法,以及使用pcntl_fork實(shí)現(xiàn)多進(jìn)程下載圖片的方法,非常具有實(shí)用價(jià)值,需要的朋友可以參考下

本文實(shí)例講述了PHP使用pcntl_fork實(shí)現(xiàn)多進(jìn)程下載圖片的方法。分享給大家供大家參考。具體分析如下：

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

注意:PHP有個(gè)pcntl_fork的函數(shù)可以實(shí)現(xiàn)多進(jìn)程,但要加載pcntl拓展,而且只有在linux下才能編譯這個(gè)拓展.

1.首先在ubuntu下編譯pcntl.so,我的ubuntu下找不到pcntl的包,于是創(chuàng)建一個(gè)文件夾下載了整個(gè)PHP包,在里面找到了pcntl包運(yùn)行如下命令,代碼如下:

復(fù)制代碼代碼如下:

# mkdir php 

# cd php 

# apt-get source php5 

# cd php5-(WHATEVER_RELEASE)/ext/pcntl 

# phpize 

# ./configure (注一) 

# make 

# make install phpize 命令是用來(lái)準(zhǔn)備 PHP 外掛模塊的編譯環(huán)境的

成功的安裝將建立 extname.so 并放置于 PHP 的外掛模塊目錄中(預(yù)設(shè)存放于 /usr/lib/php/modules/ 內(nèi)),需要調(diào)整 php.ini,加入 extension=extname.so 這一行之后才能使用此外掛模塊.

例:

復(fù)制代碼代碼如下:

void pcntl_exec(string $path [,array $args [,array $envs ]])

pcntl_exec — 在當(dāng)前進(jìn)程空間執(zhí)行指定程序,代碼如下:

復(fù)制代碼代碼如下:

$cmds=array( 

        array('/home/jerry/projects/www/test2.php'), 

        array('/home/jerry/projects/www/test3.php') 

); 

foreach($cmds as $cmd){ 

        $pid=pcntl_fork(); 

        if($pid==-1){ 

        //進(jìn)程創(chuàng)建失敗 

            echo '創(chuàng)建子進(jìn)程失敗時(shí)返回-1'; 

            exit(-1); 

        } 

        else if($pid){ 

        //父進(jìn)程會(huì)得到子進(jìn)程號(hào)，所以這里是父進(jìn)程執(zhí)行的邏輯 

            pcntl_wait($status,WNOHANG); 

        } 

        else{ 

        //子進(jìn)程處理邏輯 

            sleep(5); 

            pcntl_exec('/usr/bin/php',$cmd); 

            exit(0); 

        } 

}

例,實(shí)例多圖片同步下載,代碼如下:

復(fù)制代碼代碼如下:

#!/usr/bin/php 

<?php 

// 需要抓取的網(wǎng)頁(yè)地址 

$url = 'http://www.dbjr.com.cn'; 

$content = file_get_contents($url); 

preg_match_all('/<imgs+src="(.*?)"/', $content, $matches,PREG_SET_ORDER); 

echo "已發(fā)現(xiàn)".count($matches)."張圖片n"; 

list($sm, $ss) = explode(" ", microtime()); 

foreach ($matches as $k => $val) 

{ 

 $pid[$k] = pcntl_fork(); 

 if(!$pid[$k]) 

 { 

  download($url, $val); 

  // 子進(jìn)程要exit否則會(huì)進(jìn)行遞歸多進(jìn)程，父進(jìn)程不要exit否則終止多進(jìn)程 

  exit(0); 

 } 

 if ($pid[$k]) 

 { 

//    pcntl_waitpid($pid[$k], $status, WUNTRACED); 

 } 

} 

echo "下載完成n"; 

list($em, $es) = explode(" ", microtime()); 

echo "用時(shí)：",($es+$em) - ($ss + $sm),"n"; 

/** 

 * 抓取網(wǎng)頁(yè)圖片 

 *  

 */ 

function download($url, $val) 

{ 

 $pic_url = $val[1]; 

 if (strpos($val[1], '//') !== false) 

 { 

  ; 

 } 

 elseif (preg_match('@^(.*?)/@', $val[1], $inner_matches) == 0) 

 { 

  $pic_url = $url.$val[1]; 

 } 

 elseif (preg_match('@[:.]@', $inner_matches[1], $tmp_matches) == 0) 

 { 

  $pic_url = $url.$val[1]; 

 } 

 $pic = file_get_contents($pic_url); 

 if ($pic === false) 

 { 

  return; 

 } 

 preg_match('@/([^/]+)$@', $pic_url, $tmp_matches); 

 // 可使用assert處理異常 

 $pic_file_name = $tmp_matches[1]; 

 $f = fopen("tmp/".$pic_file_name, "wb"); # 

 fwrite($f, $pic); 

 fclose($f); 

} 

/* End of file pcntl_fork.php */ 

?>