rabbitmq消息件在idc机房监控中的应用

1199阅读 0评论2010-08-26 bailiangcn
分类:LINUX



2009-11-24 21:38:26
 标签:rabbitmq消息件在idc机房监控中的应用   [推送到技术圈]

原文见
  rabbitmq-server是一个消息中间件,由erlang语言写就。erlang号称是能达到六西格玛标准的电信级编程语言,时下很流行撒。IDC服务器监控似乎跟这个东西风马牛不向及啊,呵呵,其实监控本质就是消息的传送。这么就说得通了。
   进程自动监控的想法是很早以前就有了,当时的情况是这样的:客服人员经常晚上半夜三更给我打电话,说系统慢啊,不可访问啊,其实我上去一看,90%的问 题出在程序员写的Java程序上,现象非常讨厌,进程是存在的,日志照常甩出,端口依然存活,就是反映慢到死,这个问题到现在也还是无解啊!没办法,只能 够重启应用程序,一重启就好。这么做的次数多了,自己也烦不胜烦。于是就想出个偷懒的主意,能否让客服自己来重启进程呢?当然可以了,给客服个WEB页 面,上面有重启的连接,点击即可。问题也来了,页面么,就用php可以搞定,但是涉及到要重启进程,php显然是不适合做这件事的,理由如下:php运行 的时候是继承了apache设置的权限,缺省应该是nobody,如果用suexec或者其他身份运行,明显就是为php提升了权限,这样很可能会带来大 问题,不可取。比较可行的方法是:php发送消息到消息服务器,然后各服务器跟消息服务器通讯,取出各自的消息,再由本地进程控制重启。这样漏洞比较少。 也没有权限的危险。
  具体实现的架构如下:
  php提供展示页面,调用stomp协议发送消息;rabbitmq做消息中间服务器,存储并转发消息;服务器端用Python来接收stomp消息,并调用shell命令执行重启等命令。结构图如下:

  所用到的软件:
  
  (不要下default.zip那个包,不能用)
  
mkdir -p /data/mq
cd /data/mq
wget
tar jxvf Python-2.6.2.tar.bz2
cd Python-2.6.2
./configure --prefix=/data/python262;make;make install
cd ..;rm -rf Python-2.6.2
wget
tar zxvf otp_src_R13B.tar.gz
cd otp_src_R13B
./configure --prefix=/data/erlang;make;make install
cd ..;rm -rf otp_src_R13B
export PATH=/data/python262/bin:/data/erlang/bin:$PATH
wget
tar zxvf rabbitmq-server-1.5.5.tar.gz
ln -s rabbitmq-server-1.5.5 rabbitmq-server
cd rabbitmq-server
make all
cd ..;rm -rf rabbitmq-server-1.5.5.tar.gz
wget
tar jxvf rabbitmq-stomp-5ee5e2c0b64a.tar.bz2
cd rabbitmq-stomp-5ee5e2c0b64a
make
cd ..;rm -rf rabbitmq-stomp-5ee5e2c0b64a.tar.bz2
vi rabbitmq-server/scripts/rabbitmq-server
SERVER_START_ARGS=
改成:
SERVER_START_ARGS='
-pa /data/mq/rabbitmq-stomp-5ee5e2c0b64a/ebin
-rabbit
stomp_listeners [{"0.0.0.0",61613}]
extra_startup_steps [{"STOMP-listeners",rabbit_stomp,kickstart,[]}]'

./rabbitmq-server/scripts/rabbitmq-server -detached
#缺省的用户是guest,密码也是guest,这太不安全了,改之:
./rabbitmq-server/scripts/rabbitmqctl delete_user guest
./rabbitmq-server/scripts/rabbitmqctl add_user songxr Loveyou
./rabbitmq-server/scripts/rabbitmqctl map_user_vhost songxr /

  这样rabbitmq+stomp就配置好了。
  搜遍了网上的php stomp客户端,有好几个,都是一堆文件,其实我们只用到了一个最简单的功能,就是发送,干脆自己写了个函数:

function sendmsg($host,$port,$login,$passcode,$timeout,$msg,$queue) {
$msg_connect = "CONNECTnlogin:$loginnpasscode:$passcodennx00";
$msg_send = "SENDndestination:$queuenreceipt:oknn$msgx00";
$msg_disconnect = "DISCONNECTnnx00";
if(!($r = fsockopen($host,$port))) return false;
stream_set_timeout($r, $timeout);
if(!fwrite($r, $msg_connect.$msg_send.$msg_disconnect)){
$md = stream_get_meta_data($r);
if($md['timed_out']) return false;
}
if(!('CONNECTED' == fread($r,9))){
$md = stream_get_meta_data($r);
if($md['timed_out']) return false;
}
fread($r,44);
$md = stream_get_meta_data($r);
if($md['timed_out']) return false;
if(!("RECEIPTnreceipt-id:ok" == fread($r,21))){
$md = stream_get_meta_data($r);
if($md['timed_out']) return false;
}
if (!(strstr(fgets($r,100),'access_refused'))) {
fclose($r);
return true;
}else{
fclose($r);
return false;
}
}

  发送端程序下载:
  各个客户端的Python端采用Jason R Briggs的stomp类,加上daemon类和实际执行的server.py和shell脚本,一共四个文件:
  接收端程序下载:
  用这个方法就可以远程管理机房的服务器进程了,当然最后别忘了为php程序加上口令密码验证......
Popularity: 95% []
上一篇:Shell脚本调试技术
下一篇:[RabbitMQ+Python入门经典] 兔子和兔子窝