· next_attempt-下次尝试连接到服务器的时间。
· current_status-服务的当前状态：SUCCESS或FAILURE。
· previous_status-当前状态之前的状态。
· frequency-每隔多长时间检查一次服务。
· description-服务描述。
· consecutive_failures-自从上次成功以来，服务检查连续失败的次数。
· status_time-服务被检查的最后时间。
· failure_time-如果状态为FAILED，则它代表发生失败的时间。
这个类还实现了观察者模式，允许ServiceLogger类型的对象注册自身，然后当调用log_current_status()或log_service_event()时调用它。
这里实现的关键函数是run()，它负责定义应该怎样执行检查。如果检查成功，它应该返回SUCCESS；否则返回FAILURE。
当定义在run()中的服务检查返回后，post_run()方法被调用。它负责设置对象的状态并实现记入日志。
ServiceLogger接口：指定一个日志类仅需要实现两个方法：log_service_event()和log_current_status()，它们分别在当一个run()检查返回时和当实现一个普通状态请求时被调用。
该接口如下所示：
interface ServiceLogger {
public function log_service_event(ServiceCheck$service);
public function log_current_status(ServiceCheck$service);
}
最后，你需要编写引擎本身。该想法类似于在前一节编写简单程序时使用的思想：服务器应该创建一个新的进程来处理每一次检查并使用一个SIGCHLD处理器来检测当检查完成时的返回值。可以同时检查的最大数目应该是可配置的，从而可以防止对系统资源的过渡使用。所有的服务和日志都将在一个XML文件中定义。
下面是定义该引擎的ServiceCheckRunner类：
class ServiceCheckRunner {
private $num_children;
private $services = array();
private $children = array();
public function _ _construct($conf， $num_children)
{
$loggers = array();
$this-＞num_children = $num_children;
$conf = simplexml_load_file($conf);
foreach($conf-＞loggers-＞logger as $logger) {
$class = new Reflection_Class("$logger-＞class");
if($class-＞isInstantiable()) {
$loggers["$logger-＞id"] = $class-＞newInstance();
}
else {
fputs(STDERR， "{$logger-＞class} cannot be instantiated.\n");
exit;
}
}
foreach($conf-＞services-＞service as $service) {
$class = new Reflection_Class("$service-＞class");
if($class-＞isInstantiable()) {
$item = $class-＞newInstance($service-＞params);
foreach($service-＞loggers-＞logger as $logger) {
$item-＞register_logger($loggers["$logger"]);
}
$this-＞services[] = $item;
}
else {
fputs(STDERR， "{$service-＞class} is not instantiable.\n");
exit;
}
}
}
private function next_attempt_sort($a， $b){
if($a-＞next_attempt() == $b-＞next_attempt()) {
return 0;
}
return ($a-＞next_attempt() ＜ $b-＞next_attempt())? -1 : 1;
}
private function next(){
usort($this-＞services，array($this，'next_attempt_sort'));
return $this-＞services[0];
}
public function loop(){
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());
}
}
}
}
public function log_current_status(){
foreach($this-＞services as $service) {
$service-＞log_current_status();
}
}
private function sig_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);
}
}
private function sig_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://www.west263.com
以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!
