浅谈PHP进程管理
2019/6/30 16:13:50
本文主要是介绍浅谈PHP进程管理,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
这篇文章是对之前一篇文章的补充和改进, 创建一个主(master)进程,主进程安装定时器,每隔5分钟检测一次队列长度,根据队列长度计算需要的worker进程,
然后创建或者杀掉子进程。这样做的好处是防止队列堆积,任务得不到及时处理。更新业务代码,只需要reload操作即可。
整个流程有以下知识点:
创建守护进程的步骤:
- 设置默认文件权限
- 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进程管理详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对找一找教程网网站的支持!
这篇关于浅谈PHP进程管理的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-12-19php8的协程和hyperf的协程有什么区别?-icode9专业技术文章分享
- 2024-12-19php8 的fiber是什么?-icode9专业技术文章分享
- 2024-12-05怎么在php8,1 里面开启 debug?-icode9专业技术文章分享
- 2024-12-05怎么在php8,1 里面开启 debug?-icode9专业技术文章分享
- 2024-11-29使用PHP 将ETH账户的资产汇集到一个账户
- 2024-11-23怎么实现安卓+php 热更新方案?-icode9专业技术文章分享
- 2024-11-22PHP 中怎么实现判断多个值是否为空、null 或者为 false?-icode9专业技术文章分享
- 2024-11-11开源 PHP 商城项目 CRMEB 二次开发和部署教程
- 2024-11-09怎么使用php在kaufland平台刊登商品?-icode9专业技术文章分享
- 2024-11-05PHP的抽象类和接口是什么,有什么区别-icode9专业技术文章分享