检测mysql同步状态实现代码

检测mysql同步状态实现代码(php/linux)

#!/bin/sh



#checkMySQL_SlaveStatus

#crontabtime00:10

MYSQL_USER="root"

MYSQL_PWD="123456"

MYSQL_SLAVE_LOG="/tmp/check_mysql_slave.log"

EMAIL="[e-mail]"



MYSQL_PORT=`netstat-na|grep"LISTEN"|grep"3306"|awk-F[:""]+''{print$5}''`

MYSQL_IP=`ifconfigeth0|grep"inetaddr"|awk-F[:""]+''{print$4}''`

MYSQL_SLAVE_STATUS=$(/usr/local/webserver/mysql/bin/mysql-uroot-psylc23hua-S/tmp/mysql.sock-e



"showslavestatusG"|grep-i"running")

IO_ENV=`echo$MYSQL_SLAVE_STATUS|grepIO|awk''{print$2}''`

SQL_ENV=`echo$MYSQL_SLAVE_STATUS|grepSQL|awk''{print$2}''`

NOW=$(date-dtoday+''%Y-%m-%d%H:%M:%S'')



if["$MYSQL_PORT"="3306"];then

echo"mysqlisrunning!"

else

mail-s"warn!server:$MYSQL_IPmysqlisdown""$EMAIL"

fi



if["$IO_ENV"="Yes"-a"$SQL_ENV"="Yes"];then

echo"Slaveisrunning!"

else

echo"[$NOW]Slaveisnotrunning!">>"$MYSQL_SLAVE_LOG"

cat"$MYSQL_SLAVE_LOG"|mail-s"WARN!${MySQL_IP}_replicate_error""$EMAIL"

fi



exit0



php实例代码



代码如下 复制代码

check_rep.php



if(empty($_REQUEST["key"]))die('':)missingkey'');

if($_REQUEST["key"]!=''xupeng'')die('':)errorkey'');



include("mysql_instance.php");

include("check_status_api.php");



define("USERNAME","用户名");

define("PASSWORD","密码");

define("DEBUGMODE",false);



$instances=get_instances();



if($instances){

echo<<







END;

echo"

n";

if(!DEBUGMODE){

echo"



n";

}else{

echo"



n";

}

foreach($instancesas$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;

case0:

$memo="OK";

break;

case1:

$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;

case2:

$memo="数据库未设置同步";

break;

}

echo"



n";

}else{

echo"



n";

}

}

echo"