使用JMX监控Tomcat示例代码

string jmxurl = "service:jmx:rmi:///jndi/rmi://192.168.10.93:8999/jmxrmi";
jmxserviceurl serviceurl = new jmxserviceurl(jmxurl);

map map = new hashmap();
// 用户名密码，在jmxremote.password文件中查看
string[] credentials = new string[] { "monitorrole", "tomcat" };
map.put("jmx.remote.credentials", credentials);
jmxconnector connector = jmxconnectorfactory.connect(serviceurl, map);
mbeanserverconnection mbsc = connector.getmbeanserverconnection();

// 端口最好是动态取得
objectname threadobjname = new objectname("catalina:type=threadpool,name=http-8080");
mbeaninfo mbinfo = mbsc.getmbeaninfo(threadobjname);

// tomcat的线程数对应的属性值
string attrname = "currentthreadcount";
mbeanattributeinfo[] mbattributes = mbinfo.getattributes();
system.out.println("currentthreadcount:" + mbsc.getattribute(threadobjname, attrname));

import java.lang.management.memoryusage;
import java.text.simpledateformat;
import java.util.date;
import java.util.formatter;
import java.util.hashmap;
import java.util.iterator;
import java.util.map;
import java.util.set;

import javax.management.mbeanattributeinfo;
import javax.management.mbeaninfo;
import javax.management.mbeanserverconnection;
import javax.management.objectinstance;
import javax.management.objectname;
import javax.management.openmbean.compositedatasupport;
import javax.management.remote.jmxconnector;
import javax.management.remote.jmxconnectorfactory;
import javax.management.remote.jmxserviceurl;
/**
 * @author liuyazhuang
 * @date 2016-05-31 
 */
public class jmxtest {

