php多进程几个例子

php多进程这个东西先是在java中有不过现在高版本的php也支持多进程这个功能,但经过测试性能不如j(www.phpfensi.com)ava了希望后期有所提高了,下面我们一起来看看我整理了几个关于php多进程例子,希望能帮助你理解多线程.

php多进程的实现依赖于pcntl扩展,编译PHP的时候,可以加上’–enable-pcntl’或者也可以单独编译.

有三点需要注意:

1.子进程不在执行fork之前的代码，只是把父进程的内存状况复制一份新的，所以，关于子进程的个性化设置需要单独设置.

2.输出重定向,程序中使用echo,或造成命令行的混乱,影响分辨,可以用ob_start重定向到log文件,当然，你直接使用log是更好的办法,此实例中log文件，按照进程pid分组.

3.父进程没有代码执行,将可能提前退出,子进程可能成为孤儿进程.

demo接收:

用10个子进程来处理输出任务,任务总量是1000,然后,按照任务数平均分到十个子进程当中去,代码如下:

1.  //输出重定向到log文件                    
2. function echo_to_log($content){ 
3.     global $current_pid; 
4.     $logfile =  __FILE__ . $current_pid .  '.log'; 
5.     $fp = fopen($logfile, 'a+'); 
6.     fwrite($fp, $content); 
7.     fclose($fp); 
8. } 
9.                                                                                   
10. ob_start('echo_to_log'); 
11. //获取当前进程pid 
12. $current_pid = getmypid(); 
13. $fork_nums = 10; 
14. $total = 1000; 
15.                                                                                   
16. for($i = 0; $i < $fork_nums; $i++){ 
17.     $pid = pcntl_fork(); 
18.     //等于0时，是子进程 
19.     if($pid == 0){ 
20.         $current_pid = $pid; 
21.         do_task($i); 
22.      //大于0时，是父进程，并且pid是产生的子进程的PID 
23.     } else if($pid > 0) { 
24.     } 
25. } 
26.                                                                                   
27. //任务函数 
28. function do_task($task_num){ 
29.     global $total; 
30.     $start = $total / 10 * $task_num; 
31.     $end = $total / 10 * ($task_num + 1); 
32.     for(;$start<$end;$start++){ 
33.         echo $task_num . " " . $start . "＼n"; 
34.     } 
35.     //子进程执行完任务以后终止，当然你可以返回主进程的代码部分做相关操作。 
36.     exit(); 
37. } 

多进程控制的框架代码,留着备查,代码如下:

1. declare(ticks=1); 
2. function sigHandler($signal) 
3. { 
4.     echo "a child exited＼n"; 
5. } 
6. pcntl_signal(SIGCHLD, sigHandler, false); 
7. echo "this is " . posix_getpid() . PHP_EOL; 
8. for($i=0; $i<3; $i++) 
9. { 
10.     $pid = pcntl_fork(); 
11.     if($pid == -1)  
12.     {    
13.         echo 'fork failed ' . PHP_EOL; 
14.     }    
15.     else if($pid) 
16.     {    
17.     }    
18.     else 
19.     {    
20.         $pid = posix_getpid(); 
21.         echo 'child ' . $pid . ' ' . time() . PHP_EOL; 
22.         sleep(rand(2,5)); 
23.         echo 'child ' . $pid . ' done ' . time() . PHP_EOL; 
24.         exit(0); 
25.     }    
26. } 
27. do 
28. { 
29.     $pid = pcntl_wait($status);  
30.     echo 'child quit ' . $pid . PHP_EOL; 
31. }while($pid > 0);  
32. echo 'parent done' . PHP_EOL; 

例子,给出一段PHP多线程、与For循环,抓取百度搜索页面的PHP代码示例,代码如下:

1. <?php 
2.   class test_thread_run extends Thread  
3.   { 
4.       public $url; 
5.       public $data; 
6.  
7.       public function __construct($url) 
8.       { 
9.           $this->url = $url; 
10.       } 
11.  
12.       public function run() 
13.       { 
14.           if(($url = $this->url)) 
15.           { 
16.               $this->data = model_http_curl_get($url); 
17.           } 
18.       } 
19.   } 
20.  
21.   function model_thread_result_get($urls_array)  
22.   { 
23.       foreach ($urls_array as $key => $value)  
24.       { 
25.           $thread_array[$key] = new test_thread_run($value["url"]); 
26.           $thread_array[$key]->start(); 
27.       } 
28.  
29.       foreach ($thread_array as $thread_array_key => $thread_array_value)  
30.       { 
31.           while($thread_array[$thread_array_key]->isRunning()) 
32.           { 
33.               usleep(10); 
34.           } 
35.           if($thread_array[$thread_array_key]->join()) 
36.           { 
37.               $variable_data[$thread_array_key] = $thread_array[$thread_array_key]->data; 
38.           } 
39.       } 
40.       return $variable_data; 
41.   } 
42.  
43.   function model_http_curl_get($url,$userAgent="")  
44.   { 
45.       $userAgent = $userAgent ? $userAgent : 'Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.2)';  
46.       $curl = curl_init(); 
47.       curl_setopt($curl, CURLOPT_URL, $url); 
48.       curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1); 
49.       curl_setopt($curl, CURLOPT_TIMEOUT, 5); 
50.       curl_setopt($curl, CURLOPT_USERAGENT, (www.phpfensi.com)$userAgent); 
51.       $result = curl_exec($curl); 
52.       curl_close($curl); 
53.       return $result; 
54.   } 
55.  
56.   for ($i=0; $i < 100; $i++)  
57.   {  
58.       $urls_array[] = array("name" => "baidu", "url" => "http://www.phpfensi.com/s?wd=".mt_rand(10000,20000)); 
59.   } 
60.  
61.   $t = microtime(true); 
62.   $result = model_thread_result_get($urls_array); 
63.   $e = microtime(true); 
64.   echo "多线程：".($e-$t)."＼n"; 
65.  
66.   $t = microtime(true); 
67.   foreach ($urls_array as $key => $value)  
68.   { 
69.       $result_new[$key] = model_http_curl_get($value["url"]); 
70.   } 
71.   $e = microtime(true); 
72.   echo "For循环：".($e-$t)."＼n"; 
73. ?> 

