php在linux下檢測mysql同步狀態的方法

2024-05-04 23:30:10

字體：大中小

來源：轉載

供稿：網友

這篇文章主要介紹了php在linux下檢測mysql同步狀態的方法,是Linux下使用php檢測mysql同步狀態的實用技巧,具有一定參考借鑒價值,需要的朋友可以參考下

本文實例講述了php在linux下檢測mysql同步狀態的方法。分享給大家供大家參考。具體分析如下：

這里通過兩個實例來介紹mysql同步狀態檢測實現方法。代碼如下:

復制代碼代碼如下:

		#!/bin/sh  
		   
		#check MySQL_Slave Status  
		#crontab time 00:10  
		MYSQL_USER="root" 
		MYSQL_PWD="123456" 
		MYSQL_SLAVE_LOG="/tmp/check_mysql_slave.log" 
		EMAIL="1351010****@139.com" 
		   
		MYSQL_PORT=`netstat -na|grep "LISTEN"|grep "3306"|awk -F[:" "]+ '{print $5}'`  
		MYSQL_IP=`ifconfig eth0|grep "inet addr" | awk -F[:" "]+ '{print $4}'`  
		MYSQL_SLAVE_STATUS=$(/usr/local/webserver/mysql/bin/mysql -u root -psylc23hua -S /tmp/mysql.sock -e 
		 
		"show slave statusG" | grep -i "running")  
		IO_ENV=`echo $MYSQL_SLAVE_STATUS | grep IO | awk ' {print $2}'`  
		SQL_ENV=`echo $MYSQL_SLAVE_STATUS | grep SQL | awk '{print $2}'`  
		NOW=$(date -d today +'%Y-%m-%d %H:%M:%S')  
		   
		if [ "$MYSQL_PORT" = "3306" ];then 
		  echo "mysql is running!" 
		else 
		  mail -s "warn!server: $MYSQL_IP mysql is down" "$EMAIL" 
		fi 
		   
		if [ "$IO_ENV" = "Yes" -a "$SQL_ENV" = "Yes" ];then 
		  echo "Slave is running!" 
		else 
		  echo "[ $NOW ] Slave is not running!" >> "$MYSQL_SLAVE_LOG" 
		  cat "$MYSQL_SLAVE_LOG" | mail -s "WARN! ${MySQL_IP}_replicate_error" "$EMAIL" 
		fi 
		   
		exit 0

php實例代碼,代碼如下:
check_rep.php：

