php在linux下检测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

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.");

　　}

/*

　　* 检查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);

　　}

//GRANT REPLICATION CLIENT ON *.* TO '用户名'@'监控主机ip' IDENTIFIED BY '密码';  $mysql_instances =

　　array();

　　$mysql_instances[] = "远程ip:端口"; 

　　function get_instances()

　　{

　　global $mysql_instances;

　　return $mysql_instances;

　　}