程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 網頁編程 >> PHP編程 >> 關於PHP編程 >> php在linux下檢測mysql同步狀態的方法

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

編輯:關於PHP編程

     這篇文章主要介紹了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);
    }
    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

    希望本文所述對大家的php程序設計有所幫助。

    1. 上一頁:
    2. 下一頁:
    Copyright © 程式師世界 All Rights Reserved