首页 > 开发 > PHP > 正文

深入探究PHP的多进程编程方法

2024-05-04 23:38:51
字体：大 中 小
来源：转载
供稿：网友

这篇文章主要介绍了深入探究PHP的多进程编程方法,同时介绍了Windows系统下的多线程尝试,是PHP并发实现方面的重要内容,需要的朋友可以参考下

子进程的创建

一般的子进程的写法是：

 

 
  1. <?php 
  2. $pid = pcntl_fork(); 
  3. if($pid == -1){ 
  4. //创建失败 
  5. die('could not fork'); 
  6. } 
  7. else{ 
  8. if($pid){ 
  9. //从这里开始写的代码是父进程的 
  10. exit("parent!"); 
  11. } 
  12. else{ 
  13. //子进程代码，为防止不停的启用子进程造成系统资源被耗尽的情况，一般子进程代码运行完成后，加入exit来确保子进程正常退出。 
  14. exit("child"); 
  15. } 
  16. } 
  17. ?> 

上边的代码如果创建子进程成功的话，系统就有了2个进程，一个为父进程，一个为子进程，子进程的id号为$pid。在系统运行到$pid = pcntl_fork();时，在这个地方进行分支，父子进程各自开始运行各自的程序代码。代码的运行结果是parent 和child，很奇怪吧，为什么一个if和else互斥的代码中，都输出了结果?其实是像上边所说的，代码在pcntl_fork时，一个父进程运行parent，一个子进程运行了child。在代码结果上就显示了parent和child。至于谁先谁后的问题，这得要看系统资源的分配了。

如果需要起多个进程来处理数据，可以根据数据的数量，按照约定好的数量比如说1000条一个进程来起子进程。使用for循环就可以了。

 

 
  1. #如果获得的总数小于或等于0，等待60秒，并退出 
  2. if ($count <= 0)  
  3. { 
  4. sleep(60); 
  5. exit; 
  6. } 
  7. #如果大于1000，计算需要起的进程数 
  8. if ($count > 1000) 
  9. { 
  10. $cycleSize = ceil($count/1000); 
  11. } 
  12. else 
  13. { 
  14. $cycleSize = 1; 
  15. } 
  16.  
  17. for ($i=0; $i<$cycleSize; $i++) 
  18. { 
  19. $pid = pcntl_fork(); 
  20. if($pid == -1) 
  21. { 
  22. break; 
  23. } 
  24. else 
  25. { 
  26. if($pid) 
  27. { 
  28. #父进程获得子进程的pid，存入数组 
  29. $pidArr[] = $pid; 
  30. } 
  31. else 
  32. { 
  33. //开始发送，子进程执行完自己的任务后，退出。 
  34. exit; 
  35. } 
  36. } 
  37. } 
  38.  
  39. while(count($pidArr) > 0) 
  40. { 
  41. $myId = pcntl_waitpid(-1, $status, WNOHANG); 
  42. foreach($pidArr as $key => $pid) 
  43. { 
  44. if($myId == $pid) unset($pidArr[$key]); 
  45. } 
  46. } 

然后使用crontab，来使此PHP程序每隔一段时间自动执行。

当然，示例代码比较简单，具体还需要考虑怎么防止多个子进程执行到同一条数据或者当前进程处理数据未完成时，crontab又开始执行PHP文件启用新的进程等等。

PHP多进程实现方式

下面来系统地整理一下PHP多进程的实现方式：

1. 直接方式

pcntl_fork() 创建一个进程，在父进程返回值是子进程的pid，在子进程返回值是0，-1表示创建进程失败。跟C非常相似。

测试脚本 test.php

 

 
  1. <?php 
  2. // example of multiple processes 
  3. date_default_timezone_set( 'Asia/Chongqing'); 
  4. echo "parent start, pid ", getmypid(), "/n" ; 
  5. beep(); 
  6. for ($i=0; $i<3; ++$i){ 
  7. $pid = pcntl_fork(); 
  8. if ($pid == -1){ 
  9. die ("cannot fork" ); 
  10. } else if ($pid > 0){ 
  11. echo "parent continue /n"; 
  12. for ($k=0; $k<2; ++$k){ 
  13. beep(); 
  14. } 
  15. } else if ($pid == 0){ 
  16. echo "child start, pid ", getmypid(), "/n" ; 
  17. for ($j=0; $j<5; ++$j){ 
  18. beep(); 
  19. } 
  20. exit ; 
  21. } 
  22. } 
  23. // *** 
  24. function beep(){ 
  25. echo getmypid(), "/t" , date( 'Y-m-d H:i:s', time()), "/n" ; 
  26. sleep(1); 
  27. } 
  28. ?> 

