搜尋
首頁後端開發php教程PHP中的(伪)多线程与多进程_PHP教程
PHP中的(伪)多线程与多进程_PHP教程
WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB
WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB
Jul 20, 2016 am 11:14 AM
phpweb與使用處理伺服器的執行緒呼叫行程

(伪)多线程：借助外力

    利用WEB服务器本身的多线程来处理，从WEB服务器多次调用我们需要实现多线程的程序。

QUOTE:

我们知道PHP本身是不支持多线程的, 但是我们的WEB服务器是支持多线程的.

也就是说可以同时让多人一起访问. 这也是我在PHP中实现多线程的基础.

假设我们现在运行的是a.php这个文件. 但是我在程序中又请求WEB服务器运行另一个b.php

那么这两个文件将是同时执行的.

(PS: 一个链接请求发送之后, WEB服务器就会执行它, 而不管客户端是否已经退出)

有些时候, 我们想运行的不是另一个文件, 而是本文件中的一部分代码.该怎么办呢?

其实可是通过参数来控制a.php来运行哪一段程序.

下面看一个例子:

[php] view plaincopy
  2. function runThread(){  
  3.     $fp = fsockopen('localhost', 80, $errno, $errmsg);  
  4.     fputs($fp, "GET /a.php?act=brnrn");//这里的第二个参数是HTTP协议中规定的请求头，不明白的请看RFC中的定义                               
  5.     fclose($fp);  
  6. }  
  7. function a(){  
  8.     $fp = fopen('result_a.log', 'w');  
  9.     fputs($fp, 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "rn");  
  10.     fclose($fp);          
  11. }  
  12. function b(){  
  13.     $fp = fopen('result_b.log', 'w');  
  14.     fputs($fp, 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "rn");  
  15.     fclose($fp);          
  16. }  
  17. if(!isset($_GET['act'])){ $_GET['act'] = 'a';};  
  18.   
  19. if($_GET['act'] == 'a'){  
  20.     runThread();  
  21.     a();  
  22. }else if($_GET['act'] == 'b'){   
  23.     b();  
  24. };  
  25. ?>  

 

打开result_a.log 和 result_b.log 比较一下两个文件的中访问的时间. 大家会发现, 这两个的确是在不同线程中运行的.
有些时间完全一样.

上面只是一个简单的例子, 大家可以改进成其它形式.


既然PHP中也能多线程了, 那么问题也来了, 那就是同步的问题. 我们知道 PHP本身是不支持多线程的. 所以更不会有什么像

Java 中synchronize的方法了. 那我们该如何做呢.

1. 尽量不访问同一个资源. 以避免冲突. 但是可以同时像数据库操作. 因为数据库是支持并发操作的. 所以在多线程的PHP中

不要向同一个文件中写入数据. 如果必须要写的话, 用别的方法进行同步.. 如调用 flock对文件进行加锁等. 或建立临时文件

并在另外的线程中等待这个文件的消失 while(file_exits('xxx')); 这样就等于这个临时文件存在时, 表示其实线程正在操作

如果没有了这个文件, 说明其它线程已经释放了这个.

2. 尽量不要从runThread在执行fputs后取这个socket中读取数据. 因为要实现多线程, 需要的用非阻塞模式. 即在像fgets这

样的函数时立即返回.. 所以读写数据就会出问题. 如果使用阻塞模式的话, 程序就不算是多线程了. 他要等上面的返回才执行

下面的程序. 所以如果需要交换数据最后利用外面文件或数据中完成. 实在想要的话就用socket_set_nonblock($fp) 来实现.


说了这么多, 倒底这个有没有实际的意义呢? 在什么时候需要这种用这种方法呢 ?

答案是肯定的. 大家知道. 在一个不断读取网络资源的应用中, 网络的速度是瓶颈. 如果采多这种形式就可以同时以多个线程对

不同的页面进行读取.

本人做的一个能从8848、soaso这些商城网站搜索信息的程序。还有一个从阿里巴巴网站上读取商业信息和公司目录的程序也用到

