线上用lvs做负载均衡，最近发现几台机器有些时间段经常被踢出，写了个python脚本用来做简单的端口和ping检测
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
import os,socket,time
import threading
def check_port(host,port):
s = None
for res in socket.getaddrinfo(host, port, socket.AF_UNSPEC,socket.SOCK_STREAM):
af, socktype, proto, canonname, sa = res
try:
s = socket.socket(af, socktype, proto)
except socket.error, msg:
s = None
print str(msg)
continue
try:
s.settimeout(2)
s.connect(sa)
except socket.error, msg:
print str(msg)
s.close()
s = None
continue
break
if s is None:
return 0
s.close()
return 1
def ping_server(ip):
cmd = """
ping -c 50 %s|egrep "received|mdev" | sed "s,^,%s : ," >> %s/%s_ping.log
""" % (ip,time.ctime(time.time()),logs_dir,ip)
print cmd
os.popen(cmd)
def check_network():
check_ip_list = get_hosts()
thread_pool = []
for i in range(len(check_ip_list)):
ip = check_ip_list[i]
print ip
th = threading.Thread(target=ping_server,args=(ip,) ) ;
thread_pool.append(th)
for i in range(len(check_ip_list)):
thread_pool[i].deamon = True
thread_pool[i].start()
def get_hosts():
hosts_list = []
f = open('/etc/hosts')
for i in f.readlines():
if 'hadoop-' in i:
host = i.strip().split()[0]
hosts_list.append(host)
else:
continue
f.close()
print hosts_list
return hosts_list
def get_hosts_ports():
hosts_ports_list = []
f = open('/etc/hosts')
for i in f.readlines():
if 'hadoop-' in i:
host = i.strip().split()[0]
hosts_ports_list.append(host+':10050')
else:
continue
f.close()
print hosts_ports_list
return hosts_ports_list
def check_server_port():
port_file = open("%s/check_port.log"%(logs_dir),'a')
dt = time.ctime(time.time())
checklist = get_hosts_ports()
for checkitem in checklist:
host, port = checkitem.split(':')
if check_port(host, port):
port_file.write('%s connect to %s success\n'%(dt,checkitem))
else:
port_file.write('%s connect to %s fail'%(dt,checkitem))
def check_health():
while True:
check_server_port()
check_network()
time.sleep(60)
if __name__ == '__main__':
logs_dir = '/apps/logs/ping'
if not (os.path.exists(logs_dir)):
os.makedirs(logs_dir)
check_health()
|
本文转自菜菜光 51CTO博客，原文链接：http://blog.51cto.com/caiguangguang/1352307，如需转载请自行联系原作者