用命令行运行

 

 
  1. #php -f test.php 

输出结果

 

 
  1. parent start, pid 1793 
  2. 1793 2013-01-14 15:04:17 
  3. parent continue 
  4. 1793 2013-01-14 15:04:18 
  5. child start, pid 1794 
  6. 1794 2013-01-14 15:04:18 
  7. 1794 2013-01-14 15:04:19 
  8. 1793 2013-01-14 15:04:19 
  9. 1794 2013-01-14 15:04:20 
  10. parent continue 
  11. 1793 2013-01-14 15:04:20 
  12. child start, pid 1795 
  13. 1795 2013-01-14 15:04:20 
  14. 17931794 2013-01-14 15:04:212013-01-14 15:04:21 
  15.  
  16. 1795 2013-01-14 15:04:21 
  17. 1794 2013-01-14 15:04:22 
  18. 1795 2013-01-14 15:04:22 
  19. parent continue 
  20. 1793 2013-01-14 15:04:22 
  21. child start, pid 1796 
  22. 1796 2013-01-14 15:04:22 
  23. 1793 2013-01-14 15:04:23 
  24. 1796 2013-01-14 15:04:23 
  25. 1795 2013-01-14 15:04:23 
  26. 1795 2013-01-14 15:04:24 
  27. 1796 2013-01-14 15:04:24 
  28. 1796 2013-01-14 15:04:25 
  29. 1796 2013-01-14 15:04:26 

从中看到，创建了3个子进程，和父进程一起并行运行。其中有一行格式跟其他有些不同，

17931794 2013-01-14 15:04:212013-01-14 15:04:21

因为两个进程同时进行写操作，造成了冲突。

2. 阻塞方式

用直接方式，父进程创建了子进程后，并没有等待子进程结束，而是继续运行。似乎这里看不到有什么问题。如果php脚本并不是运行完后自动结束，而是常驻内存的，就会造成子进程无法回收的问题。也就是僵尸进程。可以通过pcntl_wai()方法等待进程结束，然后回收已经结束的进程。

将测试脚本改成：

 

 
  1. $pid = pcntl_fork(); 
  2. if ($pid == -1){ 
  3. ... 
  4. } else if ($pid > 0){ 
  5. echo "parent continue /n"; 
  6. pcntl_wait($status); 
  7. for ($k=0; $k<2; ++$k){ 
  8. beep(); 
  9. } 
  10. } else if ($pid == 0){ 
  11. ... 
  12. } 

用命令行运行

 

 
  1. #php -f test.php 

输出结果

 

 
  1. parent start, pid 1807 
  2. 1807 2013-01-14 15:20:05 
  3. parent continue 
  4. child start, pid 1808 
  5. 1808 2013-01-14 15:20:06 
  6. 1808 2013-01-14 15:20:07 
  7. 1808 2013-01-14 15:20:08 
  8. 1808 2013-01-14 15:20:09 
  9. 1808 2013-01-14 15:20:10 
  10. 1807 2013-01-14 15:20:11 
  11. 1807 2013-01-14 15:20:12 
  12. parent continue 
  13. child start, pid 1809 
  14. 1809 2013-01-14 15:20:13 
  15. 1809 2013-01-14 15:20:14 
  16. 1809 2013-01-14 15:20:15 
  17. 1809 2013-01-14 15:20:16 
  18. 1809 2013-01-14 15:20:17 
  19. 1807 2013-01-14 15:20:18 
  20. 1807 2013-01-14 15:20:19 
  21. child start, pid 1810 
  22. 1810 2013-01-14 15:20:20 
  23. parent continue 
  24. 1810 2013-01-14 15:20:21 
  25. 1810 2013-01-14 15:20:22 
  26. 1810 2013-01-14 15:20:23 
  27. 1810 2013-01-14 15:20:24 
  28. 1807 2013-01-14 15:20:25 
  29. 1807 2013-01-14 15:20:26 

父进程在pcntl_wait()将自己阻塞，等待子进程运行完了才接着运行。

3. 非阻塞方式

