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 runningn"
else
printf "starting memcachedn"
$memcached
sleep 2
pid=$(cat $memcached_pid_file)
printf "memcached is started pid:$pidn"
printf "starting memcached daemonn"
${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 stoppedn"
else
printf "no memcached daemon runningn"
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 stoppedn"
else
printf "no memcached runningn"
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 restartedn" >> $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#]nn"
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."rn");
}
} // 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 ;
【说明】：本文章由站长整理发布，文章内容不代表本站观点，如文中有侵权行为，请与本站客服联系(QQ:)！