了此技术。 因为这两个程序都是要不断的链接它们的服务器读取信息并保存到数据库。 利用此技术正好消除了在等待响应时的瓶

颈。
多进程：使用PHP的Process Control Functions(PCNTL/线程控制函数)
    函数参考可见：http://www.php.net/manual/zh/ref.pcntl.php
    只能用在Unix Like OS，Windows不可用。
    编译php的时候，需要加上--enable-pcntl，且推荐仅仅在CLI模式运行，不要在WEB服务器环境运行。
    以下为简短的测试代码：

[php] view plaincopy
  1. declare(ticks=1);  
  2. $bWaitFlag = FALSE; /// 是否等待进程结束  
  3. $intNum = 10;           /// 进程总数  
  4. $pids = array();        ///  进程PID数组  
  5. echo ("Start\n");  
  6. for($i = 0; $i $intNum; $i++) {  
  7.   $pids[$i] = pcntl_fork();/// 产生子进程，而且从当前行之下开试运行代码，而且不继承父进程的数据信息  
  8.   if(!$pids[$i]) {  
  9.     // 子进程进程代码段_Start  
  10.     $str="";  
  11.     sleep(5+$i);  
  12.     for ($j=0;$j$i;$j++) {$str.="*";}  
  13.     echo "$i -> " . time() . " $str \n";  
  14.     exit();  
  15.     // 子进程进程代码段_End  
  16.   }  
  17. }  
  18. if ($bWaitFlag)  
  19. {  
  20.   for($i = 0; $i $intNum; $i++) {  
  21.     pcntl_waitpid($pids[$i], $status, WUNTRACED);  
  22.     echo "wait $i -> " . time() . "\n";  
  23.   }  
  24. }  
  25. echo ("End\n");  

 

运行结果如下：

CODE:[Copy toclipboard][qiao@oicq qiao]$ phptest.php       
Start
End
[qiao@oicq qiao]$ ps -aux | grep "php"
qiao     32275  0.0  0.5 49668 6148pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32276  0.0  0.5 49668 6152pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32277  0.0  0.5 49668 6152pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32278  0.0  0.5 49668 6152pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32279  0.0  0.5 49668 6152pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32280  0.0  0.5 49668 6152pts/1    S    14:03   0:00 /usr/local/php4/b
qiao     32281  0.0  0.5 49668 6152pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32282  0.0  0.5 49668 6152pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32283  0.0  0.5 49668 6152pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32284  0.0  0.5 49668 6152pts/1    S    14:03   0:00/usr/local/php4/b
qiao     32286  0.0  0.0  1620  600pts/1    S    14:03   0:00 grep php
[qiao@oicq qiao]$ 0 -> 1133503401 
1 -> 1133503402 *
2 -> 1133503403 **
3 -> 1133503404 ***
4 -> 1133503405 ****
5 -> 1133503406 *****
6 -> 1133503407 ******
7 -> 1133503408 *******
8 -> 1133503409 ********
9 -> 1133503410 *********

[qiao@oicq qiao]$
如果$bWaitFlag=TURE，则结果如下：

CODE:[Copy toclipboard][qiao@oicq qiao]$ phptest.php       
Start
0 -> 1133503602 
wait 0 -> 1133503602
1 -> 1133503603 *
wait 1 -> 1133503603
2 -> 1133503604 **
wait 2 -> 1133503604
3 -> 1133503605 ***
wait 3 -> 1133503605
4 -> 1133503606 ****
wait 4 -> 1133503606
5 -> 1133503607 *****
wait 5 -> 1133503607
6 -> 1133503608 ******
wait 6 -> 1133503608
7 -> 1133503609 *******
wait 7 -> 1133503609
8 -> 1133503610 ********
wait 8 -> 1133503610
9 -> 1133503611 *********
wait 9 -> 1133503611
End
[qiao@oicq qiao]$
从 多进程的例子可以看出，使用pcntl_fork()之后，将生成一个子进程，而且子进程运行的代码，从pcntl_fork()之后的代码开始，而子进 程不继承父进程的数据信息(实际上是把父进程的数据做了一个全新的拷贝)，因而使用if(!$pids[$i]) 来控制子进程实际运行的代码段。

    更详细的研究出于时间关系，暂时没有进行，你可以参考我给出的手册的链接。