阻塞方式失去了多进程的并行性。还有一种方法，既可以回收已经结束的子进程，又可以并行。这就是非阻塞的方式。

修改脚本：

 

 
  1. <?php 
  2. // example of multiple processes 
  3. date_default_timezone_set( 'Asia/Chongqing'); 
  4. declare (ticks = 1); 
  5. pcntl_signal(SIGCHLD, "garbage" ); 
  6. echo "parent start, pid ", getmypid(), "/n" ; 
  7. beep(); 
  8. for ($i=0; $i<3; ++$i){ 
  9. $pid = pcntl_fork(); 
  10. if ($pid == -1){ 
  11. die ("cannot fork" ); 
  12. } else if ($pid > 0){ 
  13. echo "parent continue /n"; 
  14. for ($k=0; $k<2; ++$k){ 
  15. beep(); 
  16. } 
  17. } else if ($pid == 0){ 
  18. echo "child start, pid ", getmypid(), "/n" ; 
  19. for ($j=0; $j<5; ++$j){ 
  20. beep(); 
  21. } 
  22. exit (0); 
  23. } 
  24. } 
  25. // parent 
  26. while (1){ 
  27. // do something else 
  28. sleep(5); 
  29. } 
  30. // *** 
  31. function garbage($signal){ 
  32. echo "signel $signal received/n" ; 
  33.  
  34. while (($pid = pcntl_waitpid(-1, $status, WNOHANG))> 0){ 
  35. echo "/t child end pid $pid , status $status/n" ; 
  36. } 
  37. } 
  38. function beep(){ 
  39. echo getmypid(), "/t" , date( 'Y-m-d H:i:s', time()), "/n" ; 
  40. sleep(1); 
  41. } 
  42. ?> 

用命令行运行

 

 
  1. #php -f test.php & 

输出结果

 

 
  1. parent start, pid 2066 
  2. 2066 2013-01-14 16:45:34 
  3. parent continue 
  4. 2066 2013-01-14 16:45:35 
  5. child start, pid 2067 
  6. 2067 2013-01-14 16:45:35 
  7. 20662067 2013-01-14 16:45:362013-01-14 16:45:36 
  8.  
  9. 2067 2013-01-14 16:45:37 
  10. parent continue 
  11. 2066 2013-01-14 16:45:37 
  12. child start, pid 2068 
  13. 2068 2013-01-14 16:45:37 
  14. 2067 2013-01-14 16:45:38 
  15. 2068 2013-01-14 16:45:38 
  16. 2066 2013-01-14 16:45:38 
  17. parent continue 
  18. 2066 2013-01-14 16:45:40 
  19. child start, pid 2069 
  20. 2069 2067 2013-01-14 16:45:40 
  21. 2013-01-14 16:45:40 
  22. 2068 2013-01-14 16:45:40 
  23. 2066 2013-01-14 16:45:41 
  24. 2069 2013-01-14 16:45:41 
  25. 2068 2013-01-14 16:45:41 
  26. signel 17 received 
  27. child end pid 2067, status 0 
  28. 2069 2013-01-14 16:45:42 
  29. 2068 2013-01-14 16:45:42 
  30. 2069 2013-01-14 16:45:43 
  31. signel 17 received 
  32. child end pid 2068, status 0 
  33. 2069 2013-01-14 16:45:44 
  34. signel 17 received 
  35. child end pid 2069, status 0 

多个进程又并行运行了，而且运行大约10秒钟之后，用 ps -ef | grep php 查看正在运行的进程，只有一个进程

lqling 2066 1388 0 16:45 pts/1 00:00:00 php -f t5.php

是父进程，子进程被回收了。

子进程退出状态

 

 
  1. pcntl_waitpid(-1, $status, WNOHANG) $status 

返回子进程的结束状态

windows下多线程

windows系统不支持pcntl函数，幸好有curl_multi_exec()这个工具，利用内部的多线程，访问多个链接，每个链接可以作为一个任务。

