JMX连接Mbean获取Tomcat信息(jconsole远程查看Mbean)

最近用JAVA写了个获取tomcat信息资源的代码，随便保存一下。

大致的步骤全在这了，可以获取到任何想要的指标：

 

首先可以用JDK提供的工具jconsole来供我们查看，这个在服务端配置下catalina.bat文件，加入以下内容：

 

  
 
 

set JAVA_OPTS= -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=7999 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false  
  
 
 

端口7999可以*更改，前提是没被系统占用。

这时就可以在jconsole里面输入远程路径和用户名密码登入了。输入命令：

  
 
 

service:jmx:rmi:///jndi/rmi://192.168.133.184:7999/jmxrmi 
  
 
 

 

下面为获取数据代码：

  
 
 

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; 
   
  
  
 
   
  
  
public class test { 
   
  
  
    /** 
   
  
  
     * @param args 
   
  
  
     */ 
   
  
  
    public static void main(String[] args) { 
   
  
  
        try { 
   
  
  
 
   
  
  
            String jmxURL = "service:jmx:rmi:///jndi/rmi://192.168.1.126:10090/jmxrmi";//tomcat jmx url   
   
  
  
            JMXServiceURL serviceURL = new JMXServiceURL(jmxURL); 
   
  
  
 
   
  
  
            Map map = new HashMap(); 
   
  
  
            String[] credentials = new String[] { "monitorRole", "QED" }; 
   
  
  
            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-8089"); 
   
  
  
            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("连续工作时间:" + test.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(); 
   
  
  
    } 
   
  
  
 
   
  
  
}  
  
 
 

 

 

  
 
 

import java.util.Iterator;    
   
  
  
import java.util.Set;    
   
  
  
import javax.management.Attribute;    
   
  
  
import javax.management.MBeanInfo;    
   
  
  
import javax.management.MBeanServerConnection;    
   
  
  
import javax.management.MBeanServerInvocationHandler;    
   
  
  
import javax.management.ObjectInstance;    
   
  
  
import javax.management.ObjectName;    
   
  
  
import javax.management.remote.JMXConnector;    
   
  
  
import javax.management.remote.JMXConnectorFactory;    
   
  
  
import javax.management.remote.JMXServiceURL;    
   
  
  
public class Client {    
   
  
  
    public static void main(String[] args) throws Exception {       
   
  
  
        JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:9999/server");       
   
  
  
        JMXConnector jmxc = JMXConnectorFactory.connect(url, null);        
   
  
  
        MBeanServerConnection mbsc = jmxc.getMBeanServerConnection();      
   
  
  
        ObjectName mbeanName = new ObjectName("chengang:name=HelloWorld");    
   
  
  
        // 把所有Domain都打印出来    
   
  
  
        System.out.println("Domains:---------------");       
   
  
  
        String domains[] = mbsc.getDomains();        
   
  
  
        for (int i = 0; i < domains.length; i++) {        
   
  
  
            System.out.println("\tDomain[" + i + "] = " + domains[i]);     
   
  
  
        }    
   
  
  
        // MBean的总数    
   
  
  
        System.out.println("MBean count = " + mbsc.getMBeanCount());    
   
  
  
        // 对name属性的操作（属性名的第一个字母要大写）    
   
  
  
        mbsc.setAttribute(mbeanName, new Attribute("Name", "PANDA"));// 设值    
   
  
  
        System.out.println("Name = " + mbsc.getAttribute(mbeanName, "Name"));// 取值    
   
  
  
        // 得到proxy代理后直接调用的方式    
   
  
  
        HelloMBean proxy = (HelloMBean) MBeanServerInvocationHandler.newProxyInstance(mbsc, mbeanName, HelloMBean.class, false);         
   
  
  
        proxy.printHello();         
   
  
  
        proxy.printHello("Raymend");    
   
  
  
        // 远程调用的方式    
   
  
  
        mbsc.invoke(mbeanName, "printHello", null, null);          
   
  
  
        mbsc.invoke(mbeanName, "printHello", new Object[] { "熊猫烧香" }, new String[] { String.class.getName() });    
   
  
  
        // 得mbean的信息    
   
  
  
        MBeanInfo info = mbsc.getMBeanInfo(mbeanName);          
   
  
  
        System.out.println("Hello Class: " + info.getClassName());       
   
  
  
        System.out.println("Hello Attriber：" + info.getAttributes()[0].getName());      
   
  
  
        System.out.println("Hello Operation：" + info.getOperations()[0].getName());    
   
  
  
        // 得到所有的MBean的ObjectName    
   
  
  
        System.out.println("all ObjectName：---------------");         
   
  
  
        Set set = mbsc.queryMBeans(null, null);        
   
  
  
        for (Iterator it = set.iterator(); it.hasNext();) {         
   
  
  
            ObjectInstance oi = (ObjectInstance) it.next();         
   
  
  
            System.out.println("\t" + oi.getObjectName());         
   
  
  
            }
   
  
  
        // 关闭MBeanServer连接    
   
  
  
        jmxc.close();      
   
  
  
}    
   
  
  
}