******************************内存监控*********************************
*******************时间： 2019-08-24 16:50:20 ******************
总内存： 65958920
空闲内存： 37296548
给文件的缓冲大小: 310288
高速缓冲存储器使用的大小: 8991808
被高速缓冲存储用的交换空间大小: 7160
给文件的缓冲大小: 310288
交换内存利用率： 4.35586183351
内存利用率： 29.35 %
****************************内核线程、虚拟内存、磁盘、陷阱和 CPU 活动的统计信息监控****************************
*******************时间： 2019-08-24 16:50:22 ******************
等待运行进程的数量: 1
处于不间断状态的进程: 0
使用虚拟内存(swap)的总量: 365396
空闲的内存总量: 37298132
用作缓冲的内存总量: 310288
用作缓存的内存总量: 8991816
交换出内存总量 : 0
交换入内存总量 : 0
从一个块设备接收: 0
发送到块设备: 0
每秒的中断数: 9751
每秒的上下文切换数: 7514
用户空间上进程运行的时间百分比: 3
内核空间上进程运行的时间百分比: 2
闲置时间百分比: 95
等待IO的时间百分比: 0
从虚拟机偷取的时间百分比: 0
***************************************cpu监控***************************************
*******************时间： 2019-08-24 16:50:23 ******************
CPU数目： 24
************************负载均衡监控****************************
*******************时间： 2019-08-24 16:50:24 ******************
系统5分钟前的平均负载： 0.16
系统10分钟前的平均负载： 0.08
系统15分钟前的平均负载： 0.06
分子是正在运行的进程数,分母为总进程数： 3/968
最近运行的进程id： 25222
************************磁盘空间监控****************************
*******************时间： 2019-08-24 16:50:24 ******************
文件系统： /dev/sda3 容量： 1.8T 已用： 133G 可用： 1.7T 已用%挂载点： 8%
文件系统： tmpfs 容量： 32G 已用： 12K 可用： 32G 已用%挂载点： 1%
文件系统： /dev/sda1 容量： 477M 已用： 57M 可用： 395M 已用%挂载点： 13%
文件系统： /dev/sdb1 容量： 440G 已用： 71M 可用： 436G 已用%挂载点： 1%
******************************端口监控*********************************
*******************时间： 2019-08-24 16:50:25 ******************
1 1
#################################################

!/usr/bin/env python

-- coding: utf-8 --

@Time : 2017/11/27 15:59

@Desc : 服务器监控代码

@File : monitorserver.py

@Software: PyCharm

import commands
import re

import time
import threading

"""

内存监控

"""
def mem_info(ip):
cm="ssh -q root@{0} 'cat /proc/meminfo'".format(ip)
status,output = commands.getstatusoutput(cm)
mem = output
mem_values = re.findall("(\d+)\ kB", mem)
MemTotal = mem_values[0]
MemFree = mem_values[1]
Buffers = mem_values[2]
Cached = mem_values[3]
SwapCached=mem_values[4]
SwapTotal = mem_values[13]
SwapFree = mem_values[14]
print '******************************内存监控*********************************'
print "*******************时间：", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************"
print "总内存：",MemTotal
print "空闲内存：", MemFree
print "给文件的缓冲大小:",Buffers
print "高速缓冲存储器使用的大小:", Cached
print "被高速缓冲存储用的交换空间大小:", SwapCached
print "给文件的缓冲大小:", Buffers
if int(SwapTotal) == 0:
print "交换内存总共为：0"
else:
Rate_Swap = 100 - 100int(SwapFree)/float(SwapTotal)
print "交换内存利用率：", Rate_Swap
Free_Mem = int(MemFree) + int(Buffers) + int(Cached)
Used_Mem = int(MemTotal) - Free_Mem
Rate_Mem = 100Used_Mem/float(MemTotal)
print "内存利用率：", str("%.2f" % Rate_Mem), "%"

