JMX详解编程语言

一、为什么使用JMX，解决那些问题

举一个应用实例：在一个系统中常常会有一些配置信息，比如服务的IP地址，端口号什么的，那么如何来写这些代码呢？

写死在程序里，到要改变时就去改程序，然后再编译发布；
把这些信息写在一个配置文件里（JAVA一般都是*.properties文件），到要改变时只要改配置文件，但还是重新启动系统，以便读取配置文件里的新值；
写一个段代码，把配置值缓存起来，系统在读值的时候，先看看配置文件有没有更动。如有更改则重读一遍，否则从缓存里读取值
用JMX！把配置属性集中在一个类，然后写一个叫MBean的东东，再配置一下就轻松搞定了。而且JMX自动提供了一个WEB页面来给你来改变这些配置信息。

JMX是一种JAVA的正式规范，它主要目的是让程序有被管理的功能。试想你开发了一个软件（如WEB网站），它是在24小时不间断运行的，那么你可能会想要“监控”这个软件的运行情况，比如收到了多少数据，有多少人登录等等。或者你又想“配置”这个软件，比如现在访问人数比较多，你想把数据连接池设置得大一些。

二、JMX使用

JMX 全称是 Java Management Extensions, Java5.0开始引入，提供连接、监控和管理远程JVM的方式。

MBean

一个MBean是一个被管理的Java对象，有点类似于JavaBean，一个设备、一个应用或者任何资源都可以被表示为MBean，MBean会暴露一个接口对外，这个接口可以读取或者写入一些对象中的属性，通常一个MBean需要定义一个接口，以MBean结尾，例如：DataSourceMBean, 格式为XXXMBean，这个是规范，必须得遵守。

MBeanServer

MBean的容器，提供远程访问、命名空间管理和安全服务。

JMX 指定了在 MBeanServer 和 JMX 客户之间通信所使用的协议，协议可以在各种传输机制上运行。可以使用针对本地连接的内置传输，及通过 RMI、socket 或 SSL 的远程传输（可以通过 JMX Connector API 创建新的传输）。

示例：

public interface HelloMBean { 
    public String getName(); 
    public void setName(String name); 
    public void printHello(); 
    public void printHello(String whoName); 
}

public class Hello implements HelloMBean { 
 
    private String name = "loull"; 
 
    @Override 
    public String getName() { 
        return name; 
    } 
 
    @Override 
    public void setName(String name) { 
        this.name = name; 
    } 
 
    @Override 
    public void printHello() { 
        System.out.println("Hello, " + name); 
    } 
 
    @Override 
    public void printHello(String whoName) { 
        System.out.println("Hello, " + whoName); 
    } 
}

本地agent

import javax.management.InstanceAlreadyExistsException; 
import javax.management.MBeanRegistrationException; 
import javax.management.MBeanServer; 
import javax.management.MalformedObjectNameException; 
import javax.management.NotCompliantMBeanException; 
import javax.management.ObjectName; 
 
public class HelloAgent { 
 
    private static final String MBEAN_NAME = "com.jmxtest:type=HelloMBean"; 
 
    public static void main(String[] args) throws MalformedObjectNameException, 
                                           InstanceAlreadyExistsException, 
                                           MBeanRegistrationException, NotCompliantMBeanException, 
                                           InterruptedException { 
        //        MBeanServer server = MBeanServerFactory.createMBeanServer(); 
        MBeanServer server = ManagementFactory.getPlatformMBeanServer(); 
 
        ObjectName helloName = new ObjectName(MBEAN_NAME); 
 
        Hello hello = new Hello(); 
 
        server.registerMBean(hello, helloName); 
 
        System.out.println("start..."); 
        Thread.currentThread().join(); 
    } 
 
}

这样就可以了。然后我们就可以使用jconsole进行监控和管理了。需要注意的是这里需要使用getPlatformMBeanServer才能够被jconsole监控到，创建新的MBeanServer是监控不到的。原因是JConsole通过Attach API动态attach到已经运行的目标JVM，然后命令其动态的load了JDK_HOME/lib/management-agent.jar这个agent包，这个agent包的agentmain方法会对PlatformMBeanServer进行RMI注册和监听。

html agent

import javax.management.InstanceAlreadyExistsException; 
import javax.management.MBeanRegistrationException; 
import javax.management.MBeanServer; 
import javax.management.MBeanServerFactory; 
import javax.management.MalformedObjectNameException; 
import javax.management.NotCompliantMBeanException; 
import javax.management.ObjectName; 
 
import com.sun.jdmk.comm.HtmlAdaptorServer; 
 
public class HelloHtmlAgent { 
 
    private static final String MBEAN_NAME = "com.alipay.jmxtest:type=HelloMBean"; 
 
