PHP+shell½Å±¾²Ù×÷MemcachedºÍApache StatusµÄÊµÀý·ÖÏí

5年以前 | 阅读数：366 次 | 编程语言：PHP

memcached ½ø³ÌÆo¶¯¼°¼a¿Ø
1.memcached_inc.sh
ÉeÖÃÂ*¾¶£¬¶Ë¿ÚµÈÑ¶Ï¢¡£


    #!/bin/sh 

    #config include 

    HOST=$(hostname) 
    SITE="mysite" 
    PORT=11211 

    MEMCACHED_PID_FILE="/tmp/memcached.pid" 
    MEMCACHED_DAEMON_PID_FILE="/tmp/memcached_daemon.pid" 

    MEMCACHED="memcached -d -m 64 -p $PORT -u memcache -l 127.0.0.1 -P $MEMCACHED_PID_FILE" 
    MEMCACHED_DAEMON_FILE="memcached_daemon.sh" 

    ERROR_LOG_FILE="${ROOT}/memcached_${SITE}_${HOST}_${PORT}.log"

2.gm_memcached.sh
¿ØÖÆmemcached Æo¶¯£¬Í£Ö¹£¬ÖØÆo¡£


    #!/bin/sh 

    #memcached start and stop 
    #$1 action 

    ROOT=$(cd "$(dirname "$0")"; pwd) 

    . ${ROOT}/memcached_inc.sh 


    start() { 

     if [ -f "$MEMCACHED_PID_FILE" ] && [ -s "$MEMCACHED_PID_FILE" ]; then 
      printf "memcached already running\n" 
     else 
      printf "starting memcached\n" 
      $MEMCACHED 

      sleep 2 

      PID=$(cat $MEMCACHED_PID_FILE) 
      printf "memcached is started PID:$PID\n" 

      printf "starting memcached daemon\n" 
      ${ROOT}/${MEMCACHED_DAEMON_FILE} & 
      DAEMON_PID=$! 
      echo ${DAEMON_PID} > ${MEMCACHED_DAEMON_PID_FILE} 
      printf "memcached daemon is started PID:${DAEMON_PID}\n" 
     fi 

    } 


    stop() { 

     if [ -f "$MEMCACHED_DAEMON_PID_FILE" ] && [ -s "$MEMCACHED_DAEMON_PID_FILE" ]; then 
      DAEMON_PID=$(cat $MEMCACHED_DAEMON_PID_FILE) 
      rm -f ${MEMCACHED_DAEMON_PID_FILE} 
      if [ ! -z ${DAEMON_PID} ]; then 
       kill -9 ${DAEMON_PID} 
      fi 
      printf "memcached daemon is stopped\n" 
     else 
      printf "no memcached daemon running\n" 
     fi 

     sleep 1 

     if [ -f "$MEMCACHED_PID_FILE" ] && [ -s "$MEMCACHED_PID_FILE" ]; then 
      PID=$(cat $MEMCACHED_PID_FILE) 
      rm -f ${MEMCACHED_PID_FILE} 
      if [ ! -z ${PID} ]; then 
       kill -9 ${PID} 
      fi 
      printf "memcached is stopped\n" 
     else 
      printf "no memcached running\n" 
     fi 

    } 


    case "$1" in 

     start) 
      start 
      ;; 

     stop) 
      stop 
      ;; 

     restart) 
      stop 
      sleep 3 
      start 
      ;; 

     *) 
      printf "Usage:$0 {start|stop|restart}\n" 
      exit 1 

    esac 

    exit 0

3.memcached_daemon.sh
¼a¿Ømemcached ½ø³Ì£¬Èç½ø³ÌÊ§Ð§Ôo×Ô¶¯Æo¶¯¡£


    #!/bin/sh 

    #memcached daemon 

    ROOT=$(cd "$(dirname "$0")"; pwd) 

    . ${ROOT}/memcached_inc.sh 


    while : 
    do 
     if [ -f "$MEMCACHED_PID_FILE" ] && [ -s "$MEMCACHED_PID_FILE" ]; then 
      PID=$(cat $MEMCACHED_PID_FILE) 
     else 
      PID="" 
     fi 

     if [ -z "$PID" ] || [ -z $(ps aux|awk '{print $2}' | grep "^$PID$") ]; then 
      $MEMCACHED 
      sleep 1 
      printf "[$(date +%Y-%m-%d' '%H:%M:%S)] ${SITE} ${HOST} memcached ${PORT} is restarted\n" >> $ERROR_LOG_FILE 
      echo "Subject: ${SITE} ${HOST} memcached ${PORT} is restarted $(date +%Y-%m-%d' '%H:%M:%S)" | sendmail me@gmail.com 
     fi 

     sleep 5 

    done 

    exit 0