"""
内核线程、虚拟内存、磁盘、陷阱和 CPU 活动的统计信息
"""
def vm_stat_info(ip):
cm="ssh -q root@{0} 'vmstat 1 2 | tail -n 1'".format(ip)
status,output = commands.getstatusoutput(cm)
vmstat_info = output.strip().split()
processes_waiting = vmstat_info[7]
processes_sleep = vmstat_info[8]
swpd = vmstat_info[9]
free = vmstat_info[10]
buff = vmstat_info[11]
cache = vmstat_info[12]
si = vmstat_info[13]
so = vmstat_info[14]
io_bi = vmstat_info[15]
io_bo = vmstat_info[16]
system_interrupt = vmstat_info[17]
system_context_switch = vmstat_info[18]
cpu_user = vmstat_info[19]
cpu_sys = vmstat_info[20]
cpu_idle = vmstat_info[21]
cpu_wait = vmstat_info[22]
st=vmstat_info[23]
print '****************************内核线程、虚拟内存、磁盘、陷阱和 CPU 活动的统计信息监控****************************'
print "*******************时间：", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************"
print "等待运行进程的数量:", processes_waiting
print "处于不间断状态的进程:", processes_sleep
print "使用虚拟内存(swap)的总量:", swpd
print "空闲的内存总量:", free
print "用作缓冲的内存总量:", buff
print "用作缓存的内存总量:", cache
print "交换出内存总量 :", si
print "交换入内存总量 :", so
print "从一个块设备接收:", io_bi
print "发送到块设备:", io_bo
print "每秒的中断数:", system_interrupt
print "每秒的上下文切换数:", system_context_switch
print "用户空间上进程运行的时间百分比:", cpu_user
print "内核空间上进程运行的时间百分比:", cpu_sys
print "闲置时间百分比:", cpu_idle
print "等待IO的时间百分比:", cpu_wait
print "从虚拟机偷取的时间百分比:", st

'''
cpu监控
'''
def cpu_info(ip):
cm="ssh -q root@{0} 'cat /proc/cpuinfo'".format(ip)
status,output = commands.getstatusoutput(cm)
cpuinfo = output
cpu_num = re.findall('processor.*?(\d+)', cpuinfo)[-1]
cpu_num = str(int(cpu_num) + 1)
print '***************************************cpu监控***************************************'
print "*******************时间：", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************"
print u"CPU数目：", cpu_num

"""
负载均衡
"""
def load_stat(ip):
cm="ssh -q root@{0} 'cat /proc/loadavg'".format(ip)
status,output = commands.getstatusoutput(cm)
loadavgs = output.strip().split()
print '************************负载均衡监控****************************'
print "*******************时间：",time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()),"******************"
print "系统5分钟前的平均负载：", loadavgs[7]
print "系统10分钟前的平均负载：", loadavgs[8]
print "系统15分钟前的平均负载：", loadavgs[9]
print "分子是正在运行的进程数,分母为总进程数：",loadavgs[10]
print "最近运行的进程id：", loadavgs[11]

"""
磁盘空间监控
"""
def disk_stat(ip):
cm="ssh -q root@{0} 'df -h'".format(ip)
status,output = commands.getstatusoutput(cm)
disk = output
disklist = disk.strip().split('\n')
disklists=[]
for disk in disklist[3:]:
disklists.append(disk.strip().split())
print '************************磁盘空间监控****************************'
print "*******************时间：", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************"
for i in disklists:
print "\t文件系统：", i[0],
print "\t容量：", i[1],
print "\t已用：", i[2],
print "\t可用：", i[3],
print "\t已用%挂载点：", i[4]

"""
端口监控
一般是远程服务器用户名用户
"""
def getComStr(ip,port,pro):
cm="ssh -q root@{0} 'netstat -tpln|grep 60001|wc -l;ps aux|grep -v grep|grep java|wc -l'".format(ip)
status,output = commands.getstatusoutput(cm)
com = output.split("\n")
print '******************************端口监控*********************************'
print "*******************时间：", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************"
print com[2],com[3]

"""
第一种执行
"""
def alltask():
try:
threads = []
t1 = threading.Thread(target=mem_info)
threads.append(t1)
t2 = threading.Thread(target=vm_stat_info)
threads.append(t2)
t3 = threading.Thread(target=cpu_info)
threads.append(t3)
t4 = threading.Thread(target=load_stat)
threads.append(t4)
t5 = threading.Thread(target=ionetwork)
threads.append(t5)
t6 = threading.Thread(target=disk_stat)
threads.append(t6)
t7 = threading.Thread(target=getComStr)
threads.append(t7)
for n in range(len(threads)):
threads[n].start()
except Exception, e:
print str(e)

"""
第二种执行
"""
if name == 'main':
try:
mem_info('113.219.129.32')
vm_stat_info('113.219.129.32')
cpu_info('113.219.129.32')
load_stat('113.219.129.32')
disk_stat('113.219.129.32')
getComStr('113.219.129.32',"","")
except Exception, e:
print str(e)