PHP进程管理

发布日期:2019-08-07

 

这篇文章是对之前一篇文章的补充和改进 创建一个主(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!" 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" } } 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" } } if(!posix_kill($pid SIGALRM)){ echo "restart gamelog faild" } } 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"}