Ê¹ÓÃ½¨£º


    ./gm_memcached.sh start #Æo¶¯memcached 
    ./gm_memcached.sh stop #Í£Ö¹memcached 
    ./gm_memcached.sh restart #ÖØÆomemcached

shell ¼ÇÂ¼apache status²¢×Ô¶¯¸uÐÂµ½Êý¾Ý¿a
1. »ñÈ¡apache status
monitor_log.sh


    #!/bin/bash 

    #Á¬½ÓÊý 
    site_connects=$(netstat -ant | grep $ip:80 | wc -l) 
    #µ±Ç°Á¬½ÓÊý 
    site_cur_connects=$(netstat -ant | grep $ip:80 | grep EST | wc -l) 

    #apache 
    apache_speed=$(netstat -n | awk '/^tcp/ {++S[$NF]} END {for(a in S) print a, S[a]}') 

    printf "[#start#]\n$(date '+%Y-%m-%d %H:%M:%S')\n" 
    printf "connects:${site_connects}\n" 
    printf "cur connects:${site_cur_connects}\n" 
    printf "apache_speed:\n${apache_speed}\n[#end#]\n\n" 

    exit 0

ÔÚÖÕ¶ËÉeÖÃcrontabÖ´ÐÐ


    * * * * * /home/fdipzone/monitor_log.sh >> /home/fdipzone/monitor.log