復制代碼代碼如下:

		if(emptyempty($_REQUEST["key"])) die(':) missing key'); 
		if($_REQUEST["key"] != 'xupeng') die(':) error key'); 
		 
		include("mysql_instance.php"); 
		include("check_status_api.php"); 
		 
		define("USERNAME", "用戶名"); 
		define("PASSWORD", "密碼"); 
		define("DEBUGMODE", false); 
		 
		$instances = get_instances(); 
		 
		if($instances){ 
		 echo << 
		 
		<!-- 30分鐘自動刷新 --> 
		 
		END; 
		 echo " 
		n"; 
		 if(!DEBUGMODE){ 
		  echo " 
		n"; 
		 }else{ 
		  echo " 
		n"; 
		 } 
		 foreach($instances as $host){ 
		  $res = check_mysql_replication_status($host, USERNAME, PASSWORD); 
		  if(!DEBUGMODE){ 
		   switch($res["result"]){ 
		    case -4: 
		     $memo = "未知異常"; 
		     break; 
		    case -3: 
		     $memo = "查詢失敗"; 
		     break; 
		    case -2: 
		     $memo = "無法連接端口"; 
		     break; 
		    case -1: 
		     $memo = "狀態未知"; 
		     break; 
		    case 0: 
		     $memo = "OK"; 
		     break; 
		    case 1: 
		     $memo = "同步失敗"; 
		     if($res["Slave_IO_Running"] <> "Yes"){ 
		      $memo .= $res["Last_IO_Error"] . "(" .  $res 
		 
		["Last_IO_Errno"] . ")"; 
		     } 
		     if($res["Slave_SQL_Running"] <> "Yes"){ 
		      $memo .= $res["Last_SQL_Error"] . "(" .  $res 
		 
		["Last_SQL_Errno"] . ")"; 
		     } 
		     break; 
		    case 2: 
		     $memo = "數據庫未設置同步"; 
		     break; 
		   } 
		   echo " 
		 
		n"; 
		  }else{ 
		   echo " 
		 
		n"; 
		  } 
		 } 
		 echo " 
		<table border=""> 
		<tbody> 
		<tr> 
		<td>instance</td> 
		<td>result</td> 
		<td>Slave_IO_Running</td> 
		<td>Slave_SQL_Running</td> 
		<td>Master_Host</td> 
		<td>Master_Port</td> 
		<td>Replicate_Do_DB</td> 
		<td>memo</td> 
		</tr> 
		<tr> 
		<td>instance</td> 
		<td>result</td> 
		<td>Slave_IO_Running</td> 
		<td>Slave_SQL_Running</td> 
		<td>Master_Host</td> 
		<td>Master_Port</td> 
		<td>Replicate_Do_DB</td> 
		<td>Slave_IO_State</td> 
		<td>Last_IO_Errno</td> 
		<td>Last_IO_Error</td> 
		<td>Last_SQL_Errno</td> 
		<td>Last_SQL_Error</td> 
		</tr> 
		<tr> 
		<td>{$host}</td> 
		<td>{$res['result']}</td> 
		<td>{$res['Slave_IO_Running']}</td> 
		<td>{$res['Slave_SQL_Running']}</td> 
		<td>{$res['Master_Host']}</td> 
		<td>{$res['Master_Port']}</td> 
		<td>{$res['Replicate_Do_DB']}</td> 
		<td>{$memo}</td> 
		</tr> 
		<tr> 
		<td>{$host}</td> 
		<td>{$res['result']}</td> 
		<td>{$res['Slave_IO_Running']}</td> 
		<td>{$res['Slave_SQL_Running']}</td> 
		<td>{$res['Master_Host']}</td> 
		<td>{$res['Master_Port']}</td> 
		<td>{$res['Replicate_Do_DB']}</td> 
		<td>{$res['Slave_IO_State']}</td> 
		<td>{$res['Last_IO_Errno']}</td> 
		<td>{$res['Last_IO_Error']}</td> 
		<td>{$res['Last_SQL_Errno']}</td> 
		<td>{$res['Last_SQL_Error']}</td> 
		</tr> 
		</tbody> 
		</table> 
		n"; 
		 echo << 
		 
		END; 
		}else{ 
		 die("no mysql instances defined."); 
		}

check_status_api.php：

復制代碼代碼如下:

		/* 
		 * 檢查mysql服務器的同步狀態 
		 */ 
		function check_mysql_replication_status($host, $username, $password) 
		{ 
		 //默認狀態未知 
		 $r = array( 
		  "result" => -1 
		  ); 
		 try{ 
		  $dbh = @mysql_connect($host, $username, $password); 
		  if(!$dbh){ 
		   //無法連接 
		   $r["result"] = -2; 
		   return($r); 
		  } 
		  $query = "SHOW SLAVE STATUS"; 
		  $res = @mysql_query($query, $dbh); 
		  $err = @mysql_error(); 
		  if($err){ 
		   //無法連接 
		   $r["result"] = -3; 
		   return($r); 
		  } 
		  $row = mysql_fetch_array($res); 
		  $r = $row; 
		  if(($r["Slave_IO_Running"] == "Yes") && ($r["Slave_SQL_Running"] == "Yes")) 
		  { 
		   $r["result"] = 0; 
		  }else{ 
		   if(!emptyempty($row)){ 
		    $r["result"] = 1; 
		   }else{ 
		    $r["result"] = 2; 
		   } 
		  } 
		 }catch(Exception $e){ 
		  $r["result"] = -4; 
		 } 
		 return($r); 
		}