博客地址pcntl_fork可以很方便的创建进程,对于一般的需要固定的多进程处理的应用场景来说,实现比较简单,但是,对于需要大量并发创建子进程的应用场景来说,主要的问题在于会产生大量的僵尸进程我们的应用中,之前是采用将过程中产生的子进程pid收集起来, 间隔一定时间统一回收(pcntl_waitpid),这样带来的一个问题是:在大量并发情况下,服务器压力过大,会导致子进程“死掉”,这个时候,子进程不是僵尸,无法回收掉,主控进程就卡在那里不动了今天借鉴了一下“http://www.perkiset.org/forum/php/forked_php_daemon_example- t474.0.html”文中的方式,用二次创建进程的方式(孙进程处理业务)来将子进程交给系统,达到了在父进程中不需要wait真正的业务子进程的目的,也更接近其他语言中的线程并发控制:我们原来的子进程创建接口: 1. /**
2. * author: selfimpr
3. * blog: http://blog.csdn.net/lgg201
4. * mail: [email protected]
5. */
6. function new_child($func_name) {
7. $args = func_get_args();
8. unset($args[0]);
9. $pid = pcntl_fork();
10. if($pid == 0) {
11. function_exists($func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
12. } else if($pid == -1) {
13. echo "Couldn’t create child process.";
14. } else {
15. return $pid;
16. }
17. }
新的方式: 1. <?php
2. /**
3. * author: selfimpr
4. * blog: http://blog.csdn.net/lgg201
5. * mail: [email protected]
6. */
7. function daemon($func_name) {
8. $args = func_get_args();
9. unset($args[0]);
10. $pid = pcntl_fork();
11. if($pid) {
12. pcntl_wait($status);
13. } else if($pid == -1) {
14. echo "Couldn't create child process.";
15. } else {
16. $pid = pcntl_fork();
17. if($pid == 0) {
18. posix_setsid();
19. function_exists($func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
20. } else if($pid == -1) {
21. echo "Couldn’t create child process.";
22. } else {
23. exit;
24. }
25. }
26. }
27. ?>
新方式的完整测试:测试方法:cli模式下运行, ps -ef | grep php查看过程中的php进程情况# <?php
# /**
# * author: selfimpr
# * blog: http://blog.csdn.net/lgg201
# * mail: [email protected]
# */
# function daemon($func_name) {
# $args = func_get_args();
# unset($args[0]);
# $pid = pcntl_fork();
# if($pid) {
# pcntl_wait($status);
# } else if($pid == -1) {
# echo "Couldn't create child process.";
# } else {
# $pid = pcntl_fork();
# if($pid == 0) {
# posix_setsid();
# function_exists($func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
# } else if($pid == -1) {
# echo "Couldn’t create child process.";
# } else {
# sleep(5);
# exit;
# }
# }
# }
# function test() {
# while($i ++ < 10) {
# echo "child process $i\n";
# sleep(1);
# }
# }
# daemon(test);
# while(++ $j) echo "parent process $j\n";
# ?>
2. * author: selfimpr
3. * blog: http://blog.csdn.net/lgg201
4. * mail: [email protected]
5. */
6. function new_child($func_name) {
7. $args = func_get_args();
8. unset($args[0]);
9. $pid = pcntl_fork();
10. if($pid == 0) {
11. function_exists($func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
12. } else if($pid == -1) {
13. echo "Couldn’t create child process.";
14. } else {
15. return $pid;
16. }
17. }
新的方式: 1. <?php
2. /**
3. * author: selfimpr
4. * blog: http://blog.csdn.net/lgg201
5. * mail: [email protected]
6. */
7. function daemon($func_name) {
8. $args = func_get_args();
9. unset($args[0]);
10. $pid = pcntl_fork();
11. if($pid) {
12. pcntl_wait($status);
13. } else if($pid == -1) {
14. echo "Couldn't create child process.";
15. } else {
16. $pid = pcntl_fork();
17. if($pid == 0) {
18. posix_setsid();
19. function_exists($func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
20. } else if($pid == -1) {
21. echo "Couldn’t create child process.";
22. } else {
23. exit;
24. }
25. }
26. }
27. ?>
新方式的完整测试:测试方法:cli模式下运行, ps -ef | grep php查看过程中的php进程情况# <?php
# /**
# * author: selfimpr
# * blog: http://blog.csdn.net/lgg201
# * mail: [email protected]
# */
# function daemon($func_name) {
# $args = func_get_args();
# unset($args[0]);
# $pid = pcntl_fork();
# if($pid) {
# pcntl_wait($status);
# } else if($pid == -1) {
# echo "Couldn't create child process.";
# } else {
# $pid = pcntl_fork();
# if($pid == 0) {
# posix_setsid();
# function_exists($func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);
# } else if($pid == -1) {
# echo "Couldn’t create child process.";
# } else {
# sleep(5);
# exit;
# }
# }
# }
# function test() {
# while($i ++ < 10) {
# echo "child process $i\n";
# sleep(1);
# }
# }
# daemon(test);
# while(++ $j) echo "parent process $j\n";
# ?>
解决方案 »
免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货