Java SE基础巩固（十三）：JMX-秋月博客

1 概述

很多Java相关的基础书籍（包括Java核心技术I、II）都没有涉及到JMX的内容，以至于大多数Java学习者对JMX都不甚了解，但这个东西确实是Java SE的一部分，很多性能监控软件都是基于JMX规范开发的，例如jconsole。

JMX即Java Management Extensions（Java管理扩展），是Java SE的一部分，在Java2的时候加入到Java SE平台中，但Java5才正式发布。JMX提供了一个非常简单的途径去管理应用程序的资源，这里的所说的资源包括内存资源，磁盘资源等，而且因为JMX相关技术是动态的，所以可以在应用程序运行时监控和管理资源。

JMX主要由三大部分构成：

Managed Beans （MBean）代表了某种资源，MBean可以暴露一些接口，用于对MBean所代表的资源进行查看、修改等操作。
JMX agents （JMX代理）管理着一个或多个MBean，并将MBean暴露给客户端。JMX代理的核心组件是MBean Server，用于接受客户端的连接，并对客户端的请求做出响应。
Remoete Connectors 可以简单理解成客户端，最贴近用户，用于接受用户的请求，并将请求发送给JMX代理，然后将JMX代理的响应返回给用户。

举个例子，假设公司现在有一大堆粮食（有很多种类）需要管理，并设计了一套方案用来管理粮食。他们是这样设计的：用一类特殊的对象来这些粮食并且搭建了一个服务器，该服务器管理着这些粮食，而且还开发了一个对用户友好的程序供用户查看，购买各种各样的粮食。在这个例子中，用来表示粮食的对象就是MBean，而服务器就是JMX Aagent，对用户友好的程序其实就是客户端。

例子可能不太恰当，希望各位能理解其中的意思。

下面是JMX的架构图：

接下来我将就围绕这三大部分介绍JMX技术。

2 Managed Beans

Managed Beans简称MBean（后面就统一使用MBean了），一个MBean是一个被管理的Java对象，它和Java Bean有些相似，但不是完全等同，一个标准的MBean包含了以下内容：

一系列可读的或者可写或者既可读又可写的属性。
一系列可被调用的操作（方法）。
描述自己的信息。

JMX规范定义了五种类型的MBean，分别是：

Standard MBeans
Dynamic MBeans
Open MBeans
Model MBeans
MXBeans

本文主要介绍的是Standard MBeans，至于其他类型的MBean，读者如果感兴趣，可以自行查找资料学习。

2.1 标准的MBean

下面是一个“标准”的MBean：

public interface HelloMBean {    void sayHello();    int add(int x, int y);    String getName();    void setCacheSize(int cacheSize);    int getCacheSize();}public class Hello        implements HelloMBean {    private final String name = "Yeonon";    private static final int DEFAULT_CACHE_SIZE = 200;    private int cacheSize = DEFAULT_CACHE_SIZE;    @Override    public void sayHello() {        System.out.println("hello, world!");    }    @Override    public int add(int x, int y) {        return x + y;    }    @Override    public String getName() {        return this.name;    }    @Override    public void setCacheSize(int cacheSize) {        int oldValue = this.cacheSize;        this.cacheSize = cacheSize;        System.out.println("Cache size now is : " + this.cacheSize);    }    @Override    public int getCacheSize() {        return this.cacheSize;    }}

标准的MBean通常都包含了一个以MBean为后缀的接口，以及其实现类，例如这里的HelloMBean以及其实现类Hello，在接口里定义了一系列的抽象方法，这些方法都是后面被暴露的，getter和setter方法的最主要作用是来表示某个字段的可读性和可写性，如果某个字段只包含了getter方法而没有包含setter方法，那么该字段就只是可读的，即无法通过JMX技术来修改该属性。在示例代码中，只定义了个操作，即sayHello和add（getter和setter虽然也是方法，但不把他们认为是操作），客户端可以在远程执行这些操作（调用这些方法），后面会看到一个具体的表现，在这里先不说。

2.2 通知

JMX还支持事件通知。当MBean的属性被修改、删除或者出现问题的时候，可以生成一个通知，并将其发送出去给，如果客户端包含了通知监听器，客户端就可以接受该通知并将其呈现给用户。MBean要支持通知机制，其实现类必须实现NotificationEmitter接口或者继承NotificationBroadcasterSupport类（推荐继承NotificationBroadcasterSupport类，因为该类已经实现了很多有用的方法），对上面的Hello类进行修改，修改之后的代码如下所示：