[文章二] 尝试php命令行脚本多进程并发执行

作者：dulao5
来源：http://dulao5.blog.hexun.com/3726837_d.html

除了fork, cli下的并发方式还有一种,看我的例子:


php不支持多线程，但是我们可以把问题转换成“多进程”来解决。由于php中的pcntl_fork只有unix平台才可以使用，所以本文尝试使用popen来替代。


下面是一个例子：

被并行调用的子程序代码：

[php] view plaincopy
  2. if($argc==1){  
  3.     echo("argv\n");  
  4. }  
  5. $arg = $argv[1];  
  6. for($i=0; $i$i++)  
  7. {  
  8.     echo($i.".1.".time()." exec $arg \n");  
  9.     if($arg=='php2'){  
  10.         sleep(1);  
  11.         echo($i.".2.".time()." exec $arg \n");  
  12.         sleep(1);  
  13.     }else{  
  14.         sleep(1);  
  15.     }  
  16. }  
  17. ?>  

 

主调用者程序，由他调用子进程，同时并发的收集子程序的输出

[php] view plaincopy
  1. error_reporting(E_ALL);  
  2.   
  3. $handle1 = popen('php sub.php php1', 'r');  
  4. $handle2 = popen('php sub.php php2', 'r');  
  5. $handle3 = popen('php sub.php php3', 'r');  
  6.   
  7. echo "'$handle1'; " . gettype($handle1) . "\n";  
  8. echo "'$handle2'; " . gettype($handle2) . "\n";  
  9. echo "'$handle3'; " . gettype($handle3) . "\n";  
  10. //sleep(20);  
  11. while(!feof($handle1) || !feof($handle2) || !feof($handle3) )  
  12. {  
  13. $read = fgets($handle1);  
  14. echo $read;  
  15. $read = fgets($handle2);  
  16. echo $read;  
  17. $read = fgets($handle3);  
  18. echo $read;  
  19. }  
  20. pclose($handle1);  
  21. pclose($handle2);  
  22. pclose($handle3);  

 

下面是我机器上的输出：

C:\my_hunter>php exec.php
'Resource id #4'; resource
'Resource id #5'; resource
'Resource id #6'; resource
0.1.1147935331 exec php1
0.1.1147935331 exec php2
0.1.1147935331 exec php3
1.1.1147935332 exec php1
0.2.1147935332 exec php2
1.1.1147935332 exec php3
2.1.1147935333 exec php1
1.1.1147935333 exec php2
2.1.1147935333 exec php3
3.1.1147935334 exec php1
1.2.1147935334 exec php2
3.1.1147935334 exec php3
4.1.1147935335 exec php1
2.1.1147935335 exec php2
4.1.1147935335 exec php3
5.1.1147935336 exec php1
2.2.1147935336 exec php2
5.1.1147935336 exec php3
6.1.1147935337 exec php1
3.1.1147935337 exec php2
6.1.1147935337 exec php3
7.1.1147935338 exec php1
3.2.1147935338 exec php2
7.1.1147935338 exec php3
8.1.1147935339 exec php1
4.1.1147935339 exec php2
8.1.1147935339 exec php3
9.1.1147935340 exec php1
4.2.1147935340 exec php2
9.1.1147935340 exec php3
5.1.1147935341 exec php2
5.2.1147935342 exec php2
6.1.1147935343 exec php2
6.2.1147935344 exec php2
7.1.1147935345 exec php2
7.2.1147935346 exec php2
8.1.1147935347 exec php2
8.2.1147935348 exec php2
9.1.1147935349 exec php2
9.2.1147935350 exec php2

**总结：**

**主程序循环等待子进程， 通过fgets或fread 把子进程的输出获取出来 ， 从时间戳上看，的确实现了并发执行。**

-----------------------------------------------
以后的改进：

