这篇文章是对之前一篇文章的补充和改进, 创建一个主(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。或者在终端启动进程的时候进行重定向
<?phpdefine(‘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进程管理
原文地址：https://www.cnblogs.com/gaoqin31/p/9904337.html