用PHP构建一个简易监视引擎

它负责设置对象的状态并实现记入日志。

ServiceLogger接口：指定一个日志类仅需要实现两个方法：log_service_event()和log_current_status()，它们分别在当一个run()检查返回时和当实现一个普通状态请求时被调用。

该接口如下所示：

     interfaceServiceLogger{
　publicfunctionlog_service_event(ServiceCheck$service);
　publicfunctionlog_current_status(ServiceCheck$service);
}
最后，你需要编写引擎本身。该想法类似于在前一节编写简单程序时使用的思想：服务器应该创建一个新的进程来处理每一次检查并使用一个SIGCHLD处理器来检测当检查完成时的返回值。可以同时检查的最大数目应该是可配置的，从而可以防止对系统资源的过渡使用。所有的服务和日志都将在一个XML文件中定义。

下面是定义该引擎的ServiceCheckRunner类：

     classServiceCheckRunner{
　private$num_children;
　private$services=array();
　private$children=array();
　publicfunction__construct($conf，$num_children)
　{
$loggers=array();
$this-＞num_children=$num_children;
$conf=simplexml_load_file($conf);
foreach($conf-＞loggers-＞loggeras$logger){
　$class=newReflection_Class("$logger-＞class");
　if($class-＞isInstantiable()){
$loggers["$logger-＞id"]=$class-＞newInstance();
　}
　else{
fputs(STDERR，"{$logger-＞class}cannotbeinstantiated.\n");
exit;
　}
}
foreach($conf-＞services-＞serviceas$service){
　$class=newReflection_Class("$service-＞class");
　if($class-＞isInstantiable()){
$item=$class-＞newInstance($service-＞params);
foreach($service-＞loggers-＞loggeras$logger){
　$item-＞register_logger($loggers["$logger"]);
}
$this-＞services[]=$item;
　}
　else{
fputs(STDERR，"{$service-＞class}isnotinstantiable.\n");
exit;
　}
}
　}
　privatefunctionnext_attempt_sort($a，$b){
if($a-＞next_attempt()==$b-＞next_attempt()){
　return0;
}
return($a-＞next_attempt()＜$b-＞next_attempt())?-1:1;
　}
　privatefunctionnext(){
usort($this-＞services，array($this，'next_attempt_sort'));
return$this-＞services[0];
　}
　publicfunctionloop(){
declare(ticks=1);
pcntl_signal(SIGCHLD，array($this，"sig_child"));
pcntl_signal(SIGUSR1，array($this，"sig_usr1"));
while(1){
　$now=time();
　if(count($this-＞children)＜$this-＞num_children){
$service=$this-＞next();
if($now＜$service-＞next_attempt()){
　sleep(1);
　continue;
}
$service-＞set_next_attempt();
if($pid=pcntl_fork()){
　$this-＞children[$pid]=$service;
}
else{
　pcntl_alarm($service-＞timeout());
　exit($service-＞run());
}
　}
}
　}
　publicfunctionlog_current_status(){
foreach($this-＞servicesas$service){
　$service-＞log_current_status();
}
　}
　privatefunctionsig_child($signal){
$status=ServiceCheck::FAILURE;
pcntl_signal(SIGCHLD，array($this，"sig_child"));
while(($pid=pcntl_wait($status，WNOHANG))＞0){
　$service=$this-＞children[$pid];
　unset($this-＞children[$pid]);
　if(pcntl_wifexited($status)&&pcntl_wexitstatus($status)==ServiceCheck::SUCCESS)
　{
$status=ServiceCheck::SUCCESS;
　}
　$service-＞post_run($status);
}
　}
　privatefunctionsig_usr1($signal){
pcntl_signal(SIGUSR1，array($this，"sig_usr1"));
$this-＞log_current_status();
　}
}
这是一个很复杂的类。其构造器读取并分析一个XML文件，创建所有的将被监视的服务，并创建记录它们的日志程序。

loop()方法是该类中的主要方法。它设置请求的信号处理器并检查是否能够创建一个新的子进程。现在，如果下一个事件(以next_attempt时间CHUO排序)运行良好，那么一个新的进程将被创建。在这个新的子进程内，发出一个警告以防止测试持续时间超出它的时限，然后执行由run()定义的测试。

还存在两个信号处理器：SIGCHLD处理器sig_child()，负责收集已终止的子进程并执行它们的服务的post_run()方法；SIGUSR1处理器sig_usr1()，简单地调用所有已注册的日志程序的log_current_status()方法，这可以用于得到整个系统的当前状态。

当然，这个监视架构并不没有做任何实际的事情。但是首先，你需要检查一个服务。下列这个类检查是否你从一个HTTP服务器取回一个"200ServerOK"响应：

     classHTTP_ServiceCheckextendsServiceCheck{
　public$url;
　publicfunction__construct($params){
foreach($paramsas$k=＞$v){
　$k="$k";
　$this-＞$k="$v";
}
　}
　publicfunctionrun(){
if(is_resource(@fopen($this-＞url，"r"))){
　returnServiceCheck::SUCCESS;
}
else{
　returnServiceCheck::FAILURE;
}
　}
}

与你以前构建的框架相比，这个服务极其简单，在此恕不多描述。

五.示例ServiceLogger进程

下面是一个示例ServiceLogger进程。当一个服务停用时，它负责把一个电子邮件发送给一个待命人员：

     classEmailMe_ServiceLoggerimplementsServiceLogger{
　publicfunctionlog_service_event(ServiceCheck$service)
　{
if($service-＞current_status==ServiceCheck::FAILURE){
　$message="Problemwith{$service-＞description()}\r\n";
　mail('oncall@example.com'，'ServiceEvent'，$message);
　if($service-＞consecutive_failures()＞5){
mail('oncall_backup@example.com'，'ServiceEvent'，$message);
　}
}
　}
　publicfunctionlog_current_status(ServiceCheck$service){
return;
　}
}
如果连续失败五次，那么该进程还把一个消息发送到一个备份地址。注意，它并没有实现一个有意义的log_current_status()方法。

无论何时象如下这样改变一个服务的状态，你都应该实现一个写向PHP错误日志的ServiceLogger进程：

     classErrorLog_ServiceLoggerimplementsServiceLogger{
　publicfunctionlog_service_event(ServiceCheck$service)
　{
if($service-＞current_status()!==$service-＞previous_status()){
　if($service-＞current_status()===ServiceCheck::FAILURE){
$status='DOWN';
　}
　else{
$status='UP';
　}
　error_log("{$service-＞description()}changedstatusto$stat