    /**
     * main方法
     * @param args
     */
    public static void main(string[] args) {
        try {

            string jmxurl = "service:jmx:rmi:///jndi/rmi://127.0.0.1:8999/jmxrmi";

            jmxserviceurl serviceurl = new jmxserviceurl(jmxurl);

            map map = new hashmap();
            string[] credentials = new string[] { "monitorrole", "tomcat" };
            map.put("jmx.remote.credentials", credentials);
            jmxconnector connector = jmxconnectorfactory.connect(serviceurl,
                    map);
            mbeanserverconnection mbsc = connector.getmbeanserverconnection();

            // 端口最好是动态取得
            objectname threadobjname = new objectname(
                    "catalina:type=threadpool,name=http-8080");
            mbeaninfo mbinfo = mbsc.getmbeaninfo(threadobjname);

            string attrname = "currentthreadcount";// tomcat的线程数对应的属性值
            mbeanattributeinfo[] mbattributes = mbinfo.getattributes();
            system.out.println("currentthreadcount:"
                    + mbsc.getattribute(threadobjname, attrname));

            // heap
            for (int j = 0; j < mbsc.getdomains().length; j++) {
                system.out.println("###########" + mbsc.getdomains()[j]);
            }
            set mbeanset = mbsc.querymbeans(null, null);
            system.out.println("mbeanset.size() : " + mbeanset.size());
            iterator mbeansetiterator = mbeanset.iterator();
            while (mbeansetiterator.hasnext()) {
                objectinstance objectinstance = (objectinstance) mbeansetiterator
                        .next();
                objectname objectname = objectinstance.getobjectname();
                string canonicalname = objectname.getcanonicalname();
                system.out.println("canonicalname : " + canonicalname);
                if (canonicalname
                        .equals("catalina:host=localhost,type=cluster")) {
                    // get details of cluster mbeans
                    system.out.println("cluster mbeans details:");
                    system.out
                            .println("=========================================");
                    // getmbeansdetails(canonicalname);
                    string canonicalkeyproplist = objectname
                            .getcanonicalkeypropertyliststring();
                }
            }
            // ------------------------- system ----------------------
            objectname runtimeobjname = new objectname("java.lang:type=runtime");
            system.out.println("厂商:"
                    + (string) mbsc.getattribute(runtimeobjname, "vmvendor"));
            system.out.println("程序:"
                    + (string) mbsc.getattribute(runtimeobjname, "vmname"));
            system.out.println("版本:"
                    + (string) mbsc.getattribute(runtimeobjname, "vmversion"));
            date starttime = new date((long) mbsc.getattribute(runtimeobjname,
                    "starttime"));
            simpledateformat df = new simpledateformat("yyyy-mm-dd hh:mm:ss");
            system.out.println("启动时间:" + df.format(starttime));

            long timespan = (long) mbsc.getattribute(runtimeobjname, "uptime");
            system.out.println("连续工作时间:" + jmxtest.formattimespan(timespan));
            // ------------------------ jvm -------------------------
            // 堆使用率
            objectname heapobjname = new objectname("java.lang:type=memory");
            memoryusage heapmemoryusage = memoryusage
                    .from((compositedatasupport) mbsc.getattribute(heapobjname,
                            "heapmemoryusage"));
            long maxmemory = heapmemoryusage.getmax();// 堆最大
            long commitmemory = heapmemoryusage.getcommitted();// 堆当前分配
            long usedmemory = heapmemoryusage.getused();
            system.out.println("heap:" + (double) usedmemory * 100
                    / commitmemory + "%");// 堆使用率

            memoryusage nonheapmemoryusage = memoryusage
                    .from((compositedatasupport) mbsc.getattribute(heapobjname,
                            "nonheapmemoryusage"));
            long noncommitmemory = nonheapmemoryusage.getcommitted();
            long nonusedmemory = heapmemoryusage.getused();
            system.out.println("nonheap:" + (double) nonusedmemory * 100
                    / noncommitmemory + "%");

            objectname permobjname = new objectname(
                    "java.lang:type=memorypool,name=perm gen");
            memoryusage permgenusage = memoryusage
                    .from((compositedatasupport) mbsc.getattribute(permobjname,
                            "usage"));
            long committed = permgenusage.getcommitted();// 持久堆大小
            long used = heapmemoryusage.getused();//
            system.out.println("perm gen:" + (double) used * 100 / committed
                    + "%");// 持久堆使用率

            // -------------------- session ---------------
            objectname managerobjname = new objectname(
                    "catalina:type=manager,*");
            set<objectname> s = mbsc.querynames(managerobjname, null);
            for (objectname obj : s) {
                system.out.println("应用名:" + obj.getkeyproperty("path"));
                objectname objname = new objectname(obj.getcanonicalname());
                system.out.println("最大会话数:"
                        + mbsc.getattribute(objname, "maxactivesessions"));
                system.out.println("会话数:"
                        + mbsc.getattribute(objname, "activesessions"));
                system.out.println("活动会话数:"
                        + mbsc.getattribute(objname, "sessioncounter"));
            }

            // ----------------- thread pool ----------------
            objectname threadpoolobjname = new objectname(
                    "catalina:type=threadpool,*");
            set<objectname> s2 = mbsc.querynames(threadpoolobjname, null);
            for (objectname obj : s2) {
                system.out.println("端口名:" + obj.getkeyproperty("name"));
                objectname objname = new objectname(obj.getcanonicalname());
                system.out.println("最大线程数:"
                        + mbsc.getattribute(objname, "maxthreads"));
                system.out.println("当前线程数:"
                        + mbsc.getattribute(objname, "currentthreadcount"));
                system.out.println("繁忙线程数:"
                        + mbsc.getattribute(objname, "currentthreadsbusy"));
            }

        } catch (exception e) {
            e.printstacktrace();
        }
    }

    public static string formattimespan(long span) {
        long minseconds = span % 1000;

        span = span / 1000;
        long seconds = span % 60;

        span = span / 60;
        long mins = span % 60;

        span = span / 60;
        long hours = span % 24;

        span = span / 24;
        long days = span;
        return (new formatter()).format("%1$d天 %2$02d:%3$02d:%4$02d.%5$03d",
                days, hours, mins, seconds, minseconds).tostring();
    }
}