*  popen打开的句柄是单向的，如果需要向子进程交互，可以使用proc_open
*  使用数组和子函数代替while(!feof($handle1)|| !feof($handle2) || !feof($handle3) )这种龌龊的写法
*  用fread一次把子进程已经产生的输出取完，而不是每次一行。

一个并发执行shell任务的调度者,本程序读取一个任务文件,把里面的每行命令并发执行, 可以设置同时存在的子进程数目:

[php] view plaincopy
  1. /* 
  2.    主任务管理器 
  3.    并发的执行子任务列表 
  4. */  
  5. include("../common/conf.php");  
  6. include("../common/function.php");  
  7. //开启的进程数  
  8. $exec_number = 40 ;  
  9. /***** main ********/  
  10. if($argc==1){  
  11.     echo("argv\n");  
  12. }  
  13. $taskfile = $argv[1];  
  14. //tasklist  
  15. $tasklist = file($taskfile);  
  16. $tasklist_len = count($tasklist);  
  17. $tasklist_pos = 0;  
  18. $handle_list = array();  
  19. while(1)  
  20. {  
  21.     //子进程列表有空闲,则填充补齐子进程列表  
  22.     if($exec_number > count($handle_list) &&  
  23.             $tasklist_pos $tasklist_len)  
  24.     {  
  25.         for($i=$tasklist_pos; $i$tasklist_len; )  
  26.         {  
  27.             $command = $tasklist[$i] ;  
  28.             $handle_list[] = popen($command , "r" );  
  29.             tolog("begin task \t ".$tasklist[$i]);  
  30.             $i++;  
  31.             if($exec_number == count($handle_list)) break;  
  32.         }  
  33.         $tasklist_pos = $i;  
  34.     }  
  35.     //如果子进程列表空，退出  
  36.     if(0 == count($handle_list))  
  37.     {  
  38.         break;  
  39.     }  
  40.     //检查子进程列表的输出，把停掉的子进程关闭并记录下来  
  41.     $end_handle_keys = array();  
  42.     foreach($handle_list as $key => $handle)  
  43.     {  
  44.         //$str = fgets($handle, 65536);  
  45.         $str = fread($handle, 65536);  
  46.         echo($str);  
  47.         if(feof($handle))  
  48.         {  
  49.             $end_handle_keys[] = $key;  
  50.             pclose($handle);  
  51.         }  
  52.     }  
  53.     //踢出停掉的子进程  
  54.     foreach($end_handle_keys as $key)  
  55.     {  
  56.         unset($handle_list[$key]);  
  57.         //var_dump($handle_list);  
  58.         //exit;  
  59.     }  
  60.   
  61. }  
  62. tolog("\n\n*******************end**********************\n\n", "" ,  true);  

 

附加一段Socket多进程接收的代码：

[php] view plaincopy
  1. do {  
  2.  if (($msgsock = socket_accept($sock)) 
  3.   echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n";  
  4.   break;  
  5.  }  
  6.  $pid = pcntl_fork();  
  7.  if ($pid == -1) {  
  8.   die('could not fork');  
  9.  } else if (!$pid) {  
  10.   .....  
  11.   socket_write($msgsock, $msg, strlen($msg));  
  12.   do {  
  13.    ......  
  14.   } while (true);  
  15.    socket_close($msgsock);  
  16.  }  
  17. } while (true);  


原文地址：http://www.alixixi.com/program/a/2008050731686.shtml

www.bkjia.comtruehttp://www.bkjia.com/PHPjc/440281.htmlTechArticle(伪)多线程：借助外力 利用WEB服务器本身的多线程来处理，从WEB服务器多次调用我们需要实现多线程的程序。 QUOTE: 我们知道PHP本身是不支...
陳述
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
相關文章
php怎么把负数转为正整数php怎么把负数转为正整数Apr 19, 2022 pm 08:59 PM

php把负数转为正整数的方法：1、使用abs()函数将负数转为正数，使用intval()函数对正数取整，转为正整数，语法“intval(abs($number))”；2、利用“~”位运算符将负数取反加一，语法“~$number + 1”。

