• 企业400电话
  • 微网小程序
  • AI电话机器人
  • 电商代运营
  • 全 部 栏 目

    企业400电话 网络优化推广 AI电话机器人 呼叫中心 网站建设 商标✡知产 微网小程序 电商运营 彩铃•短信 增值拓展业务
    浅谈PHP进程管理

    这篇文章是对之前一篇文章的补充和改进, 创建一个主(master)进程,主进程安装定时器,每隔5分钟检测一次队列长度,根据队列长度计算需要的worker进程,

    然后创建或者杀掉子进程。这样做的好处是防止队列堆积,任务得不到及时处理。更新业务代码,只需要reload操作即可。

    整个流程有以下知识点:

    创建守护进程的步骤:

    1. 设置默认文件权限
    2. fork一个进程,父进程退出
    3. 调用setsid创建一个新的会话
    4. 将当前工作目录更改为根目录
    5. 关闭不再需要的文件描述符

    使用信号实现定时器
    上一篇定时器依赖于系统的定时任务,这次使用闹钟信号实现,php 5.3.0以下的版本依赖于ticks,5.3.0及以上版本可使用pcntl_signal_dispatch

    信号:提供了一种异步事件处理的方法,在某个信号出现时,进程有以下三种方式对信号进行处理

    1. 忽略此信号
    2. 捕捉信号
    3. 执行系统默认动作,大多数信号的默认动作是终止该进程

    常见信号
    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如何限制定时任务的进程数量
    • PHP基于进程控制函数实现多线程
    • PHP程序守护进程化实现方法详解
    • 一文看懂PHP进程管理器php-fpm
    • php多进程中的阻塞与非阻塞操作实例分析
    • php多进程并发编程防止出现僵尸进程的方法分析
    • PHP多进程通信-消息队列使用
    • php多进程模拟并发事务产生的问题小结
    • 浅谈并发处理PHP进程间通信之外部介质
    上一篇:PHP多进程通信-消息队列使用
    下一篇:PHP htmlspecialchars()函数用法与实例讲解
  • 相关文章
  • 

    © 2016-2020 巨人网络通讯 版权所有

    《增值电信业务经营许可证》 苏ICP备15040257号-8

    浅谈PHP进程管理 浅谈,PHP,进程,管理,浅谈,