请教一个用perl写监控另外一台WEB服务器是否运行正常的脚本

lxc521

对perl不熟悉， 却要在一台只能运行perl脚本的机器上去监控另外一台WEB服务器是否运行正常。
哪位可以帮帮说说。

Perl_Er

1. #!/usr/bin/perl
   
2. use IO::Socket;
   
3. use IO::File;
   
4. use MIME::Base64;
   
5. 
   
6. ##############################
   
7. # Constant define (configure)
   
8. ##############################
   
9. # mail config
   
10. use constant MAIL_ADDR       => ('to'=>'webmaster@example.com', 'from'=>'webmaster@example.com');
    
11. use constant SMTP_INFO       => ('host'=>'smtp.example.com', 'user'=>'webmaster', 'password'=>'pass',
    
12.                                  'debug'=>1, 'bufsize'=>1024);
    
13. # common config
    
14. use constant MD5SUM_FILE        => '/tmp/__monitor_md5sum_hash';
    
15. use constant APACHE_LOG_PATH => '/usr/local/apache2/logs/access';
    
16. # apache
    
17. use constant APACHE_PORT        => 80;
    
18. use constant APACHE_SERVERS     => ('web1.example.com', 'web2.example.com');
    
19. # mysql
    
20. use constant MYSQL_PORT       => 3306;
    
21. use constant MYSQL_SERVERS    => ('db1.example.com', 'db2.example.com');
    
22. # memcache
    
23. use constant MEMCACHE_PORT    => 11211;
    
24. use constant MEMCACHE_SERVERS => ('cache1.example.com', 'cache2.example.com');
    
25. # search
    
26. use constant SEARCH_PORT        => 8000;
    
27. use constant SEARCH_SERVERS     => ('search1.example.com');
    
28. 
    
29. 
    
30. ##############################
    
31. # Server port is alive check
    
32. ##############################
    
33. sub check_server_alive {
    
34. my($server, $port) = @_;
    
35. 
    
36. $sock = IO::Socket::INET->new(PeerAddr=>$server, PeerPort=>$port, Proto=>'tcp', Timeout=>3);
    
37. if (!$sock){
    
38.        return 0;
    
39. }
    
40. $sock->close();
    
41. return 1;
    
42. }
    
43. 
    
44. ##############################
    
45. # Check process is exist
    
46. ##############################
    
47. sub check_process_exist {
    
48. my $proc_name = shift;
    
49. $line = `/bin/ps auxw | /bin/grep $proc_name | /bin/grep -v grep | /usr/bin/wc -l`;
    
50. $line =~ s/^s+|s+$//g;
    
51. if ($line == 0){
    
52.        return 0;
    
53. }
    
54. return 1;
    
55. }
    
56. 
    
57. ##############################
    
58. # Check file md5 fingerprint
    
59. ##############################
    
60. sub check_file_md5sum {
    
61. my $io, $line;
    
62. $filename = shift;
    
63. @arr = split(/s/, `/usr/bin/md5sum $filename`);
    
64. $filehash = shift(@arr);
    
65. $io = IO::File->new();
    
66. $io->open(MD5SUM_FILE, O_RDWR);
    
67. if (!($line = $io->getLine())){
    
68.        $io->syswrite($filehash);
    
69.        $io->close;
    
70.        return true;
    
71. }
    
72. if ($line != $filehash){
    
73.        $io->truncate(0);
    
74.        $io->syswrite($filehash);
    
75.        $io->close;
    
76.        return true;
    
77. }
    
78. return true;
    
79. }
    
80. 
    
81. ##############################
    
82. # SMTP execute command
    
83. ##############################
    
84. sub smtp_cmd {
    
85. my ($sock, $cmd, $blocking) = @_;
    
86. my %smtpinfo = SMTP_INFO;
    
87. my $buf, $bufsize = $smtpinfo{'bufsize'}, $debug=$smtpinfo{'debug'};
    
88. 
    
89. $sock->syswrite($cmd);
    
90. if ($debug == 1){
    
91.        print ">>> $cmd ";
    
92. }
    
93. if ($blocking == 1){
    
94.        $sock->sysread($buf, $bufsize);
    
95.        if ($debug){
    
96.          print "<<< $buf";
    
97.        }
    
98. }
    
99. }
    
100. 
     
101. ##############################
     
102. # Send notice mail
     
103. ##############################
     
