#!/usr/bin/python

import os
import sys
import commands


tomcats=[]
tomcat_pid={}

jstat='/data/java/jdk1.7/bin/jstat'
jstack='/data/java/jdk1.7/bin/jstack'
zbx_sender='/usr/local/zabbix/bin/zabbix_sender'
zbx_tmp_file='/tmp/zbx_tmp_file'
HostName='192.168.154.6'
jstat_dict = {
        "S0":"Young.Space0.Percent",
        "S1":"Young.Space1.Percent",
        "E":"Eden.Space.Percent",
        "O":"Old.Space.Percent",
        "P":"Perm.Space.Percent",
        "FGC":"Old.Gc.Count",
        "FGCT":"Old.Gc.Time",
        "YGC":"Young.Gc.Count",
        "YGCT":"Young.Gc.Time",
        "GCT":"Total.Gc.Time",
        "PGCMN":"Perm.Gc.Min",
        "PGCMX":"Perm.Gc.Max",
        "PGC":"Perm.Gc.New",
        "PC":"Perm.Gc.Cur",
        "Tomcat.Thread":"Tomcat.Thread"
    }
#1,get tomcat name & pid
def discoveryNamePid():
        getTomcatName_cmd="ps -ef | grep '.service'| grep -v grep | awk -F '/' '{print $(NF-1)}'| awk -F '.' '{print $1}'"
        ResName=os.popen(getTomcatName_cmd).readlines()
        for name in ResName:
                tomcats.append(name.strip('\n'))
        for i in tomcats:
                cmd="ps -ef | grep %s | grep -v grep | awk '{print $2}'" % i
                pid=os.popen(cmd).read()
                tomcat_pid[i]=pid.strip('\n')
        return tomcat_pid

#2,get tomcat status

def getStatus(cmd,args,pid):
        value=commands.getoutput('%s -%s %s' % (cmd,args,pid)).strip().split('\n')
        kv=[]
        vv=[]
        for i in value[0].split(' '):
                if i != '':
                        kv.append(i)
        for i in value[1].split(' '):
                if i != '':
                        vv.append(i)
        data=dict(zip(kv,vv))
        return data

def getThread(pid):
        value=commands.getoutput('%s %s | grep http | wc -l' % (jstack,pid))
        data={"Tomcat.Thread":value}
        return data

def fileEmpty():
        with open(zbx_tmp_file,'w') as f:
                f.truncate()

def getJVMStatus(TomcatName,pid):
        gcutil_data=getStatus(jstat,"gcutil",pid)
        gccapacity_data=getStatus(jstat,"gccapacity",pid)
        thread_data=getThread(pid)
        data_dict=dict(gcutil_data.items()+gccapacity_data.items()+thread_data.items())
        for jmxkey in data_dict.keys():
                if jmxkey in jstat_dict.keys():
                        cur_key=jstat_dict[jmxkey]
                        zbx_data="%s jstat[%s,%s] %s" %(HostName,TomcatName,cur_key,data_dict[jmxkey])
                        with open(zbx_tmp_file,'a') as file_obj:
                                file_obj.write(zbx_data + '\n')
def sendData():
        send_cmd="%s -z 192.168.153.12 -s '192.168.154.6' -i %s" % (zbx_sender,zbx_tmp_file)
        os.system(send_cmd)

if len(zbx_tmp_file) !=0:
        fileEmpty()
for TomcatName in discoveryNamePid().keys():
        pid=tomcat_pid[TomcatName]
        getJVMStatus(TomcatName,pid)
sendData()

代码大体思路就是:

　　.1、定义需要搜集项的数据名称

　　.2、收集系统中运行的tomcat实例，取名称和PID

　　.3、根据PID调用jstat命令生成jvm性能数据

　　.4、将生成的数据存放在临时文件中

　　.5、调用zabbix_sender命令，将临时文件发送给zabbix服务端

生成的临时文件内数据格式如下(节选):

192.168.154.6 jstat[content,Young.Space1.Percent] 34.38
192.168.154.6 jstat[content,Young.Space0.Percent] 0.00
192.168.154.6 jstat[content,Young.Gc.Time] 6.342
192.168.154.6 jstat[content,Old.Gc.Time] 0.221
192.168.154.6 jstat[content,Perm.Gc.New] 75264.0
192.168.154.6 jstat[content,Total.Gc.Time] 6.564
192.168.154.6 jstat[product,Young.Space1.Percent] 0.00
192.168.154.6 jstat[product,Young.Space0.Percent] 87.50
192.168.154.6 jstat[product,Young.Gc.Count] 3990
192.168.154.6 jstat[product,Young.Gc.Time] 22.918
192.168.154.6 jstat[product,Old.Gc.Time] 1.597
192.168.154.6 jstat[product,Perm.Gc.New] 131072.0
192.168.154.6 jstat[product,Total.Gc.Time] 24.516
192.168.154.6 jstat[order,Young.Space1.Percent] 0.00
192.168.154.6 jstat[order,Young.Space0.Percent] 3.23
192.168.154.6 jstat[order,Eden.Space.Percent] 48.40
192.168.154.6 jstat[order,Old.Space.Percent] 59.65
192.168.154.6 jstat[order,Perm.Space.Percent] 83.46

其中，第一列是主机名(注意：和zabbix配置文件中的Hostname相同)，第二列是key(创建监控项时的key)，第三列就是值了。

2、客户端采集到数据后，zabbix服务端需要接收这些数据。但是数据放在哪呢？监控项！需要在zabbix监控页面中创建监控项，来接收存放客户端发来的数据。

首先创建一个模版，方便套用:

配置－模版－创建模版，输入模版的名字和应用的主机即可。

创建监控项:

配置－模版－监控项－创建监控项,如下图:

注意其中类型、键值和信息类型几项。这里信息类型选择浮点行，是因为采集到的数据有小数。

按照以上创建所有需要监控的项。

2、添加计划任务，每分钟采集一次数据发送给zabbix服务端：

*/1 * * * * /scripts/zabbix_tomcat/jvmstatus.py

3、如果一切正常，在zabbix监控页面‘最新数据’中即可收到发来的数据，并且可自动生成图形，如下图:

点击右侧的图形，就可以看到趋势图了：

最后生成模版：

zbx_export_templates.xml

优质内容筛选与推荐>>
1、QString QByteArray char* 相互转换（转）
2、Redis的Linux系统优化
3、NET学习路线 收藏
4、Oracle: 通过命令行下载安装文件
5、RabbitMQ消息队列（九）：Publisher的消息确认机制

赞赏

长按二维码向我转账

受苹果公司新规定影响，微信 iOS 版的赞赏功能被关闭，可通过二维码转账支持公众号。

阅读

好看

已推荐到看一看

你的朋友可以在“发现”-“看一看”看到你认为好看的文章。

取消 推荐

我知道了

已取消，“好看”想法已同步删除

知道了