PHP中利用pcntl进行多进程并发控制

PHP中利用pcntl进行多进程并发控制

分类： PHP2010-11-08
23:07 7921人阅读 评论(1) 收藏 举报
phpfunctionbloguser测试服务器

pcntl_fork可以很方便的创建进程，对于一般的需要固定的多进程处理的应用场景来说，实现比较简单，但是，对于需要大量并发创建子进程的应用场景来说，主要的问题在于会产生大量的僵尸进程。。。



我们的应用中，之前是采用将过程中产生的子进程pid收集起来， 间隔一定时间统一回收（pcntl_waitpid），这样带来的一个问题是：在大量并发情况下，服务器压力过大，会导致子进程“死掉”，这个时候，子进程不是僵尸，无法回收掉，主控进程就卡在那里不动了。。。



今天借鉴了一下“http://www.perkiset.org/forum/php/forked_php_daemon_example-t474.0.html”文中的方式，用二次创建进程的方式（孙进程处理业务）来将子进程交给系统，达到了在父进程中不需要wait真正的业务子进程的目的，也更接近其他语言中的线程并发控制:



我们原来的子进程创建接口：

[php] view
plaincopy

/**

* author: selfimpr

* blog: http://blog.csdn.net/lgg201

* mail: lgg860911@yahoo.com.cn

*/

function new_child($func_name) {

$args = func_get_args();

unset($args[0]);

$pid = pcntl_fork();

if($pid == 0) {

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 {

return $pid;

}

}



新的方式：

[php] view
plaincopy

<?php

/**

* author: selfimpr

* blog: http://blog.csdn.net/lgg201

* mail: lgg860911@yahoo.com.cn

*/

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 {

exit;

}

}

}

?>



新方式的完整测试：

测试方法：cli模式下运行， ps -ef | grep php查看过程中的php进程情况

[php] view
plaincopy

<?php

/**

* author: selfimpr

* blog: http://blog.csdn.net/lgg201

* mail: lgg860911@yahoo.com.cn

*/

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";

?>

php ”Call to undefined function pcntl_fork”错误 解决办法

2010-08-09 15:05:39| 分类： 实习工作|举报|字号 订阅







下载LOFTER客户端

执行下面的函数时，php报了”Call to undefined function pcntl_fork”错误：

PHP代码



<?php

$pid = pcntl_fork();



if ($pid == -1) {

die("could not fork");

} else if ($pid) {

// we are the parent

} else {

// we are the child

}

?>;

原来是因为php默认没有安装pcntl扩展包，你可以缷载掉原来的，并用./configure –enable-pcntl重新编译php安装。

当然，你也可以不缷载php，而是直接编译pcntl扩展，并在php.ini文件中加载它即可：

代码



# 下载php源码并解压

cd php-5.3.2/ext/pcntl

phpize5

./configure --with-php-config=/usr/bin/php-config5

make && make install

安装完成后会输出*.so文件被编译在什么目录：Installing shared extensions: /usr/lib/php5/20060613+lfs/。/usr/lib/php5/20060613+lfs是php默认的扩展程序目录，所以你不需要在php.ini文件中额外的定义php扩展目录。

加载pcntl扩展：

代码



# 新建文件pcntl.ini

sudo vim /etc/php5/conf.d/pcntl.ini

# pcntl.ini的内容

extension=pcntl.so

最后重启php-cgi进程与Nginx：

代码



sudo /etc/init.d/php stop

sudo /etc/init.d/php start

sudo /etc/init.d/nginx restart

在命令行输入：

代码



php -r 'var_dump(function_exists("gzopen"));'

如果输出bool(true)，则表示pcntl扩展已经加载成功了。当然你也可以创建一个php文件，然后通过访问它来测试pcntl是否安装成功，文件内容如下：

PHP代码



<?php

echo function_exists("pcntl_fork");

?> 文章来自: 王殿臣-天空网(bestlovesky.com)详文参考：http://www.bestlovesky.com/read.php/950.htm



上一篇PHP中的uniqid在高并发下的重复问题

下一篇PHP
Memcached客户端官方文档翻译