2. ½«apache status log Ð´ÈeÊý¾Ý¿a
save_monitor_log.php


    <?php 

    $logfile = dirname(__FILE__).'/monitor.log'; 

    $dbconfig = array( 
       'host' => '192.168.1.100', 
       'username' => 'username', 
       'password' => 'password', 
       'dbname' => 'mydb', 
       'tabname' => 'monitor_log' 
    ); 

    $obj = new SaveMonitorLog($dbconfig, 'myweb'); 
    $obj->load($logfile); 


    // ×xÈ¡monitor log£¬Ó›a›Èedb£¬²e¿´db 
    class SaveMonitorLog{ // class start 

     private $_apache_state = array('TIME_WAIT', 'CLOSE_WAIT', 'SYN_SENT', 'SYN_RECV', 'FIN_WAIT1', 'FIN_WAIT2', 'ESTABLISHED', 'LAST_ACK', 'CLOSING'); 
     private $_dbconfig = array(); 
     private $_site = null; 


     /** init */ 
     public function __construct($dbconfig=array(), $site='web'){ 
      if(!isset($dbconfig['host']) || !isset($dbconfig['username']) || !isset($dbconfig['password']) || !isset($dbconfig['dbname']) || !isset($dbconfig['tabname'])){ 
       $this->debug('dbconfig error'); 
      } 
      $this->_dbconfig = $dbconfig; 
      $this->_site = $site; 
      $this->connectdb(); 
     } 


     /** load data 
     * @param String $logfile logÎÄ¼þ 
     * @return boolean 
     */ 
     public function load($logfile){ 

      // ×xÈ¡log"µ"þ 
      if(file_exists($logfile)){ 
       $logdata = file_get_contents($logfile); 
       // Ça¿Õmonitor.log 
       file_put_contents($logfile, '', true); 
      }else{ 
       return false; 
      } 

      // Õý„t*ÖÎo"µ"þ [#start#]*[#end#] 
      preg_match_all('/
    #start#
    (.*?)
    #end#
    .*?/si', $logdata, $data); 

      if(isset($data[1]) && count($data[1])>0){ 
       $alldata = $data[1]; 
       foreach($alldata as $val){ 
        $indb = $this->parser($val); 
        $newid = $this->addtodb($indb); 
       } 
      } 

     } 


     /** parser data 
     * @param Array $data 
     * @return Array 
     */ 
     private function parser($data){ 
      $indb = array(); 
      $tmp = explode(chr(10), $data); // °´"QÐÐ*Ö¸o 

      $indb['site'] = $this->_site; 
      $indb['addtime'] = $tmp[1]; 
      $indb['connects'] = array_pop(explode(':',$tmp[2])); 
      $indb['cur_connects'] = array_pop(explode(':',$tmp[3])); 

      for($i=5, $max=count($tmp)-2; $i<$max; $i++){ 
       list($key, $num) = explode(' ', $tmp[$i]); 
       if(in_array($key, $this->_apache_state)){ 
        $indb[$key] = $num; 
       } 
      } 

      return $indb; 
     } 


     /** connect db */ 
     private function connectdb(){ 
      $conn=@mysql_connect($this->_dbconfig['host'], $this->_dbconfig['username'], $this->_dbconfig['password']) or die(mysql_error()); 
      mysql_select_db($this->_dbconfig['dbname'], $conn) or die(mysql_error()); 
     } 


     /** add to db */ 
     private function addtodb($indb){ 
      $insertkey = ''; 
      $insertval = ''; 
      if($indb){ 
       foreach($indb as $key=>$val){ 
        $insertkey .= $insertkey? " ,".$key : $key; 
        $insertval .= $insertval? " ,'".mysql_escape_string(trim($val))."'" : "'".mysql_escape_string(trim($val))."'"; 
       } 
       $sqlstr = "insert into ".$this->_dbconfig['tabname']."($insertkey) values($insertval)"; 
       $query = @mysql_query($sqlstr) or die(mysql_error()); 
       $id = mysql_insert_id(); 
       return $id? $id : false; 
      } 
     } 


     /** debug */ 
     private function debug($msg){ 
      exit($msg."\r\n"); 
     } 


    } // class end 

    ?>

ÔÚÖÕ¶ËcrontabÖ´ÐÐ


    0 0 * * * php /home/fdipzone/save_monitor_log.php

table monitor_log struct


    CREATE TABLE IF NOT EXISTS `monitor_log` ( 
     `id` int(10) unsigned NOT NULL AUTO_INCREMENT, 
     `site` varchar(20) NOT NULL, 
     `connects` int(10) unsigned NOT NULL DEFAULT '0', 
     `cur_connects` int(10) unsigned NOT NULL DEFAULT '0', 
     `TIME_WAIT` int(10) unsigned NOT NULL DEFAULT '0', 
     `CLOSE_WAIT` int(10) unsigned NOT NULL DEFAULT '0', 
     `SYN_SENT` int(10) unsigned NOT NULL DEFAULT '0', 
     `SYN_RECV` int(10) unsigned NOT NULL DEFAULT '0', 
     `FIN_WAIT1` int(10) unsigned NOT NULL DEFAULT '0', 
     `FIN_WAIT2` int(10) unsigned NOT NULL DEFAULT '0', 
     `ESTABLISHED` int(10) unsigned NOT NULL DEFAULT '0', 
     `LAST_ACK` int(10) unsigned NOT NULL DEFAULT '0', 
     `CLOSING` int(10) unsigned NOT NULL DEFAULT '0', 
     `addtime` datetime NOT NULL, 
     PRIMARY KEY (`id`), 
     KEY `connects` (`connects`), 
     KEY `cur_connects` (`cur_connects`), 
     KEY `TIME_WAIT` (`TIME_WAIT`), 
     KEY `CLOSE_WAIT` (`CLOSE_WAIT`), 
     KEY `SYN_SENT` (`SYN_SENT`), 
     KEY `SYN_RECV` (`SYN_RECV`), 
     KEY `FIN_WAIT1` (`FIN_WAIT1`), 
     KEY `FIN_WAIT2` (`FIN_WAIT2`), 
     KEY `ESTABLISHED` (`ESTABLISHED`), 
     KEY `LAST_ACK` (`LAST_ACK`), 
     KEY `CLOSING` (`CLOSING`), 
     KEY `addtime` (`addtime`) 
    ) ENGINE=MyISAM DEFAULT CHARSET=latin1 ;