    public static void main(String[] args) throws MalformedObjectNameException, 
                                           InstanceAlreadyExistsException, 
                                           MBeanRegistrationException, NotCompliantMBeanException { 
        //创建MBeanServer   
        MBeanServer server = MBeanServerFactory.createMBeanServer(); 
        //创建MBean ObjectName   
        ObjectName helloName = new ObjectName("MBeanTest:name=HelloWorld"); 
        //注册MBean   
        Hello hello = new Hello(); 
        server.registerMBean(hello, helloName); 
 
        ObjectName adapterName = new ObjectName("HelloAgent:name=htmladapter,port=8082"); 
        HtmlAdaptorServer adapter = new HtmlAdaptorServer(); 
        server.registerMBean(adapter, adapterName); 
 
        adapter.start(); 
        System.out.println("start....."); 
    } 
 
}

运行HelloAgent，然后打开网页：http://localhost:8082/。单击“name=HelloWorld”链接进入。

说明：

先创建了一个MBeanServer，用来做MBean的容器将Hello这个类注入到MBeanServer中，注入需要创建一个ObjectName类创建一个AdaptorServer，这个类将决定MBean的管理界面，这里用最普通的Html型界面。AdaptorServer其实也是一个MBean。 “MBeanTest:name=HelloWorld”的名字是有一定规则的，格式：“域名:name=MBean名称”，域名和MBean名称都可以任意取。

在实际系统中我们可以把name变成决定数库链接池的变量，这样我就可以对系统的运行参数进行实现的监控和配置（管理）。

三、JMX 提供的虚拟机检测API

检测虚拟机当前的状态总是 Java 开放人员所关心的，从 Java SE 5 之后，java.lang.management包里面包括了许多MXBean的接口类和 LockInfo、MemoryUsage、MonitorInfo 和 ThreadInfo 等类。从名字可以看出，该包提供了虚拟机内存分配、垃圾收集（GC）情况、操作系统层、线程调度和共享锁，甚至编译情况的检测机制。

JVM在启动的时候会默认将这些内建的MBean注册到PlatfromMBeanServer。这样一来，Java 的开发人员就可以很简单地为自己做一些轻量级的系统检测，来确定当前程序的各种状态，以便随时调整。jconsole的MBeans中就能够看到这些系统MXBeans。

具体有如下这些MXBean Package java.lang.management:

ClassLoadingMXBean: ClassLoadMXBean 包括一些类的装载信息，比如有多少类已经装载/卸载（unloaded），虚拟机类装载的 verbose 选项（即命令行中的 Java – verbose:class 选项）是否打开，还可以帮助用户打开 / 关闭该选项。
CompilationMXBean: CompilationMXBean 帮助用户了解当前的编译器和编译情况，该 mxbean 提供的信息不多。
GarbageCollectorMXBean: 相对于开放人员对 GC 的关注程度来说，该 mxbean 提供的信息十分有限，仅仅提供了 GC 的次数和 GC 花费总时间的近似值。但是这个包中还提供了三个的内存管理检测类：MemoryManagerMXBean，MemoryMXBean 和 MemoryPoolMXBean。
MemoryManagerMXBean: 这个类相对简单，提供了内存管理类和内存池（memory pool）的名字信息。
MemoryMXBean: 这个类提供了整个虚拟机中内存的使用情况，包括 Java 堆（heap）和非 Java 堆所占用的内存，提供当前等待 finalize 的对象数量，它甚至可以做 gc（实际上是调用 System.gc）。
MemoryPoolMXBean: 该信息提供了大量的信息。在 JVM 中，可能有几个内存池，因此有对应的内存池信息，因此，在工厂类中，getMemoryPoolMXBean() 得到是一个 MemoryPoolMXBean 的 list。每一个 MemoryPoolMXBean 都包含了该内存池的详细信息，如是否可用、当前已使用内存 / 最大使用内存值、以及设置最大内存值等等。
OperatingSystemMXBean: 该类提供的是操作系统的简单信息，如构架名称、当前 CPU 数、最近系统负载等。
RuntimeMXBean: 运行时信息包括当前虚拟机的名称、提供商、版本号，以及 classpath、bootclasspath 和系统参数等等。
ThreadMXBean: 在 Java 这个多线程的系统中，对线程的监控是相当重要的。ThreadMXBean 就是起到这个作用。ThreadMXBean 可以提供的信息包括各个线程的各种状态，CPU 占用情况，以及整个系统中的线程状况。从 ThreadMXBean 可以得到某一个线程的 ThreadInfo 对象。这个对象中则包含了这个线程的所有信息。

如果我们要想获得这些信息，只需要简单的通过java.lang.management.ManagementFactory这个工厂类（单例）来获得相应的的MXBean，然后就可以通过这个MBean获取其监控的数据了:

