這篇文章主要介紹了深入探究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 

從打印的時間看到，多個任務幾乎是同時運行的。