Linux服务器系统监控框架与MSN、E-mail、手机短信报警的实现
<?php//HTTP服务器监控if (htmlspecialchars($_POST["menu"]) == "http") ? { ? ? ?$date = htmlspecialchars($_POST["date"]); ? ? ?$ip = htmlspecialchars($_POST["ip"]); ? ?$port = htmlspecialchars($_POST["port"]); ? ?$status = htmlspecialchars($_POST["status"]);//状态，0表示无法访问，1表示正常，2表示无法访问但能ping通 ? ?//...下一步处理（省略）... ?}//TCP服务器监控if (htmlspecialchars($_POST["menu"]) == "tcp") ? { ? ? ?$date = htmlspecialchars($_POST["date"]); ? ? ?$ip = htmlspecialchars($_POST["ip"]); ? ?$port = htmlspecialchars($_POST["port"]); ? ?$status = htmlspecialchars($_POST["status"]);//状态，0表示无法访问，1表示正常，2表示无法访问但能ping通 ? ?//...下一步处理（省略）...}//MySQL服务器监控if (htmlspecialchars($_POST["menu"]) == "mysql") ? { ? ? ?$date = htmlspecialchars($_POST["date"]); ? ? ?$ip = htmlspecialchars($_POST["ip"]); ? ?$port = htmlspecialchars($_POST["port"]); ? ?$abstract = htmlspecialchars($_POST["abstract"]);//故障摘要（必须为全角） ? ?$info = htmlspecialchars($_POST["info"]);//故障详细描述 ? ?$failback = htmlspecialchars($_POST["failback"]);//如果服务器存活，此处接收的值为active ? ?//...下一步处理（省略）...}?>
二、主动探测监控（“监控机”主动探测“被监控机”）
１、HTTP服务器监控
脚本：/data0/monitor/http.sh
#采用HTTP POST方式发送检测信息给接口程序interface.php，接口程序负责分析信息，决定是否发送报警MSN消息、手机短信、电子邮件。
send_msg_to_interface()
{
? ?/usr/bin/curl -m 600 -d menu=http -d date=$date -d ip=$server_ip -d port=$server_port -d status=$status http://127.0.0.1:8888/interface.php
}
server_all_len=${#server_all_list[*]}
i=0
while ?[ $i -lt $server_all_len ]
do
? ?server_ip=$(echo ${server_all_list[$i]} | awk -F ':' '{print $1}')
? ?server_port=$(echo ${server_all_list[$i]} | awk -F ':' '{print $2}')
? ?if curl -m 10 -G http://${server_all_list[$i]}/ > /dev/null 2>&1
? ?then
? ? ?#status: ? ?0,http down ? ?1,http ok ? ?2,http down but ping ok
? ? ?status=1
? ? ? ? ? ?echo "服务器${server_ip}，端口${server_port}能够正常访问！"
? ?else
? ? ? ?if curl -m 30 -G http://${server_all_list[$i]}/ > /dev/null 2>&1
? ? ? ?then
? ? ? ? ? ?status=1
? ? ? ? ? ?echo "服务器${server_ip}，端口${server_port}能够正常访问！"
? ? ? ?else
? ? ? ? ? ?if ping -c 1 $server_ip > /dev/null 2>&1
? ? ? ? ? ?then
? ? ? ? ? ? ? ?status=2
? ? ? ? ? ? ? ?echo "服务器${server_ip}，端口${server_port}无法访问，但是能够Ping通！"
? ? ? ? ? ?else
? ? ? ? ? ? ? ?status=0
? ? ? ? ? ? ? ?echo "服务器${server_ip}，端口${server_port}无法访问，并且无法Ping通！"
? ? ? ? ? ?fi
? ? ? ?fi
? ?fi
?send_msg_to_interface
? ?let i++
done
２、TCP服务器监控
脚本：/data0/monitor/tcp.sh
#采用HTTP POST方式发送检测信息给接口程序interface.php，接口程序负责分析信息，决定是否发送报警MSN消息、手机短信、电子邮件。
send_msg_to_interface()
{
? ?/usr/bin/curl -m 600 -d menu=tcp -d date=$date -d ip=$server_ip -d port=$server_port -d status=$status http://127.0.0.1:8888/interface.php
}
server_all_len=${#server_all_list[*]}
i=0
while ?[ $i -lt $server_all_len ]
do
? ?server_ip=$(echo ${server_all_list[$i]} | awk -F ':' '{print $1}')
? ?server_port=$(echo ${server_all_list[$i]} | awk -F ':' '{print $2}')
? ?if nc -vv -z -w 3 $server_ip $server_port > /dev/null 2>&1
? ?then
? ? ? ?#status: ? ?0,http down ? ?1,http ok ? ?2,http down but ping ok
? ? ? ?status=1
? ? ? ?echo "服务器${server_ip}，端口${server_port}能够正常访问！"
? ?else
? ? ? ?if nc -vv -z -w 10 $server_ip $server_port > /dev/null 2>&1
? ? ? ?then
? ? ? ? ? ?status=1
? ? ? ? ? ?echo "服务器${server_ip}，端口${server_port}能够正常访问！"
? ? ? ?else
? ? ? ? ? ?if ping -c 1 $server_ip > /dev/null 2>&1
? ? ? ? ? ?then
? ? ? ? ? ? ? ?status=2
? ? ? ? ? ? ? ?echo "服务器${server_ip}，端口${server_port}无法访问，但是能够Ping通！"
? ? ? ? ? ?else
? ? ? ? ? ? ? ?status=0
? ? ? ? ? ? ? ?echo "服务器${server_ip}，端口${server_port}无法访问，并且无法Ping通！"
? ? ? ? ? ?fi
? ? ? ?fi
? ?fi
? ?send_msg_to_interface
? ?let i++
done
３、MySQL服务器监控
①、MySQL是否能够连接
②、MySQL是否发生表损坏等错误
③、MySQL活动连接数是否过多
④、MySQL从库是否同步正常
⑤、MySQL从库同步延迟时间是否过大
脚本：/data0/monitor/mysql.php
<?php//$server_list[]="服务器地址:端口:帐号:密码";$server_list[]="192.168.1.11:3306:root:password";$server_list[]="192.168.1.12:3306:root:password";$server_list[]="192.168.1.13:3306:root:password";$database="mysql";$curl = new Curl_Class(); foreach ($server_list as $server) { ? ?$status=1;//初始化，正常状态 ?unset($data); ? ?$data["menu"] = "mysql"; ?$data["info"] = ""; ? ?list($data["ip"], $data["port"], $username, $password) = explode(":", $server); ? ?$connect = @mysql_connect($data["ip"].":".$data["port"], $username, $password); ? ?if(! $connect) ? ?{ ? ? ? ?$status=0; ? ? ? ?$data["info"] = $data["info"] . "无法连接MySQL服务器\r\n"; ? ?} ? ? ?$select = @mysql_select_db($database, $connect); ? ?$result = @mysql_query("show slave status"); ? ?$rs_slave = @mysql_fetch_array($result); ? ?$result = @mysql_query("show global status like 'Threads_running'"); ? ?$rs_threads = @mysql_fetch_array($result); ? ?if($rs_slave["Slave_SQL_Running"] == "No") ? ?{ ? ? ? ?$status=0;//故障状态 ? ? ? ?$data["abstract"] = "从库不同步"; ? ? ? ?$data["info"] = $data["info"] . "Slave_SQL_Running = No\r\n"; ? ? ?} ? ?if($rs_slave["Slave_IO_Running"] == "No") ? ?{ ? ? ? ?$status=0; ? ? ? ?$data["abstract"] = "从库不同步"; ? ? ? ?$data["info"] = $data["info"] . "Slave_IO_Running = No\r\n"; ? ? ?} ? ?if($rs_slave["Last_Error"] != "") ? ?{ ? ? ? ?$status=0; ? ? ? ?$data["abstract"] = "从库同步出错"; ? ? ? ?$data["info"] = $data["info"] . "Last_Error = ".substr($rs_slave["Last_Error"], 0, 40)."\r\n"; ? ?} ? ?if($rs_slave["Seconds_Behind_Master"] > 180) ? ?{ ? ? ? ?$status=0; ? ? ? ?$data["abstract"] = "从库同步延迟时间高达".$rs_slave["Seconds_Behind_Master"]."秒"; ? ? ? ?$data["info"] = $data["info"] . "Seconds_Behind_Master = ".$rs_slave["Seconds_Behind_Master"]."\r\n"; ? ?} ? ?if($rs_threads["Value"] > 60) ? ?{ ? ? ? ?$status=0; ? ? ? ?$data["abstract"] = "活动连接数多达".$rs_threads["Value"]; ? ? ? ?$data["info"] = $data["info"] . "Threads_running = ".$rs_threads["Value"]."\r\n"; ? ?} ? ?$data["date"] = date("Y-m-d_H:i:s"); ? ?if($status == 0) ? ?{ ? ? ? ?$post = @$curl->post("http://127.0.0.1:8888/interface.php", $data); ? ? ? ?echo "MySQL服务器“".$data["ip"].":".$data["port"]."”发生故障!\n"; ? ? ? ?print_r($post); ? ? ? ? ?} ? ?else ? ?{ ? ? ? ?$data["failback"] = "active";//服务器正常，发送通知信息 ? ? ? ?$post = @$curl->post("http://127.0.0.1:8888/interface.php", $data); ? ? ? ?echo "MySQL服务器“".$data["ip"].":".$data["port"]."”运行正常!\n"; ? ? ? ?print_r($post); ? ?}}/************************************************************************ Curl_Class :curl 类*********************************************************************/class Curl_Class{ ? ?function Curl_Class() ? ?{ ? ? ? ?return true; ? ?} ? ?function execute($method, $url, $fields = '', $userAgent = '', $httpHeaders = '', ? ? ? ?$username = '', $password = '') ? ?{ ? ? ? ?$ch = Curl_Class::create(); ? ? ? ?if (false === $ch) ? ? ? ?{ ? ? ? ? ? ?return false; ? ? ? ?} ? ? ? ?if (is_string($url) && strlen($url)) ? ? ? ?{ ? ? ? ? ? ?$ret = curl_setopt($ch, CURLOPT_URL, $url); ? ? ? ?} ? ? ? ?else ? ? ? ?{ ? ? ? ? ? ?return false; ? ? ? ?} ? ? ? ?//是否显示头部信息 ? ? ? ?curl_setopt($ch, CURLOPT_HEADER, false); ? ? ? ?// ? ? ? ?curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); ? ? ? ?if ($username != '') ? ? ? ?{ ? ? ? ? ? ?curl_setopt($ch, CURLOPT_USERPWD, $username . ':' . $password); ? ? ? ?} ? ? ? ?$method = strtolower($method); ? ? ? ?if ('post' == $method) ? ? ? ?{ ? ? ? ? ? ?curl_setopt($ch, CURLOPT_POST, true); ? ? ? ? ? ?if (is_array($fields)) ? ? ? ? ? ?{ ? ? ? ? ? ? ? ?$sets = array(); ? ? ? ? ? ? ? ?foreach ($fields as $key => $val) ? ? ? ? ? ? ? ?{ ? ? ? ? ? ? ? ? ? ?$sets[] = $key . '=' . urlencode($val); ? ? ? ? ? ? ? ?} ? ? ? ? ? ? ? ?$fields = implode('&', $sets); ? ? ? ? ? ?} ? ? ? ? ? ?curl_setopt($ch, CURLOPT_POSTFIELDS, $fields); ? ? ? ?} ? ? ? ?else ? ? ? ? ? ?if ('put' == $method) ? ? ? ? ? ?{ ? ? ? ? ? ? ? ?curl_setopt($ch, CURLOPT_PUT, true); ? ? ? ? ? ?} ? ? ? ?//curl_setopt($ch, CURLOPT_PROGRESS, true); ? ? ? ?//curl_setopt($ch, CURLOPT_VERBOSE, true); ? ? ? ?//curl_setopt($ch, CURLOPT_MUTE, false); ? ? ? ?curl_setopt($ch, CURLOPT_TIMEOUT, 600); ? ? ? ?if (strlen($userAgent)) ? ? ? ?{ ? ? ? ? ? ?curl_setopt($ch, CURLOPT_USERAGENT, $userAgent); ? ? ? ?} ? ? ? ?if (is_array($httpHeaders)) ? ? ? ?{ ? ? ? ? ? ?curl_setopt($ch, CURLOPT_HTTPHEADER, $httpHeaders); ? ? ? ?} ? ? ? ?$ret = curl_exec($ch); ? ? ? ?if (curl_errno($ch)) ? ? ? ?{ ? ? ? ? ? ?curl_close($ch); ? ? ? ? ? ?return array(curl_error($ch), curl_errno($ch)); ? ? ? ?} ? ? ? ?else ? ? ? ?{ ? ? ? ? ? ?curl_close($ch); ? ? ? ? ? ?if (!is_string($ret) || !strlen($ret)) ? ? ? ? ? ?{ ? ? ? ? ? ? ? ?return false; ? ? ? ? ? ?} ? ? ? ? ? ?return $ret; ? ? ? ?} ? ?} ? ?function post($url, $fields, $userAgent = '', $httpHeaders = '', $username = '', ? ? ? ?$password = '') ? ?{ ? ? ? ?$ret = Curl_Class::execute('POST', $url, $fields, $userAgent, $httpHeaders, $username, ? ? ? ? ? ?$password); ? ? ? ?if (false === $ret) ? ? ? ?{ ? ? ? ? ? ?return false; ? ? ? ?} ? ? ? ?if (is_array($ret)) ? ? ? ?{ ? ? ? ? ? ?return false; ? ? ? ?} ? ? ? ?return $ret; ? ?} ? ?function get($url, $userAgent = '', $httpHeaders = '', $username = '', $password = ? ? ? ?'') ? ?{ ? ? ? ?$ret = Curl_Class::execute('GET', $url, '', $userAgent, $httpHeaders, $username, ? ? ? ? ? ?$password); ? ? ? ?if (false === $ret) ? ? ? ?{ ? ? ? ? ? ?return false; ? ? ? ?} ? ? ? ?if (is_array($ret)) ? ? ? ?{ ? ? ? ? ? ?return false; ? ? ? ?} ? ? ? ?return $ret; ? ?} ? ?function create() ? ?{ ? ? ? ?$ch = null; ? ? ? ?if (!function_exists('curl_init')) ? ? ? ?{ ? ? ? ? ? ?return false; ? ? ? ?} ? ? ? ?$ch = curl_init(); ? ? ? ?if (!is_resource($ch)) ? ? ? ?{ ? ? ? ? ? ?return false; ? ? ? ?} ? ? ? ?return $ch; ? ?}}?>
4、主动监控守护进程
脚本：/data0/monitor/monitor.sh
引用#!/bin/sh
while true
do
? ?/bin/sh /data0/monitor/http.sh > /dev/null 2>&1
? ?/bin/sh /data0/monitor/tcp.sh > /dev/null 2>&1
? ?/usr/local/php/bin/php /data0/monitor/mysql.php > /dev/null 2>&1
? ?sleep 10
done
启动主动监控守护进程：
/usr/bin/nohup /bin/sh /data0/monitor/monitor.sh 2>&1 > /dev/null &
三、被动报告监控（“被监控机”采集数据发送给“监控机”）
１、磁盘空间使用量监控
２、磁盘Inode使用量监控
３、Swap交换空间使用量监控
４、系统负载监控
５、Apache进程数监控
被动监控这部分，在我的文章《写完“Linux服务器监控系统 ServMon V1.1” 》中已经实现，就不再详细写出。
????? 原文链接：http://blog.s135.com/read.php/354.htm]
