77. /**
78. *********************************************************************
79. * Curl_Class :curl 类
80. *********************************************************************/  
81. class Curl_Class  
82. {  
83.     function Curl_Class()  
84.      {  
85.         return true;  
86.      }  
87.   
88.     function execute($method, $url, $fields = '', $userAgent = '', $httpHeaders = '',  
89.         $username = '', $password = '')  
90.      {  
91.         $ch = Curl_Class::create();  
92.         if (false === $ch)  
93.          {  
94.             return false;  
95.          }  
96.   
97.         if (is_string($url) && strlen($url))  
98.          {  
99.             $ret = curl_setopt($ch, CURLOPT_URL, $url);  
100.          }  
101.         else  
102.          {  
103.             return false;  
104.          }  
105.         //是否显示头部信息  
106.          curl_setopt($ch, CURLOPT_HEADER, false);  
107.         //  
108.          curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);  
109.   
110.         if ($username != '')  
111.          {  
112.              curl_setopt($ch, CURLOPT_USERPWD, $username . ':' . $password);  
113.          }  
114.   
115.         $method = strtolower($method);  
116.         if ('post' == $method)  
117.          {  
118.              curl_setopt($ch, CURLOPT_POST, true);  
119.             if (is_array($fields))  
120.              {  
121.                 $sets = array();  
122.                 foreach ($fields as $key => $val)  
123.                  {  
124.                     $sets[] = $key . '=' . urlencode($val);  
125.                  }  
126.                 $fields = implode('&', $sets);  
127.              }  
128.              curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);  
129.          }  
130.         else  
131.             if ('put' == $method)  
132.              {  
133.                  curl_setopt($ch, CURLOPT_PUT, true);  
134.              }  
135.   
136.         //curl_setopt($ch, CURLOPT_PROGRESS, true);  
137.         //curl_setopt($ch, CURLOPT_VERBOSE, true);  
138.         //curl_setopt($ch, CURLOPT_MUTE, false);  
139.          curl_setopt($ch, CURLOPT_TIMEOUT, 600);  
140.   
141.         if (strlen($userAgent))  
142.          {  
143.              curl_setopt($ch, CURLOPT_USERAGENT, $userAgent);  
144.          }  
145.   
146.         if (is_array($httpHeaders))  
147.          {  
148.              curl_setopt($ch, CURLOPT_HTTPHEADER, $httpHeaders);  
149.          }  
150.   
151.         $ret = curl_exec($ch);  
152.   
153.         if (curl_errno($ch))  
154.          {  
155.              curl_close($ch);  
156.             return array(curl_error($ch), curl_errno($ch));  
157.          }  
158.         else  
159.          {  
160.              curl_close($ch);  
161.             if (!is_string($ret) || !strlen($ret))  
162.              {  
163.                 return false;  
164.              }  
165.             return $ret;  
166.          }  
167.      }  
168.   
169.     function post($url, $fields, $userAgent = '', $httpHeaders = '', $username = '',  
170.         $password = '')  
171.      {  
172.         $ret = Curl_Class::execute('POST', $url, $fields, $userAgent, $httpHeaders, $username,  
173.             $password);  
174.         if (false === $ret)  
175.          {  
176.             return false;  
177.          }  
178.   
179.         if (is_array($ret))  
180.          {  
181.             return false;  
182.          }  
183.         return $ret;  
184.      }  
185.   
186.     function get($url, $userAgent = '', $httpHeaders = '', $username = '', $password =  
187.         '')  
188.      {  
189.         $ret = Curl_Class::execute('GET', $url, '', $userAgent, $httpHeaders, $username,  
190.             $password);  
191.         if (false === $ret)  
192.          {  
193.             return false;  
194.          }  
195.   
196.         if (is_array($ret))  
197.          {  
198.             return false;  
199.          }  
200.         return $ret;  
201.      }  
202.   
203.     function create()  
204.      {  
205.         $ch = null;  
206.         if (!function_exists('curl_init'))  
207.          {  
208.             return false;  
209.          }  
210.         $ch = curl_init();  
211.         if (!is_resource($ch))  
212.          {  
213.             return false;  
214.          }  
215.         return $ch;  
216.      }  
217.   
218. }  
219. ?>  

<?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


启动主动监控守护进程：

---

三、被动报告监控（“被监控机”采集数据发送给“监控机”）
１、磁盘空间使用量监控
２、磁盘Inode使用量监控
３、Swap交换空间使用量监控
４、系统负载监控
５、Apache进程数监控

被动监控这部分，在我的文章《写完“Linux服务器监控系统 ServMon V1.1” 》中已经实现，就不再详细写出。