PHP pcntl_fork多进程下载图片实例

PHP pcntl_fork — 在当前进程当前位置产生分支,子进程,译注:fork是创建了一个子进程,父进程和子进程 都从fork的位置开始向下继续执行,不同的是父进程执行过程中,得到的fork返回值为子进程号,而子进程得到的是0.

注意:PHP有个pcntl_fork的函数可以实现多进程,但要加载pcntl拓展,而且只有在linux下才能编译这个拓展.

1.首先在ubuntu下编译pcntl.so,我的ubuntu下找不到pcntl的包,于是创建一个文件夹下载了整个PHP包,在里面找到了pcntl包运行如下命令,代码如下:

1. # mkdir php 
2. # cd php 
3. # apt-get source php5 
4. # cd php5-(WHATEVER_RELEASE)/ext/pcntl 
5. # phpize 
6. # ./configure (注一) 
7. # make 
8. # make install phpize 命令是用来准备 PHP 外挂模块的编译环境的 

成功的安装将建立 extname.so 并放置于 PHP 的外挂模块目录中(预设存放于 /usr/lib/php/modules/ 内),需要调整 php.ini,加入 extension=extname.so 这一行之后才能使用此外挂模块.

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

pcntl_exec — 在当前进程空间执行指定程序,代码如下:

1. $cmds=array( 
2.  
3.         array('/home/jerry/projects/www/test2.php'), 
4.  
5.         array('/home/jerry/projects/www/test3.php') 
6.  
7. ); 
8.  
9. foreach($cmds as $cmd){ 
10.  
11.         $pid=pcntl_fork(); 
12.  
13.         if($pid==-1){ 
14.  
15.         //进程创建失败 
16.  
17.             echo '创建子进程失败时返回-1'; 
18.  
19.             exit(-1); 
20.  
21.         } 
22.  
23.         else if($pid){ 
24.  
25.         //父进程会得到子进程号，所以这里是父进程执行的逻辑 
26.             
27.             pcntl_wait($status,WNOHANG); 
28.  
29.         } 
30.  
31.         else{ 
32.  
33.         //子进程处理逻辑 
34.  
35.             sleep(5); 
36.  
37.             pcntl_exec('/usr/bin/php',$cmd); 
38.  
39.             exit(0); 
40.  
41.         } 
42.  
43. } 

例,实例多图片同步下载,代码如下:

1. #!/usr/bin/php 
2. <?php 
3. // 需要抓取的网页地址 
4. $url = 'http://www.Vevb.com'; 
5. $content = file_get_contents($url); 
6. preg_match_all('/<imgs+src="(.*?)"/', $content, $matches,PREG_SET_ORDER); 
7. echo "已发现".count($matches)."张图片n"; 
8.  
9. list($sm, $ss) = explode(" ", microtime()); 
10. foreach ($matches as $k => $val) 
11. { 
12.  $pid[$k] = pcntl_fork(); 
13.  if(!$pid[$k]) 
14.  { 
15.   download($url, $val); 
16.   // 子进程要exit否则会进行递归多进程，父进程不要exit否则终止多进程 
17.   exit(0); 
18.  } 
19.  
20.  if ($pid[$k]) 
21.  { 
22. //    pcntl_waitpid($pid[$k], $status, WUNTRACED); 
23.  } 
24.  
25. } 
26. echo "下载完成n"; 
27.  
28. list($em, $es) = explode(" ", microtime()); 
29.  
30. echo "用时：",($es+$em) - ($ss + $sm),"n"; 
31. /** 
32.  * 抓取网页图片 
33.  *  
34.  */ 
35. function download($url, $val) 
36. { 
37.  $pic_url = $val[1]; 
38.  if (strpos($val[1], '//') !== false) 
39.  { 
40.   ; 
41.  } 
42.  elseif (preg_match('@^(.*?)/@', $val[1], $inner_matches) == 0) 
43.  { 
44.   $pic_url = $url.$val[1]; 
45.  } 
46.  elseif (preg_match('@[:.]@', $inner_matches[1], $tmp_matches) == 0) 
47.  { 
48.   $pic_url = $url.$val[1]; 
49.  } 
50.  
51.  $pic = file_get_contents($pic_url); 
52.  
53.  if ($pic === false) 
54.  { 
55.   return; 
56.  } 
57.  
58.  preg_match('@/([^/]+)$@', $pic_url, $tmp_matches); 
59.  // 可使用assert处理异常 
60.  $pic_file_name = $tmp_matches[1]; 
61.  $f = fopen("tmp/".$pic_file_name, "wb"); # 
62.  fwrite($f, $pic); 
63.  fclose($f); 
64. } 
65.  
66. /* End of file pcntl_fork.php */ 
67. ?>