这篇文章给大家介绍PHP怎么实现进程管理,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
创建守护进程的步骤:
设置默认文件权限
fork一个进程,父进程退出
调用setsid创建一个新的会话
将当前工作目录更改为根目录
关闭不再需要的文件描述符
使用信号实现定时器
上一篇定时器依赖于系统的定时任务,这次使用闹钟信号实现,php 5.3.0以下的版本依赖于ticks,5.3.0及以上版本可使用pcntl_signal_dispatch
信号:提供了一种异步事件处理的方法,在某个信号出现时,进程有以下三种方式对信号进行处理
忽略此信号
捕捉信号
执行系统默认动作,大多数信号的默认动作是终止该进程
常见信号
SIGKILL,SIGSTOP是两种不能被用户忽略和捕捉的信号
SIGINT(2):程序终止信号,通常是Ctrl-C)时发出,用于通知前台进程组终止进程
SIGQUIT(3):和SIGINT类似, 但由QUIT字符(通常是Ctrl+/)来控制. 进程收到该消息退出时会产生core文件
SIGKILL(9):立即终止进程,不可被忽略捕捉或阻塞
SIGUSR1(10):用户定义信号
SIGUSR2(12):留给用户使用
SIGALRM(14):闹钟信号
SIGTERM(15):终止进程,可被程序捕捉,使得进程可以执行完清理操作。
SIGSTOP(19):停止一个进程,该进程还未结束, 只是暂停执行
防止产生僵尸进程
所有的进程在退出的时候都会成为僵尸进程,这时候如果父进程还在运行,没有调用wait或者waitpid,则僵尸进程占用的资源不会被清理,如果父进程已终止,僵尸进程由init进程进行清理。
抽调业务代码,主要代码如下
其中要注意的一点,创建守护进程关闭输入输出,错误输出流的时候,如果代码后面有echo等输出字符,将出现致命错误,需要在php代码中重定向输出流到/dev/null。或者在终端启动进程的时候进行重定向
<?php
define('PROC_MAX', 10);
define('PROC_MIN', 5);
$cmd = $argv[1];
$aPid = [];
$pidFile = __DIR__ . '/pid.pid';
$pid = file_get_contents($pidFile);
switch($cmd){
case 'start' :
if(posix_kill($pid, 0)){
echo "gamelog process is already exsits!\n";
return false;
}
//设置默认文件权限
umask(022);
//fork
$pid = pcntl_fork();
if($pid < 0){
exit('fork error!');
}else if($pid > 0){
exit;
}
//脱离当前终端
posix_setsid();
//将当前工作目录更改为根目录
chdir('/');
//关闭文件描述符
fclose(STDIN);
fclose(STDOUT);
fclose(STDERR);
//重定向输入输出
global $STDOUT, $STDERR;
$STDOUT = fopen('/dev/null', 'a');
$STDERR = fopen('/dev/null', 'a');
cli_set_process_title('gamelog:master');
$pid = posix_getpid();
file_put_contents($pidFile, $pid);
//闹钟信号
pcntl_signal(SIGALRM, function() use (&$aPid) {
pcntl_alarm(300);
$workerNum = mt_rand(1, 20);//此处检测你需要的进程数
$daemonNum = count($aPid);
($workerNum > PROC_MAX) && ($workerNum = PROC_MAX);
if($daemonNum < $workerNum){
$procNum = $workerNum - $daemonNum;
$procNum = max(PROC_MIN, $procNum);
for($p = 1; $p <= $procNum; $p++){
$pid = pcntl_fork();
if ($pid < 0) {
exit('fork error!');
} else if ($pid == 0) {
cli_set_process_title('gamelog:worker');
while (true) {
//do your work
usleep(100);
}
exit();
} else {
$aPid[] = $pid;
}
}
}else if($daemonNum > $workerNum){
$wokerNum = max($wokerNum, PROC_MIN);
$killNum = $daemonNum - $workerNum;
foreach($aPid as $key=>$pid){
if(posix_kill($pid, SIGKILL)){
unset($aPid[$key]);
if(--$killNum <= 0){
break;
}
}
}
}
}, false);
pcntl_signal(SIGUSR1, function() use (&$aPid, $pid){
foreach($aPid as $key=>$chpid){
if(!posix_kill($chpid, SIGKILL)){
echo "kill child $chpid faild\n";
}
}
posix_kill($pid, SIGKILL);
}, false);
pcntl_signal(SIGUSR2, function() use (&$aPid, $pid){
foreach($aPid as $key=>$chpid){
if(!posix_kill($chpid, SIGKILL)){
echo "kill child $chpid faild\n";
}
}
if(!posix_kill($pid, SIGALRM)){
echo "restart gamelog faild\n";
}
}, false);
posix_kill($pid, SIGALRM);
while (true) {
pcntl_signal_dispatch();
$pid = pcntl_wait($status, WUNTRACED);//不阻塞
}
break;
case 'stop' :
if(!posix_kill($pid, SIGUSR1)){
exit('stop gamelog process error!');
}
break;
case 'reload' :
if(!posix_kill($pid, SIGUSR2)){
exit('restop gamelog process error!');
}
break;
default :
echo "Useage php signal.php start|stop|reload\n";
}
关于PHP怎么实现进程管理就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。