编写脚本 test1.php

 

 
  1. <?php 
  2. date_default_timezone_set( 'Asia/Chongqing'); 
  3. $tasks = array( 
  4. 'http://localhost/feedbowl/t2.php?job=task1', 
  5. 'http://localhost/feedbowl/t2.php?job=task2', 
  6. 'http://localhost/feedbowl/t2.php?job=task3' 
  7. ); 
  8. $mh = curl_multi_init(); 
  9. foreach ($tasks as $i => $task){ 
  10. $ch[$i] = curl_init(); 
  11. curl_setopt($ch[$i], CURLOPT_URL, $task); 
  12. curl_setopt($ch[$i], CURLOPT_RETURNTRANSFER, 1); 
  13. curl_multi_add_handle($mh, $ch[$i]); 
  14. } 
  15. do {$mrc = curl_multi_exec($mh,$active); } while ($mrc == CURLM_CALL_MULTI_PERFORM); 
  16. while ($active && $mrc == CURLM_OK) { 
  17. if (curl_multi_select($mh) != -1) { 
  18. do {$mrc = curl_multi_exec($mh, $active); } while ($mrc == CURLM_CALL_MULTI_PERFORM); 
  19. } 
  20. } 
  21. // completed, checkout result 
  22. foreach ($tasks as $j => $task){ 
  23. if (curl_error($ch[$j])){ 
  24. echo "task ${j} [$task ] error " , curl_error($ch[$j]), "/r/n" ; 
  25. } else { 
  26. echo "task ${j} [$task ] get: /r/n" , curl_multi_getcontent($ch[$j]), "/r/n" ; 
  27. } 
  28. } 
  29. ?> 

编写脚本 test2.php

 

 
  1. <?php 
  2. date_default_timezone_set( 'Asia/Chongqing'); 
  3. echo "child start, pid ", getmypid(), "/r/n" ; 
  4. for ($i=0; $i<5; ++$i){ 
  5. beep(); 
  6. } 
  7. exit (0); 
  8. // *** 
  9. function beep(){ 
  10. echo getmypid(), "/t" , date('Y-m-d H:i:s' , time()), "/r/n"; 
  11. sleep(1); 
  12. } 
  13. ?> 

用命令行运行

 

 
  1. #php -f test1.php & 

输出结果

 

 
  1. task 0 [http://localhost/feedbowl/t2.php?job=task1] get: 
  2. child start, pid 5804 
  3. 5804 2013-01-15 20:22:35 
  4. 5804 2013-01-15 20:22:36 
  5. 5804 2013-01-15 20:22:37 
  6. 5804 2013-01-15 20:22:38 
  7. 5804 2013-01-15 20:22:39 
  8.  
  9. task 1 [http://localhost/feedbowl/t2.php?job=task2] get: 
  10. child start, pid 5804 
  11. 5804 2013-01-15 20:22:35 
  12. 5804 2013-01-15 20:22:36 
  13. 5804 2013-01-15 20:22:37 
  14. 5804 2013-01-15 20:22:38 
  15. 5804 2013-01-15 20:22:39 
  16.  
  17. task 2 [http://localhost/feedbowl/t2.php?job=task3] get: 
  18. child start, pid 5804 
  19. 5804 2013-01-15 20:22:35 
  20. 5804 2013-01-15 20:22:36 
  21. 5804 2013-01-15 20:22:37 
  22. 5804 2013-01-15 20:22:38 
  23. 5804 2013-01-15 20:22:39 

从打印的时间看到，多个任务几乎是同时运行的。

上一篇：以实例全面讲解PHP中多进程编程的相关函数的使用

下一篇：PHP的Yii框架的基本使用示例

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表
学习交流
更多

硬盘分区如何设置准确的分区空间

硬盘分区如何设置准确的分区空间...
热门图片
更多
猜你喜欢的新闻
猜你喜欢的关注

新闻热点

英伟达市值一夜大涨9246亿 创2023年5月以来最大单周涨幅
2024-04-27 13:35:46
雷军：小米正在申请3万件专利，以提升自身的竞争力
2024-04-27 13:33:47
人参泡酒15年后竟“复活”？网友：这酒还能喝不？
2024-04-24 22:53:44
芯片股普涨！英伟达市值一夜大涨6000亿元
2024-04-23 19:32:50
面馆老板1天卖100碗刚够交房租 要卖到150碗才能实现盈利
2024-04-23 19:25:50
跌近30%！茶百道上市一小时跌没3年净利润
2024-04-23 19:13:19

疑难解答

图片精选

网友关注

关于本站 - 网上投稿 - 商务合作 - 隐私政策 - 网站地图
Copyright © 2008 - 2024 VEVB.COM. All Rights Reserved.武林网 版权所有