PHP多线程类,代码如下:

1. /** 
2.  * @title:  PHP多线程类(Thread) 
3.  * @version: 1.0 
4.  * @author:   < web@ > 
5.  * @published: 2010-11-2 
6.  *  
7.  * PHP多线程应用示例： 
8.  *  require_once 'thread.class.php'; 
9.  *  $thread = new thread(); 
10.  *  $thread->addthread('action_log','a'); 
11.  *  $thread->addthread('action_log','b'); 
12.  *  $thread->addthread('action_log','c'); 
13.  *  $thread->runthread(); 
14.  *   
15.  *  function action_log($info) { 
16.  *   $log = 'log/' . microtime() . '.log'; 
17.  *   $txt = $info . "rnrn" . 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "rn"; 
18.  *   $fp = fopen($log, 'w'); 
19.  *   fwrite($fp, $txt); 
20.  *   fclose($fp); 
21.  *  } 
22.  */ 
23. class thread { 
24.  
25.     var $hooks = array(); 
26.     var $args = array(); 
27.      
28.     function thread() { 
29.     } 
30.      
31.     function addthread($func) 
32.     { 
33.      $args = array_slice(func_get_args(), 1); 
34.      $this->hooks[] = $func; 
35.   $this->args[] = $args; 
36.   return true; 
37.     } 
38.      
39.     function runthread() 
40.     { 
41.      if(isset($_GET['flag'])) 
42.      { 
43.       $flag = intval($_GET['flag']); 
44.      } 
45.      if($flag || $flag === 0) 
46.   { 
47.    call_user_func_array($this->hooks[$flag], $this->args[$flag]); 
48.   } 
49.      else  
50.      { 
51.          for($i = 0, $size = count($this->hooks); $i < $size; $i++) 
52.          { 
53.           $fp=fsockopen($_SERVER['HTTP_HOST'],$_SERVER['SERVER_PORT']); 
54.           if($fp) 
55.           { 
56.            $out = "GET {$_SERVER['PHP_SELF']}?flag=$i HTTP/1.1rn"; 
57.            $out .= "Host: {$_SERVER['HTTP_HOST']}rn"; 
58.            $out .= "Connection: Closernrn"; 
59.                  fputs($fp,$out); 
60.                  fclose($fp); 
61.           } 
62.          } 
63.      } 
64.     } 
65. } 

使用方法,代码如下:

1. $thread = new thread(); 
2. $thread->addthread('func1','info1'); 
3. $thread->addthread('func2','info2'); 
4. $thread->addthread('func3','info3'); 
5. $thread->runthread(); 

说明:addthread是添加线程函数,第一个参数是函数名,之后的参数(可选)为传递给指定函数的参数.

runthread是执行线程的函数.

在linux系统中需要配置安装一下pthreads

1、扩展的编译安装(Linux),www.phpfensi.com 编辑参数 --enable-maintainer-zts 是必选项,代码如下:

1. cd /Data/tgz/php-5.5.1 
2. ./configure --prefix=/Data/apps/php --with-config-file-path=/Data/apps/php/etc --with-mysql=/Data/apps/mysql --with-mysqli=/Data/apps/mysql/bin/mysql_config --with-iconv-dir --with-freetype-dir=/Data/apps/libs --with-jpeg-dir=/Data/apps/libs --with-png-dir=/Data/apps/libs --with-zlib --with-libxml-dir=/usr --enable-xml --disable-rpath --enable-bcmath --enable-shmop --enable-sysvsem --enable-inline-optimization --with-curl --enable-mbregex --enable-fpm --enable-mbstring --with-mcrypt=/Data/apps/libs --with-gd --enable-gd-native-ttf --with-openssl --with-mhash --enable-pcntl --enable-sockets --with-xmlrpc --enable-zip --enable-soap --enable-opcache --with-pdo-mysql --enable-maintainer-zts 
3. make clean 
4. make 
5. make install        
6.  
7. unzip pthreads-master.zip 
8. cd pthreads-master 
9. /Data/apps/php/bin/phpize 
10. ./configure --with-php-config=/Data/apps/php/bin/php-config 
11. make 
12. make install 
13. vi /Data/apps/php/etc/php.ini 

添加如下代码:

extension = "pthreads.so" 

PHP扩展下载：https://github.com/krakjoe/pthreads

PHP手册文档：http://php.net/manual/zh/book.pthreads.php