php怎么实现几秒后执行一个函数php怎么实现几秒后执行一个函数Apr 24, 2022 pm 01:12 PM

实现方法：1、使用“sleep(延迟秒数)”语句，可延迟执行函数若干秒；2、使用“time_nanosleep(延迟秒数,延迟纳秒数)”语句，可延迟执行函数若干秒和纳秒；3、使用“time_sleep_until(time()+7)”语句。

php字符串有没有下标php字符串有没有下标Apr 24, 2022 am 11:49 AM

php字符串有下标。在PHP中，下标不仅可以应用于数组和对象，还可应用于字符串，利用字符串的下标和中括号“[]”可以访问指定索引位置的字符，并对该字符进行读写，语法“字符串名[下标值]”；字符串的下标值（索引值）只能是整数类型，起始值为0。

php怎么除以100保留两位小数php怎么除以100保留两位小数Apr 22, 2022 pm 06:23 PM

php除以100保留两位小数的方法：1、利用“/”运算符进行除法运算，语法“数值 / 100”；2、使用“number_format(除法结果, 2)”或“sprintf("%.2f",除法结果)”语句进行四舍五入的处理值，并保留两位小数。

php怎么读取字符串后几个字符php怎么读取字符串后几个字符Apr 22, 2022 pm 08:31 PM

在php中，可以使用substr()函数来读取字符串后几个字符，只需要将该函数的第二个参数设置为负值，第三个参数省略即可；语法为“substr(字符串,-n)”，表示读取从字符串结尾处向前数第n个字符开始，直到字符串结尾的全部字符。

php怎么根据年月日判断是一年的第几天php怎么根据年月日判断是一年的第几天Apr 22, 2022 pm 05:02 PM

判断方法：1、使用“strtotime("年-月-日")”语句将给定的年月日转换为时间戳格式；2、用“date("z",时间戳)+1”语句计算指定时间戳是一年的第几天。date()返回的天数是从0开始计算的，因此真实天数需要在此基础上加1。

php怎么查找字符串是第几位php怎么查找字符串是第几位Apr 22, 2022 pm 06:48 PM

查找方法：1、用strpos()，语法“strpos("字符串值","查找子串")+1”；2、用stripos()，语法“strpos("字符串值","查找子串")+1”。因为字符串是从0开始计数的，因此两个函数获取的位置需要进行加1处理。

php怎么替换nbsp空格符php怎么替换nbsp空格符Apr 24, 2022 pm 02:55 PM

方法：1、用“str_replace(" ","其他字符",$str)”语句，可将nbsp符替换为其他字符；2、用“preg_replace("/(\s|\&nbsp\;||\xc2\xa0)/","其他字符",$str)”语句。

See all articles

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序，用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

顯示更多

熱門文章

R.E.P.O.能量晶體解釋及其做什麼（黃色晶體）
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
3 週前By尊渡假赌尊渡假赌尊渡假赌
刺客信條陰影：貝殼謎語解決方案
1 週前ByDDD
R.E.P.O.如果您聽不到任何人，如何修復音頻
3 週前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25：如何解鎖Myrise中的所有內容
3 週前By尊渡假赌尊渡假赌尊渡假赌
顯示更多

熱工具

WebStorm Mac版

WebStorm Mac版

好用的JavaScript開發工具

Dreamweaver Mac版

Dreamweaver Mac版

視覺化網頁開發工具

Safe Exam Browser

Safe Exam Browser

Safe Exam Browser是一個安全的瀏覽器環境，安全地進行線上考試。該軟體將任何電腦變成一個安全的工作站。它控制對任何實用工具的訪問，並防止學生使用未經授權的資源。

VSCode Windows 64位元 下載

VSCode Windows 64位元 下載

微軟推出的免費、功能強大的一款IDE編輯器

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

顯示更多

熱門話題

gmail信箱登陸入口在哪裡
7445
15
CakePHP 教程
1374
52
steam的賬戶名稱是什麼格式
76
11
win11激活密鑰永久
39
19
NYT連接提示和答案
14
6
顯示更多