PHP+shell脚本操作Memcached和Apache Status的实例分享


            memcached 进程启动及监控

1.memcached_inc.sh

设置路径，端口等讯息。





#!/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 启动，停止，重启。





#!/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

监控memcached 进程，如进程失效则自动启动。





#!/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 #启动memcached 

./gm_memcached.sh stop #停止memcached 

./gm_memcached.sh restart #重启memcached 









shell 记录apache status并自动更新到数据库

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 





在终端设置crontab执行





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







2. 将apache status log 写入数据库

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

 

 

// 讀取monitor log，記錄入db，查看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){ 

 

  // 讀取log數據 

  if(file_exists($logfile)){ 

   $logdata = file_get_contents($logfile); 

   // 清空monitor.log 

   file_put_contents($logfile, '', true); 

  }else{ 

   return false; 

  } 

 

  // 正則分析數據 [#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); // 按換行分隔 

 

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