public class Hello        extends NotificationBroadcasterSupport        implements HelloMBean {    private final String name = "Yeonon";    private final AtomicLong sequenceNumber = new AtomicLong(0);    private static final int DEFAULT_CACHE_SIZE = 200;    private int cacheSize = DEFAULT_CACHE_SIZE;    @Override    public void sayHello() {        System.out.println("hello, world!");    }    @Override    public int add(int x, int y) {        return x + y;    }    @Override    public String getName() {        return this.name;    }    @Override    public void setCacheSize(int cacheSize) {        int oldValue = this.cacheSize;        this.cacheSize = cacheSize;        System.out.println("Cache size now is : " + this.cacheSize);        Notification notification = new AttributeChangeNotification(                this, sequenceNumber.getAndIncrement(), System.currentTimeMillis(),                "Cache Size changed", "CacheSize", "int",                oldValue, this.cacheSize);        sendNotification(notification);    }    @Override    public int getCacheSize() {        return this.cacheSize;    }    @Override    public MBeanNotificationInfo[] getNotificationInfo() {        String[] types = new String[] {                AttributeChangeNotification.ATTRIBUTE_CHANGE        };        String name = AttributeChangeNotification.class.getName();        String description = "An attribute of this MBean has changed";        MBeanNotificationInfo info = new MBeanNotificationInfo(types, name, description);        return new MBeanNotificationInfo[]{info};    }}

最主要的修改是在setCacheSize方法里生成了一个Notification对象，该Notification对象就代表一个通知，Notification有很多已经编写好的实现类，例如这里的AttributeChangeNotification，因为这里要发送通知的原因就是属性被修改，所以就使用了这个实现类，该实现类的构造器签名如下所示：

    public AttributeChangeNotification(Object source, long sequenceNumber, long timeStamp, String msg,                                       String attributeName, String attributeType, Object oldValue, Object newValue) {        super(AttributeChangeNotification.ATTRIBUTE_CHANGE, source, sequenceNumber, timeStamp, msg);        this.attributeName = attributeName;        this.attributeType = attributeType;        this.oldValue = oldValue;        this.newValue = newValue;    }

一共7个参数，这里我就说一个参数（其他参数根据参数名就可以知道是什么东西了），即sequenceNumber，从参数名上可以知道这是一个序列号，每一个通知都有一个序列化，主要是为了防止通知的顺序错误，和网络协议中的那个序列化有异曲同工之妙。例如，如果通知在JMX Agent和远程客户端之间的链路中传输时，发生了顺序错乱，有了序列号，客户端就可以知道应该先处理哪个通知，后处理哪个通知，避免乱序处理。

通知生成完毕之后，就调用sendNotification()方法将通知发送出去。你可能会有疑问？这个通知发送到哪去呢？答案是发送到客户端那里（默认是通过RMI机制发送），如果客户端有实现通知监听器，客户端就可以接受并处理通知了。

下面来看看JMX代理。

3 JMX代理

JMX代理的核心组件就是一个MBean Server，可以将MBean注册到MBean Server中，这就表示MBean由该MBean Server管理了。下面的代码演示了获取MBean Server并且将MBean注册到MBean Server的过程：

public class Main {    public static void main(String[] args) throws MalformedObjectNameException, NotCompliantMBeanException, InstanceAlreadyExistsException, MBeanRegistrationException {        MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();        ObjectName name = new ObjectName("top.yeonon.jmx:type=Hello");        Hello mbean = new Hello();        mBeanServer.registerMBean(mbean, name);        System.out.println("waiting forever....");        while (true) {        }    }}

可以通过ManagementFactory.getPlatformMBeanServer()来获取一个MBean Server实例对象，然后调用mBeanServer.registerMBean方法来把一个MBean注册到MBean Server中，该方法有两个参数，一个参数是MBean实例对象，第二个参数是对应MBean的名字，是ObjectName类型的对象，这里的名字其实并不一定就是top.yeonon.jmx:type=Hello，其格式是XXX:type=YYY，XXX和YYY都可以是任意的字符串，并不一定就是包名和类名，不过最好还是建议使用包名和类名，这样可以避免命名冲突。

启动程序，发现输出waiting forever....，程序没有关闭，其实就是进入无限循环了。这里先不着急，只要程序不包错就行了，下面我会带你来点刺激的！

4 JMX客户端

JMX客户端是最接近用户的，用户也许不知道后面的JMX Agent，MBean，但一定会知道客户端，JMX客户端不会直接和MBean打交道，而是通过JMX Agent来操作其管理的MBean。我们熟知的Jconsole就是一个JMX客户端，下面先介绍一下如何使用Jconsole来操作MBean，随后再介绍如何自定义一个JMX客户端。

4.1 Jconsole

保持JMX Agent处于运行状态，然后打开jconsole软件，如下所示：

