怎么在linux中利用php對mysql同步狀態進行檢測

怎么在linux中利用php對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);
}

mysql_instance.php：

//GRANT REPLICATION CLIENT ON *.* TO '用戶名'@'監控主機ip' IDENTIFIED BY '密碼';  $mysql_instances = 

 
array(); 
$mysql_instances[] = "遠程ip:端口"; 

function get_instances() 
{   
global $mysql_instances;   
return $mysql_instances;  
}
將以上三個PHP文件放在虛擬目錄中,然后通過URL訪問.

訪問方式：http://ip/check_repl.php?key=xupeng

看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業資訊頻道，感謝您對億速云的支持。