104. sub send_mail {
     
105. my ($subject, $content) = @_;
     
106. my $sock;
     
107. my %mailaddr = MAIL_ADDR;
     
108. my %smtpinfo = SMTP_INFO;
     
109. my $debug = $smtpinfo{'debug'};
     
110. 
     
111. # Count date time
     
112. ($sec, $min, $hour, $day, $mon, $year, $wday, $yday, $isdst) = localtime(time());
     
113. $datetime = sprintf("%s-%s-%s %s:%s:%s", "20".substr($year,1,2), length($mon)==1?"0$mon":$mon, length($day)==1?"0$day":$day, length($hour)==1?"0$hour":$hour, length($min)==1?"0$min":$min, length($sec)==1?"0$sec":$sec);
     
114. $subject .= "[$datetime]";
     
115. 
     
116. # Connect to SMTP server
     
117. $sock = IO::Socket::INET->new(PeerAddr=>$smtpinfo{'host'}, PeerPort=>25, Proto=>'tcp', Timeout=>10);
     
118. $sock->blocking(1);
     
119. 
     
120. # Send smtp command
     
121. if ($debug == 1){
     
122.        print "<<< ". $sock->sysread($buf, $smtpinfo{'bufsize'});
     
123. }
     
124. smtp_cmd($sock, "HELO locahost ", 1);
     
125. smtp_cmd($sock, "AUTH LOGIN ", 1);
     
126. smtp_cmd($sock, encode_base64($smtpinfo{'user'}), 1);
     
127. smtp_cmd($sock, encode_base64($smtpinfo{'password'}), 1);
     
128. smtp_cmd($sock, "MAIL FROM: <". $mailaddr{'from'} ."> ", 1);
     
129. smtp_cmd($sock, "RCPT TO: <". $mailaddr{'to'} ."> ", 1);
     
130. smtp_cmd($sock, "DATA ", 1);
     
131. smtp_cmd($sock, "From: ". $smtpinfo{'from'} ." ", 0);
     
132. smtp_cmd($sock, "To: ". $smtpinfo{'to'} ." ", 0);
     
133. smtp_cmd($sock, "Subject: $subject ", 0);
     
134. smtp_cmd($sock, "$content ", 0);
     
135. smtp_cmd($sock, " . ", 1);
     
136. smtp_cmd($sock, "QUIT ", 0);
     
137. $sock->close();
     
138. 
     
139. return 1;
     
140. }
     
141. 
     
142. ##############################
     
143. # Check server alive main
     
144. ##############################
     
145. sub monitor_main {
     
146. # check apache
     
147. foreach $item (APACHE_SERVERS) {
     
148.        if (!check_server_alive($item, APACHE_PORT)) {
     
149.          send_mail("$item apache server is down", "$item apache server is down. please timely restoration");
     
150.        }
     
151. }
     
152. # check mysql
     
153. foreach $item (MYSQL_SERVERS) {
     
154.        if (!check_server_alive($item, MYSQL_PORT)) {
     
155.          send_mail("$item mysql server is down", "$item mysql server is down. please timely restoration");
     
156.        }
     
157. }
     
158. # check memcache
     
159. foreach $item (MEMCACHE_SERVERS) {
     
160.        if (!check_server_alive($item, MEMCACHE_PORT)) {
     
161.          send_mail("$item memcache server is down", "$item memcache server is down. please timely restoration");
     
162.        }
     
163. }
     
164. # check search
     
165. foreach $item (SEARCH_SERVERS) {
     
166.        if (!check_server_alive($item, SEARCH_PORT)) {
     
167.          send_mail("$item search server is down", "$item search server is down. please timely restoration");
     
168.        }
     
169. }
     
170. }
     
171. 
     
172. 
     
173. ##############################
     
174. # Main running
     
175. ##############################
     
176. 
     
177. monitor_main();

复制代码

[ 本帖最后由 Perl_Er 于 2009-8-21 12:27 编辑 ]

iakuf

版权声明：转载时请以超链接形式标明文章原始出处和作者信息及本声明
[url]http://imaginaryboy.blogbus.com/logs/44036265.html[/url]

#!/usr/bin/perl
use strict;
use HTTP::SimpleLinkChecker;

my $url;
my $code;
print "Please input the target url(start with \"http\"):\n";
chomp($url = <STDIN>);
$code = HTTP::SimpleLinkChecker::check_link($url);
print "The $url response code is $code\n";