RuntimeMXBean mxbean = ManagementFactory.getRuntimeMXBean(); 
// Get the standard attribute "VmVendor" 
String vendor = mxbean.getVmVendor(); 
 
// Or by calling the getPlatformMXBean or getPlatformMXBeans method: 
RuntimeMXBean mxbean = ManagementFactory.getPlatformMXBean(RuntimeMXBean.class); 
// Get the standard attribute "VmVendor" 
String vendor = mxbean.getVmVendor();

或者Construct an MXBean proxy instance that forwards the method calls to a given MBeanServer:

MBeanServerConnection mbs; 
 
// Connect to a running JVM (or itself) and get MBeanServerConnection 
// that has the JVM MBeans registered in it 
... 
 
// Get a MBean proxy for RuntimeMXBean interface 
RuntimeMXBean proxy = ManagementFactory.getPlatformMXBean(mbs, RuntimeMXBean.class); 
// Get standard attribute "VmVendor" 
String vendor = proxy.getVmVendor();

Tomcat有个Tomcat Manager工程就是通过JMXProxyServlet暴露JMX监控项的。它的实现其实非常简单，就是根据用户指定的MBeanName和Attribute，在platformMBeanServer中访问该MBean的属性而已。

核心代码就是这几个函数：

public void getAttribute(PrintWriter writer, String onameStr, String att) { 
    try { 
        ObjectName oname = new ObjectName(onameStr); 
        Object value = mBeanServer.getAttribute(oname, att); 
        writer.println("OK - Attribute get '" + onameStr + "' - " + att 
                + "= " + escape(value.toString())); 
    } catch (Exception ex) { 
        writer.println("Error - " + ex.toString()); 
    } 
} 
 
 
public void setAttribute( PrintWriter writer, 
                          String onameStr, String att, String val ) 
{ 
    try { 
        ObjectName oname=new ObjectName( onameStr ); 
        String type=registry.getType(oname, att); 
        Object valueObj=registry.convertValue(type, val ); 
        mBeanServer.setAttribute( oname, new Attribute(att, valueObj)); 
        writer.println("OK - Attribute set"); 
    } catch( Exception ex ) { 
        writer.println("Error - " + ex.toString()); 
    } 
} 
 
public void listBeans( PrintWriter writer, String qry ) 
{ 
 
    Set names = null; 
    try { 
        names=mBeanServer.queryNames(new ObjectName(qry), null); 
        writer.println("OK - Number of results: " + names.size()); 
        writer.println(); 
    } catch (Exception e) { 
        writer.println("Error - " + e.toString()); 
        return; 
    } 
 
    Iterator it=names.iterator(); 
    while( it.hasNext()) { 
        ObjectName oname=(ObjectName)it.next(); 
        writer.println( "Name: " + oname.toString()); 
 
        try { 
            MBeanInfo minfo=mBeanServer.getMBeanInfo(oname); 
            // can't be null - I thinl 
            String code=minfo.getClassName(); 
            if ("org.apache.commons.modeler.BaseModelMBean".equals(code)) { 
                code=(String)mBeanServer.getAttribute(oname, "modelerType"); 
            } 
            writer.println("modelerType: " + code); 
 
            MBeanAttributeInfo attrs[]=minfo.getAttributes(); 
            Object value=null; 
 
            for( int i=0; i< attrs.length; i++ ) { 
                if( ! attrs[i].isReadable() ) continue; 
                if( ! isSupported( attrs[i].getType() )) continue; 
                String attName=attrs[i].getName(); 
                if( attName.indexOf( "=") >=0 || 
                        attName.indexOf( ":") >=0 || 
                        attName.indexOf( " ") >=0 ) { 
                    continue; 
                } 
 
                try { 
                    value=mBeanServer.getAttribute(oname, attName); 
                } catch( Throwable t) { 
                    log("Error getting attribute " + oname + 
                        " " + attName + " " + t.toString()); 
                    continue; 
                } 
                if( value==null ) continue; 
                if( "modelerType".equals( attName)) continue; 
                String valueString=value.toString(); 
                writer.println( attName + ": " + escape(valueString)); 
            } 
        } catch (Exception e) { 
            // Ignore 
        } 
        writer.println(); 
    } 
}

JMXProxyServlet的作用是将MBean数据以HTTP方式而不是RMI方式暴露出去。对于页面展示也好，或者穿越防火墙来说都是比较友好的。

原创文章，作者：Maggie-Hunter，如若转载，请注明出处：https://blog.ytso.com/17027.html

JMX详解编程语言

一、为什么使用JMX，解决那些问题

二、JMX使用

三、JMX 提供的虚拟机检测API

相关推荐

发表回复