2014-09-05
[php]
//保证子进程上限
if($this->_maxFork >0 && $this->_children > $this->_maxFork)
{
Yii::log("_children > ".$this->_maxFork,CLogger::LEVEL_WARNING,__METHOD__);
$this->handler(SIGCHLD);
usleep(200);
continue;
}
/**
* 监控信号
* @param object socket $clientt
* @return boolean
*/
public function handler($signo) {
Yii::log("handler {$signo} ",CLogger::LEVEL_INFO, __METHOD__);
switch(intval($signo)) {
case SIGCLD:
case SIGCHLD:
Yii::log("SIGCHLD sub proccess ",CLogger::LEVEL_TRACE, __METHOD__);
//正常退出
//declare = 1, that means one signal may be correspond multi-process die
while( ($pid = pcntl_wait($status, WNOHANG|WUNTRACED)) > 0 ) {
if (FALSE === pcntl_wifexited($status)) {
Yii::log("sub proccess {$pid} exited unormally with code {$status}",CLogger::LEVEL_WARNING, __METHOD__);
} else {
Yii::log("sub proccess {$pid} exited normally",CLogger::LEVEL_INFO, __METHOD__);
}
$this->_children--;
}
break;
case SIGINT:
case SIGQUIT:
case SIGHUP:
//异常退出
$this->_cleanup();
exit(0);
break;
default:
break;
}
}
//保证子进程上限
if($this->_maxFork >0 && $this->_children > $this->_maxFork)
{
Yii::log("_children > ".$this->_maxFork,CLogger::LEVEL_WARNING,__METHOD__);
$this->handler(SIGCHLD);
// usleep(200);
continue;
}
/**
* 监控信号
* @param object socket $clientt
* @return boolean
*/
public function handler($signo) {
Yii::log("handler {$signo} ",CLogger::LEVEL_INFO, __METHOD__);
switch(intval($signo)) {
case SIGCLD:
case SIGCHLD:
Yii::log("SIGCHLD sub proccess ",CLogger::LEVEL_TRACE, __METHOD__);
//正常退出
//declare = 1, that means one signal may be correspond multi-process die
while( ($pid = pcntl_wait($status, WNOHANG|WUNTRACED)) > 0 ) {
if (FALSE === pcntl_wifexited($status)) {
Yii::log("sub proccess {$pid} exited unormally with code {$status}",CLogger::LEVEL_WARNING, __METHOD__);
} else {
Yii::log("sub proccess {$pid} exited normally",CLogger::LEVEL_INFO, __METHOD__);
}
$this->_children--;
}
break;
case SIGINT:
case SIGQUIT:
case SIGHUP:
//异常退出
$this->_cleanup();
exit(0);
break;
default:
break;
}
}
【多进程方式注意点】
变量共享问题
因为是进程,可以理解成主进程的一个拷贝,执行是从调用 pcntl_fork() 后各主、子进程后自往后运行,避免子进程层层嵌套,一般子进程执行完后是用exit(0)来退出。 子进程如果执行过程中崩溃不会影响到主进程,也不能和主进程共享变量。
信号和select 冲突问题
pcntl_signal 注册信号后会和 stream_select 有冲突
PHP Error[2]: stream_select(): unable to select [4]: 被中断的系统调用 (max_fd=10)
目前没找到解决方法,未采用 pcntl_signal 进行监控。
进程回收
子进程通过exit退出后,会变成僵尸进程,需要通过 pcntl_wait 来进行回收。
centos 测试中发现最大的进程上限是3.2万,通过设置子进程总数,大于设定值再调用 pcntl_wait 来进行回收
socket读写注意
多进程情况下,会出现对同个socket句柄,有多个进程同时在读的问题。
解决方法是读操作在主进程里,读出所有数据后,抛给子进程进行执行。
文件操作注意
filesize 函数在多进程情况下会出现取不到或取到的文件大小一直不变问题
这里采用直接调用 linux下的系统函数解决。
$file_size = @filesize($logFile);
//解决并发情况下取不到文件大小问题
if(0 == $file_size ||$this->_prevFileSize == $file_size )
{
$file_size = @exec('/usr/bin/stat -c %s '. escapeshellarg($logFile));
clearstatcache();
}
压力测试后1000的并发可达到350每秒的请求。应该还可优化。
1
CI框架连接数据库配置操作以及多数据库操作
09-05
2
asp 简单读取数据表并列出来 ASP如何快速从数据库读取大量数据
05-17
3
C语言关键字及其解释介绍 C语言32个关键字详解
04-05
4
C语言中sizeof是什么意思 c语言里sizeof怎样用法详解
04-26
5
PHP中的魔术方法 :__construct, __destruct , __call, __callStatic,__get, __set, __isset, __unset , __sleep,
09-05
6
将视频设置为Android手机开机动画的教程
12-11
7
PHP中的(++i)前缀自增 和 (i++)后缀自增
09-05
8
最简单的asp登陆界面代码 asp登陆界面源代码详细介绍
04-12
常用dos命令及语法
2014-09-27
PHP中include和require区别之我见
2014-09-05
如何安装PHPstorm并配置方法教程 phpstorm安装后要进行哪些配置
2017-05-03
php递归返回值的问题
2014-09-05
单片机编程好学吗?单片机初学者怎样看懂代码
2022-03-21
PHP 教程之如何使用BLOB存取图片信息实例
2014-09-05
学ug编程如何快速入门?
2022-03-17
PHP数组函数array
2014-09-05
学习使用C语言/C++编程的7个步骤!超赞~
2022-03-20
零基础的初学者怎样学习java,或者应该先学什么?
2022-03-21
街头斗士功夫进攻5最新版下载v1.1.1.107 安卓版
其它手游 65MB
下载
点击忍者大师游戏(tap ninja)下载v7.1.9 安卓版
其它手游 77.74MB
下载
tap ninja游戏下载v7.1.9 安卓版
其它手游 77.74MB
下载
德雷姆代尔手机版下载v2.7.0 安卓正式版
其它手游 187.16MB
下载
火柴人龙影战士中文版下载v2.0.0 安卓版
其它手游 101.44MB
下载
火柴人战士暗影龙珠格斗游戏下载v2.0.0 安卓版
其它手游 101.44MB
下载
火柴人勇士超级龙影搏斗最新版下载v2.0.0 安卓版
其它手游 101.44MB
下载
安洁拉世界奇幻之旅游戏下载v2.9 安卓版
其它手游 338.88MB
下载坦克沙盒游戏手机版(坦克物理模拟)下载v9.0 安卓版
下载
太空人抽卡对决手机版下载v1.6 安卓版
下载
棕熊露营旅行游戏下载v1.1.0 安卓版
下载
回家的猫游戏下载v2.5.18 安卓版
下载
蜗牛鲍勃3游戏(snail bob 3)下载v1.0.34 安卓版
下载
snail bob3最新版下载v1.0.34 安卓版
下载
西梅小说手机版v1.0
下载
超级舰队3k破解版下载v10.3 安卓最新版
下载