选择对应的本地进程（后面会介绍如何使用远程进程来访问），点击之后看到如下界面：

选择MBean选项卡，然后找到top.yeonon.jmx选项，这里会看到有一个名字叫做Hello的MBean（注意到了吗，其实就是我们在JMX Agent里定义的那个ObjectName），现在选择cacheSize那一栏，在值那里修改可以看到当前cacheSize的值是200，修改成150，并点击刷新试试，如下图所示：

这时候回到控制台，发现多了一行输出：

Cache size now is : 150

说明现在cacheSize属性已经被修改成150了！我们成功的在程序运行时修改了属性。其他的操作，例如sayHello()，add等，各位可以自行尝试，在此就不多说了。

除了属性和操作，还可以看到有一个通知，选择通知那一栏，然后在右下边可以看到有一个“订阅”按钮，点击一下，表示想要接受通知，然后再次尝试修改CacheSize，此时会发现多了一行记录，如下所示：

消息的内容就是我们之前定义的，Jconsole只是将其展示出来了，并有做过多的处理。

4.2 自定义客户端

光是用别人开发的客户端没啥意思是不是，没事！JMX也提供了很方便的方式让我们编写自定义的客户端，下面是一个自定义客户端的代码：

package top.yeonon.jmx;import javax.management.*;import javax.management.remote.JMXConnector;import javax.management.remote.JMXConnectorFactory;import javax.management.remote.JMXServiceURL;import java.io.IOException;import java.net.MalformedURLException;import java.util.Set;import static java.lang.Thread.sleep;/** * @Author yeonon * @date 2018/10/16 0016 20:47 **/public class Client {    //构建一个监听器类，该类需要实现NotificationListener接口并实现handleNotification方法    public static class ClientListener implements NotificationListener {        @Override        public void handleNotification(Notification notification, Object handback) {            echo("/nReceived notification:");            echo("/tClassName: " + notification.getClass().getName());            echo("/tSource: " + notification.getSource());            echo("/tType: " + notification.getType());            echo("/tMessage: " + notification.getMessage());            //如果通知类型是AttributeChangeNotification，那么就获取一些和属性有关的信息            if (notification instanceof AttributeChangeNotification) {                AttributeChangeNotification acn = (AttributeChangeNotification) notification;                echo("/tAttributeName: " + acn.getAttributeName());                echo("/tAttributeType: " + acn.getAttributeType());                echo("/tNewValue: " + acn.getNewValue());                echo("/tOldValue: " + acn.getOldValue());            }        }        public static void main(String[] args) throws IOException, MalformedObjectNameException, InstanceNotFoundException, InterruptedException {            echo("/nCreate an RMI connector client and " +                    "connect it to the RMI connector server");            //构造并获取RMI连接            JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://:9999/jmxrmi");            JMXConnector jmxc = JMXConnectorFactory.connect(url, null);            //获取MBeanServer的连接            MBeanServerConnection mbsc = jmxc.getMBeanServerConnection();            waitForEnterPressed();            echo("/nMBeanServer default domain = " + mbsc.getDefaultDomain());            echo("/nMBean count = " + mbsc.getMBeanCount());            echo("/nQuery MBeanServer MBeans:");            Set<ObjectName> objectNames = mbsc.queryNames(null, null);            for (ObjectName objectName : objectNames) {                echo("/tObjectName = " + objectName);            }            waitForEnterPressed();            //创建监听器            NotificationListener listener = new ClientListener();            //管理 Hello MBean            ObjectName mbeanName = new ObjectName("top.yeonon.jmx:type=Hello");            HelloMBean mbeanProxy = JMX.newMBeanProxy(mbsc, mbeanName, HelloMBean.class, true);            echo("/nAdd notification listener...");            mbsc.addNotificationListener(mbeanName, listener, null, null);            echo("/nCacheSize = " + mbeanProxy.getCacheSize());            mbeanProxy.setCacheSize(150);            echo("/nWaiting for notification...");            sleep(2000);            echo("/nCacheSize = " + mbeanProxy.getCacheSize());            echo("/nInvoke sayHello() in Hello MBean...");            mbeanProxy.sayHello();            echo("/nInvoke add(2, 3) in Hello MBean...");            mbeanProxy.add(2,3);            waitForEnterPressed();            //关闭客户端            echo("/nClose the connection to the server");            jmxc.close();            echo("/nBye! Bye!");        }    }    private static void echo(String msg) {        System.out.println(msg);    }    private static void waitForEnterPressed() {        try {            echo("/nPress <Enter> to continue...");            System.in.read();        } catch (IOException e) {            e.printStackTrace();        }    }}

代码不算少，我将分几步来讲解：

先创建一个通知监听器，需要实现NotificationListener并实现handleNotification方法，可以在该方法里对消息进行处理，在演示代码中只是将消息的各项信息列出来而已。

创建一个RMI连接，即如下两行代码：

//构造一个JMXServiceURL，这里使用的是RMI的连接方式，所以要按照RMI的URL格式，端口是9999,JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://:9999/jmxrmi");//连接远程的JMX AgentJMXConnector jmxc = JMXConnectorFactory.connect(url, null);

获取MBeanServer连接，使用jmxc.getMBeanServerConnection()方法来获取，下面的操作大多数都是基于该MBeanServer连接。
如果有需要的话，可以MBeanServerConnection里取出各种信息，例如MBean的数量以及具体的MBean的名字（使用MBeanServerConnection.queryNames）。
获取想要管理的MBean代理（这涉及到了代理模式）。使用JMX.newMBeanProxy()方法来生成一个MBean的带来，之后就可以使用该MBean代理对具体的MBean进行操作了（例如修改CacheSize等）。
如果需要接收通知，就使用MBeanServerConnection.addNotificationListener()方法为特定的MBean绑定一个监听器。
关闭客户端可以使用JMXConnector.close()方法。

在运行程序之前，需要先运行JMX Agent程序，由于这里是使用RMI进行远程连接，并且连接的端口号是9999，如果直接不再参数启动的话，客户端将无法连接到JMX Agent，需要添加的参数有三个，分别是：

-Dcom.sun.management.jmxremote.port=9999，即开放的接口是9999。
-Dcom.sun.management.jmxremote.authenticate=false，false表示不需要用户认证。
-Dcom.sun.management.jmxremote.ssl=false，false表示不适用SSL安全连接。

加入参数启动之后，就可以尝试启动客户端了，其输出大致如下：

Create an RMI connector client and connect it to the RMI connector serverPress <Enter> to continue...#我按个回车MBeanServer default domain = DefaultDomain#远端的系统中一共有23个MBeanMBean count = 23#23个MBean的名字Query MBeanServer MBeans:	ObjectName = java.lang:type=MemoryPool,name=Metaspace	ObjectName = java.lang:type=MemoryPool,name=PS Old Gen	ObjectName = java.lang:type=GarbageCollector,name=PS Scavenge	ObjectName = java.lang:type=MemoryPool,name=PS Eden Space	ObjectName = JMImplementation:type=MBeanServerDelegate	ObjectName = java.lang:type=Runtime	ObjectName = java.lang:type=Threading	ObjectName = java.lang:type=OperatingSystem	ObjectName = java.lang:type=MemoryPool,name=Code Cache	ObjectName = java.nio:type=BufferPool,name=direct	ObjectName = java.lang:type=Compilation	ObjectName = top.yeonon.jmx:type=Hello	ObjectName = java.lang:type=MemoryManager,name=CodeCacheManager	ObjectName = java.lang:type=MemoryPool,name=Compressed Class Space	ObjectName = java.lang:type=Memory	ObjectName = java.nio:type=BufferPool,name=mapped	ObjectName = java.util.logging:type=Logging	ObjectName = java.lang:type=MemoryPool,name=PS Survivor Space	ObjectName = java.lang:type=ClassLoading	ObjectName = java.lang:type=MemoryManager,name=Metaspace Manager	ObjectName = com.sun.management:type=DiagnosticCommand	ObjectName = java.lang:type=GarbageCollector,name=PS MarkSweep	ObjectName = com.sun.management:type=HotSpotDiagnosticPress <Enter> to continue...#我按个回车Add notification listener...CacheSize = 100Waiting for notification...#监听器收到了通知Received notification:	ClassName: javax.management.AttributeChangeNotification	Source: top.yeonon.jmx:type=Hello	Type: jmx.attribute.change	Message: Cache Size changed	AttributeName: CacheSize	AttributeType: int	NewValue: 150	OldValue: 100CacheSize = 150#调用了sayHello()方法Invoke sayHello() in Hello MBean...#调用了add()方法Invoke add(2, 3) in Hello MBean...Press <Enter> to continue...#回车Close the connection to the serverBye! Bye!

好了，打完收工！

5 小结

本文简单介绍了JMX的三大组成部分，MBean，JMX Agent，Client，但只使用到了JMX的部分功能，其实JMX远不止如此，还有很多更加高级的功能，例如扩展JMX等，希望本文能对读者有一些帮助。

如果文章一些地方说的有问题，望指正。因为我也是初学JMX，算是边学边写的。

Ps: 本文的样例代码都是来自Oracle JMX Tutorial，下面的参考资料中给出了链接。

6 参考资料

Oracle JMX Tutorial

目录CONTENT

Java SE基础巩固（十三）：JMX