#Below is the meaning of the response code of http

(100)          HTTP_CONTINUE
(101)          HTTP_SWITCHING_PROTOCOLS
(102)          HTTP_PROCESSING
(200)          HTTP_OK
(201)          HTTP_CREATED
(202)          HTTP_ACCEPTED
(203)          HTTP_NON_AUTHORITATIVE_INFORMATION
(204)          HTTP_NO_CONTENT
(205)          HTTP_RESET_CONTENT
(206)          HTTP_PARTIAL_CONTENT
(207)          HTTP_MULTI_STATUS
(300)          HTTP_MULTIPLE_CHOICES
(301)          HTTP_MOVED_PERMANENTLY
(302)          HTTP_FOUND
(303)          HTTP_SEE_OTHER
(304)          HTTP_NOT_MODIFIED
(305)          HTTP_USE_PROXY
(307)          HTTP_TEMPORARY_REDIRECT
(400)          HTTP_BAD_REQUEST
(401)          HTTP_UNAUTHORIZED
(402)          HTTP_PAYMENT_REQUIRED
(403)          HTTP_FORBIDDEN
(404)          HTTP_NOT_FOUND
(405)          HTTP_METHOD_NOT_ALLOWED
(406)          HTTP_NOT_ACCEPTABLE
(407)          HTTP_PROXY_AUTHENTICATION_REQUIRED
(408)          HTTP_REQUEST_TIMEOUT
(409)          HTTP_CONFLICT
(410)          HTTP_GONE
(411)          HTTP_LENGTH_REQUIRED
(412)          HTTP_PRECONDITION_FAILED
(413)          HTTP_REQUEST_ENTITY_TOO_LARGE
(414)          HTTP_REQUEST_URI_TOO_LARGE
(415)          HTTP_UNSUPPORTED_MEDIA_TYPE
(416)          HTTP_REQUEST_RANGE_NOT_SATISFIABLE
(417)          HTTP_EXPECTATION_FAILED
(422)          HTTP_UNPROCESSABLE_ENTITY
(423)          HTTP_LOCKED
(424)          HTTP_FAILED_DEPENDENCY
(425)          HTTP_NO_CODE
(426)          HTTP_UPGRADE_REQUIRED
(449)          HTTP_RETRY_WITH
(500)          HTTP_INTERNAL_SERVER_ERROR
(501)          HTTP_NOT_IMPLEMENTED
(502)          HTTP_BAD_GATEWAY
(503)          HTTP_SERVICE_UNAVAILABLE
(504)          HTTP_GATEWAY_TIMEOUT
(505)          HTTP_HTTP_VERSION_NOT_SUPPORTED
(506)          HTTP_VARIANT_ALSO_NEGOTIATES
(507)          HTTP_INSUFFICIENT_STORAGE
(509)          HTTP_BANDWIDTH_LIMIT_EXCEEDED
(510)          HTTP_NOT_EXTENDED

[[i] 本帖最后由 iakuf 于 2009-8-21 12:27 编辑 [/i]]

lxc521

use HTTP::SimpleLinkChecker;

请问这个是PERL自带的吗
我运行后报错

Can't locate HTTP/SimpleLinkChecker.pm in @INC

flw

原帖由 lxc521 于 2009-8-21 12:56 发表
use HTTP::SimpleLinkChecker;

请问这个是PERL自带的吗
我运行后报错

Can't locate HTTP/SimpleLinkChecker.pm in @INC

你就用 LWP::UserAgent 就可以了。

gaochong

可以通过检查title值来判断web服务器是否运行正常，特别是tomcat频繁异常的现象可以有效处理。
当title值检测不到时，可以重启tomcat来解决。还请各位指出不足。谢谢！
代码如下：

#!/usr/bin/perl -w use strict; use Net::HTTP; my $s = Net::HTTP->new(Host =>"IP") || die $@; $s->write_request(GET => "/", 'User-Agent' => "Mozilla/5.0"); my($code, $mess, %h) = $s->read_response_headers; while (1) {         my $buf;         my $n = $s->read_entity_body($buf, 4096);         die "read failed: $!" unless defined $n;         last unless $n; #       print $buf;         if ($buf =~ /somthing(.*?)/) {                 print "Alive\n";                 last;         } else {                 print "Dead\n";         } }