老版地址(仅作固定作用):old.jincong.net

浅谈PHP进程管理

这篇文章是对之前一篇文章的补充和改进,创建一个主(mae)进程,主进程安装定时器,每隔5分钟检测一次队列长度,根据队列长度计算需要的woke进程,然后创建或者杀掉子进程。这样做的好处是防止队列堆积,任务......
以下是【金聪采编】分享的内容全文:

这篇文章是对之前一篇文章的补充和改进, 创建一个主(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。或者在终端启动进程的时候进行重定向

<?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进程管理详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对金聪精品网站的支持!

金聪线报提示:[ 浅谈PHP进程管理 ] 仅为会员分享交流,仅供学习、参考使用,请勿用于其他用途,如果想商业使用或者代理,请自行联系版权方获取授权。任何未获取授权的商业使用与本站无关,请自行承担相应责任。
本站不存储任何资源文件,敬请周知!
此资源仅供个人学习、研究使用,禁止非法转播或商业用途,请在获取后24小时内删除,如果你觉得满意,请寻求购买正版或获取授权!
免责申明:本站仅提供学习的平台,所有资料均来自于网络分享线索,版权归原创者所有!本站不提供任何保证,并不承担任何法律责任,如果对您的版权或者利益造成损害,请提供相应的资质证明,我们将于3个工作日内予以处理。版权申诉相关说明
本网站采用 BY-NC-SA 协议进行授权 转载请注明原文链接:浅谈PHP进程管理
221381
领取福利

微信扫码领取福利

微信扫码分享