从零开始玩转JMX(一)——简介和Standard MBean
JMX的全稱為Java Management Extensions. 顧名思義，是管理Java的一種擴展。這種機制可以方便的管理、監(jiān)控正在運行中的Java程序。常用于管理線程，內(nèi)存，日志Level，服務(wù)重啟，系統(tǒng)環(huán)境等。
簡介
基本術(shù)語
MBean：是Managed Bean的簡稱，可以翻譯為“管理構(gòu)件”。在JMX中MBean代表一個被管理的資源實例，通過MBean中暴露的方法和屬性，外界可以獲取被管理的資源的狀態(tài)和操縱MBean的行為。事實上，MBean就是一個Java Object，同JavaBean模型一樣，外界使用自醒和反射來獲取Object的值和調(diào)用Object的方法，只是MBean更為復(fù)雜和高級一些。MBean通過公共方法以及遵從特定的設(shè)計模式封裝了屬性和操作，以便暴露給管理應(yīng)用程序。例如，一個只讀屬性在管理構(gòu)件中只有Get方法，既有Get又有Set方法表示是一個可讀寫的屬性。一共有四種類型的MBean: Standard MBean, Dynamic MBean, Open MBean, Model MBean。
MBeanServer：MBean生存在一個MBeanServer中。MBeanServer管理這些MBean，并且代理外界對它們的訪問。并且MBeanServer提供了一種注冊機制，是的外界可以通過名字來得到相應(yīng)的MBean實例。
JMX Agent：Agent只是一個Java進程，它包括這個MBeanServer和一系列附加的MbeanService。當(dāng)然這些Service也是通過MBean的形式來發(fā)布。
Protocol Adapters and Connectors：MBeanServer依賴于Protocol Adapters和Connectors來和運行該代理的Java虛擬機之外的管理應(yīng)用程序進行通信。Protocol Adapters通過特定的協(xié)議提供了一張注冊在MBeanServer的MBean的視圖。例如，一個HTML Adapter可以將所有注冊過的MBean顯示在Web 頁面上。不同的協(xié)議，提供不同的視圖。Connectors還必須提供管理應(yīng)用一方的接口以使代理和管理應(yīng)用程序進行通信，即針對不同的協(xié)議，Connectors必須提供同樣的遠程接口來封裝通信過程。當(dāng)遠程應(yīng)用程序使用這個接口時，就可以通過網(wǎng)絡(luò)透明的和代理進行交互，而忽略協(xié)議本身。Adapters和Connectors使MBean服務(wù)器與管理應(yīng)用程序能進行通信。因此，一個代理要被管理，它必須提供至少一個Protocol Adapter或者Connector。面臨多種管理應(yīng)用時，代理可以包含各種不同的Protocol Adapters和Connectors。當(dāng)前已經(jīng)實現(xiàn)和將要實現(xiàn)的Protocol Adapters和Connectors包括： RMI Connector, SNMP Adapter, IIOP Adapter, HTML Adapter, HTTP Connector.
Adapter 和Connector的區(qū)別在于：Adapter是使用某種Internet協(xié)議來與JMX Agent獲得聯(lián)系，Agent端會有一個對象 (Adapter)來處理有關(guān)協(xié)議的細節(jié)。比如SNMP Adapter和HTTP Adapter。而Connector則是使用類似RPC的方式來訪問Agent，在Agent端和客戶端都必須有這樣一個對象來處理相應(yīng)的請求與應(yīng)答。比如RMI Connector。
JMX Agent可以帶有任意多個Adapter，因此可以使用多種不同的方式訪問Agent。
JMX基本構(gòu)架
JMX分為三層，分別負責(zé)處理不同的事務(wù)。它們分別是：
Instrumentation 層?
Instrumentation層主要包括了一系列的接口定義和描述如何開發(fā)MBean的規(guī)范。通常JMX所管理的資源有一個或多個MBean組成，因此這個資源可以是任何由Java語言開發(fā)的組件，或是一個JavaWrapper包裝的其他語言開發(fā)的資源。
Agent 層?
Agent 用來管理相應(yīng)的資源，并且為遠端用戶提供訪問的接口。Agent層構(gòu)建在Intrumentation層之上，并且使用并管理 Instrumentation層內(nèi)部描述的組件。Agent層主要定義了各種服務(wù)以及通信模型。該層的核心是一MBeanServer,所有的MBean都要向它注冊，才能被管理。注冊在MBeanServer上的MBean并不直接和遠程應(yīng)用程序進行通信，他們通過協(xié)議適配器（Adapter）和連接器（Connector）進行通信。通常Agent由一個MBeanServer和多個系統(tǒng)服務(wù)組成。JMX Agent并不關(guān)心它所管理的資源是什么。
Distributed 層?
Distributed層關(guān)心Agent如何被遠端用戶訪問的細節(jié)。它定義了一系列用來訪問Agent的接口和組件，包括Adapter和Connector的描述。
如果一個Java對象可以由一個遵循JMX規(guī)范的管理器應(yīng)用管理，那么這個Java對象就可以由JMX管理資源。要使一個Java對象可管理，則必須創(chuàng)建相應(yīng)的MBean對象，并通過這些MBean對象管理相應(yīng)的Java對象。當(dāng)擁有MBean類后，需要將其實例化并注冊到MBeanServer上。
詳述
這里采用的是JDK7，JDK7中已經(jīng)包含了jmx，但是如果用到HtmlAdaptorServer類（后面會看到）還需要用到j(luò)mxtools.jar, 可以去這里下載，有兩個包：jmx-1_2_1-ri.zip； jmx_remote-1_0_1_03-ri.zip。jmx-1_2_1-ri.zip解壓后lib中有jmxri.jar和jmxtools.jar,將jmxtool.jar拷貝出來放入classpath中即可（jmxri.jar在JDK5+已經(jīng)包被包含了）。
Standard MBean
Standard MBean的設(shè)計和實現(xiàn)是最簡單的，它們的管理接口通過方法名來描述。Standard MBean的實現(xiàn)依靠一組命名規(guī)則，稱之為設(shè)計模式。這些命名規(guī)則定義了屬性和操作。?
檢查Standard MBean接口和應(yīng)用設(shè)計模式的過程被稱為內(nèi)省（Introspection）。JMX代理通過內(nèi)省來查看每一個注冊在MBeanServer上的MBean的方法和超類，看它是否遵從一定設(shè)計模式，決定它是否代表了一個MBean，并辨認出它的屬性和操作。?
Standard MBean是JMX管理構(gòu)件中最簡單的一種，只需要開發(fā)一個MBean接口（為了實現(xiàn)Standard MBean，必須遵循一套繼承規(guī)范。必須每一個MBean定義一個接口，而且這個接口的名字必須是其被管理的資源的對象類的名稱后面加上”MBean”），一個實現(xiàn)MBean接口的類，并且把它們注冊到MBeanServer中就可以了。
package com.test.jmx;
public interface HelloMBean {
? ? public String getName();
? ? public void setName(String name);
? ? public void printHello();
? ? public void printHello(String whoName);
}
1
2
3
4
5
6
7
8
接下來是真正的資源對象，因為命名規(guī)范的限制，因此對象名稱必須為Hello.
package com.test.jmx;
public class Hello implements HelloMBean {
? ? private String name;
? ? @Override
? ? public String getName() {
? ? ? ? return name;
? ? }
? ? @Override
? ? public void setName(String name) {
? ? ? ? this.name = name;
? ? }
? ? @Override
? ? public void printHello() {
? ? ? ? System.out.println("Hello world, "+ name);
? ? }
? ? @Override
? ? public void printHello(String whoName) {
? ? ? ? System.out.println("Hello, "+whoName);
? ? }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
接下去創(chuàng)建一個Agent類：
package com.test.jmx;
import com.sun.jdmk.comm.HtmlAdaptorServer;
import javax.management.*;
import javax.management.remote.JMXConnectorServer;
import javax.management.remote.JMXConnectorServerFactory;
import javax.management.remote.JMXServiceURL;
import java.io.IOException;
import java.lang.management.ManagementFactory;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
public class HelloAgent {
? ? public static void main(String[] args) throws MalformedObjectNameException,
? ? ? ? ? ? NotCompliantMBeanException, InstanceAlreadyExistsException,
? ? ? ? ? ? MBeanRegistrationException, IOException {
? ? ? ? // 下面這種方式不能再JConsole中使用
// ? ? ?MBeanServer server = MBeanServerFactory.createMBeanServer();
// 首先建立一個MBeanServer,MBeanServer用來管理我們的MBean,通常是通過MBeanServer來獲取我們MBean的信息，間接
// 調(diào)用MBean的方法，然后生產(chǎn)我們的資源的一個對象。
? ? ? ? MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
? ? ? ? String domainName = "MyMBean";
//為MBean（下面的new Hello()）創(chuàng)建ObjectName實例
? ? ? ? ObjectName helloName = new ObjectName(domainName+":name=HelloWorld");
// 將new Hello()這個對象注冊到MBeanServer上去
? ? ? ? mbs.registerMBean(new Hello(),helloName);
// Distributed Layer, 提供了一個HtmlAdaptor。支持Http訪問協(xié)議，并且有一個不錯的HTML界面，這里的Hello就是用這個作為遠端管理的界面
// 事實上HtmlAdaptor是一個簡單的HttpServer，它將Http請求轉(zhuǎn)換為JMX Agent的請求
? ? ? ? ObjectName adapterName = new ObjectName(domainName+":name=htmladapter,port=8082");
? ? ? ? HtmlAdaptorServer adapter = new HtmlAdaptorServer();
? ? ? ? adapter.start();
? ? ? ? mbs.registerMBean(adapter,adapterName);
? ? ? ? int rmiPort = 1099;
? ? ? ? Registry registry = LocateRegistry.createRegistry(rmiPort);
? ? ? ? JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:"+rmiPort+"/"+domainName);
? ? ? ? JMXConnectorServer jmxConnector = JMXConnectorServerFactory.newJMXConnectorServer(url, null, mbs);
? ? ? ? jmxConnector.start();
? ? }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
編譯運行，在瀏覽器中輸入localhost:8082,這樣我們就可以對程序進行管理，如圖：
可以看到我們注冊的MyMBean域下的”name=HelloWorld”,可以點擊進去，然后可以修改屬性Name和執(zhí)行2個printHello方法，可以在控制臺看到效果。具體不貼圖贅述，機智的小伙伴一試就知道怎么玩轉(zhuǎn)了。
上面代碼中還通過RMI(JMXServiceURL, JMXConnectorServer )注冊URL來提供客戶端連接，可以通過JConsole作為客戶端來管理MBean. 打開JConsole工具（%JAVA_HOME%/bin/jconsole.exe），如圖在遠程進程中輸入rmi地址“service:jmx:rmi:///jndi/rmi://localhost:1099/MyMBean”：
點擊“連接”之后就出現(xiàn)：?
這樣就可以像HTML一樣管理MBean了。
注意上面的代碼中：
Registry registry = LocateRegistry.createRegistry(rmiPort);
1
可以在某一特定端口創(chuàng)建名字服務(wù)，從而用戶無需再手工啟動rmiregistry，如果不加入這句代碼，就會出現(xiàn)Connection Refused的異常：
Exception in thread "main" java.io.IOException: Cannot bind to URL [rmi://localhost:1099/MyMBean]: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: localhost; nested exception is:?
? ? java.net.ConnectException: Connection refused: connect]
? ? at javax.management.remote.rmi.RMIConnectorServer.newIOException(Unknown Source)
? ? at javax.management.remote.rmi.RMIConnectorServer.start(Unknown Source)
? ? at com.test.jmx.HelloAgent.main(HelloAgent.java:44)
Caused by: javax.naming.ServiceUnavailableException [Root exception is java.rmi.ConnectException: Connection refused to host: localhost; nested exception is:?
? ? java.net.ConnectException: Connection refused: connect]
? ? at com.sun.jndi.rmi.registry.RegistryContext.bind(Unknown Source)
? ? at com.sun.jndi.toolkit.url.GenericURLContext.bind(Unknown Source)
? ? at javax.naming.InitialContext.bind(Unknown Source)
? ? at javax.management.remote.rmi.RMIConnectorServer.bind(Unknown Source)
? ? ... 2 more
Caused by: java.rmi.ConnectException: Connection refused to host: localhost; nested exception is:?
? ? java.net.ConnectException: Connection refused: connect
? ? at sun.rmi.transport.tcp.TCPEndpoint.newSocket(Unknown Source)
? ? at sun.rmi.transport.tcp.TCPChannel.createConnection(Unknown Source)
? ? at sun.rmi.transport.tcp.TCPChannel.newConnection(Unknown Source)
? ? at sun.rmi.server.UnicastRef.newCall(Unknown Source)
? ? at sun.rmi.registry.RegistryImpl_Stub.bind(Unknown Source)
? ? ... 6 more
Caused by: java.net.ConnectException: Connection refused: connect
? ? at java.net.DualStackPlainSocketImpl.connect0(Native Method)
? ? at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
? ? at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
? ? at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
? ? at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
? ? at java.net.PlainSocketImpl.connect(Unknown Source)
? ? at java.net.SocksSocketImpl.connect(Unknown Source)
? ? at java.net.Socket.connect(Unknown Source)
? ? at java.net.Socket.connect(Unknown Source)
? ? at java.net.Socket.<init>(Unknown Source)
? ? at java.net.Socket.<init>(Unknown Source)
? ? at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(Unknown Source)
? ? at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(Unknown Source)
? ? ... 11 more
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
當(dāng)然，這也就其他的解決辦法：運行 %JAVA_HOME%/bin/rmiregistry.exe 1099就有和那行代碼一樣的效果。
我們不僅可以通過JConsole作為客戶端采用rmi的方式來進行管理，我們同樣可以采用自定義程序作為客戶端來連接JMXConnectorServer管理MBean.
package com.test.jmx;
import java.io.IOException;
import java.util.Iterator;
import java.util.Set;
import javax.management.Attribute;
import javax.management.AttributeNotFoundException;
import javax.management.InstanceNotFoundException;
import javax.management.IntrospectionException;
import javax.management.InvalidAttributeValueException;
import javax.management.MBeanException;
import javax.management.MBeanInfo;
import javax.management.MBeanServerConnection;
import javax.management.MBeanServerInvocationHandler;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectInstance;
import javax.management.ObjectName;
import javax.management.ReflectionException;
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 IOException,
? ? ? ? ? ? MalformedObjectNameException, InstanceNotFoundException,
? ? ? ? ? ? AttributeNotFoundException, InvalidAttributeValueException,
? ? ? ? ? ? MBeanException, ReflectionException, IntrospectionException {
? ? ? ? String domainName = "MyMBean";
? ? ? ? int rmiPort = 1099;
? ? ? ? JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:"+rmiPort+"/"+domainName);
? ? ? ? // 可以類比HelloAgent.java中的那句：
? ? ? ? // JMXConnectorServer jmxConnector = JMXConnectorServerFactory.newJMXConnectorServer(url, null, mbs);
? ? ? ? JMXConnector jmxc = JMXConnectorFactory.connect(url);
? ? ? ? MBeanServerConnection mbsc = jmxc.getMBeanServerConnection();
? ? ? ? //print domains
? ? ? ? System.out.println("Domains:------------------");
? ? ? ? String domains[] = mbsc.getDomains();
? ? ? ? for(int i=0;i<domains.length;i++){
? ? ? ? ? ? System.out.println("\tDomain["+i+"] = "+domains[i]);
? ? ? ? }
? ? ? ? //MBean count
? ? ? ? System.out.println("MBean count = "+mbsc.getMBeanCount());
? ? ? ? //process attribute
? ? ? ? ObjectName mBeanName = new ObjectName(domainName+":name=HelloWorld");
? ? ? ? mbsc.setAttribute(mBeanName, new Attribute("Name","zzh"));//注意這里是Name而不是name
? ? ? ? System.out.println("Name = "+mbsc.getAttribute(mBeanName, "Name"));
? ? ? ? //接下去是執(zhí)行Hello中的printHello方法，分別通過代理和rmi的方式執(zhí)行
? ? ? ? //via proxy
? ? ? ? HelloMBean proxy = MBeanServerInvocationHandler.newProxyInstance(mbsc, mBeanName, HelloMBean.class, false);
? ? ? ? proxy.printHello();
? ? ? ? proxy.printHello("jizhi boy");
? ? ? ? //via rmi
? ? ? ? mbsc.invoke(mBeanName, "printHello", null, null);
? ? ? ? mbsc.invoke(mBeanName, "printHello", new String[]{"jizhi gril"}, new String[]{String.class.getName()});
? ? ? ? //get mbean information
? ? ? ? MBeanInfo info = mbsc.getMBeanInfo(mBeanName);
? ? ? ? System.out.println("Hello Class: "+info.getClassName());
? ? ? ? for(int i=0;i<info.getAttributes().length;i++){
? ? ? ? ? ? System.out.println("Hello Attribute:"+info.getAttributes()[i].getName());
? ? ? ? }
? ? ? ? for(int i=0;i<info.getOperations().length;i++){
? ? ? ? ? ? System.out.println("Hello Operation:"+info.getOperations()[i].getName());
? ? ? ? }
? ? ? ? //ObjectName of MBean
? ? ? ? System.out.println("all ObjectName:--------------");
? ? ? ? Set<ObjectInstance> set = mbsc.queryMBeans(null, null);
? ? ? ? for(Iterator<ObjectInstance> it = set.iterator();it.hasNext();){
? ? ? ? ? ? ObjectInstance oi = it.next();
? ? ? ? ? ? System.out.println("\t"+oi.getObjectName());
? ? ? ? }
? ? ? ? jmxc.close();
? ? }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
運行結(jié)果：
Domains:------------------
? ? Domain[0] = MyMBean
? ? Domain[1] = java.nio
? ? Domain[2] = JMImplementation
? ? Domain[3] = com.sun.management
? ? Domain[4] = java.lang
? ? Domain[5] = java.util.logging
MBean count = 21
Name = zzh
Hello Class: com.test.jmx.Hello
Hello Attribute:Name
Hello Operation:printHello
Hello Operation:printHello
all ObjectName:--------------
? ? java.lang:type=OperatingSystem
? ? java.lang:type=Compilation
? ? java.lang:type=MemoryPool,name=PS Old Gen
? ? java.lang:type=Memory
? ? JMImplementation:type=MBeanServerDelegate
? ? java.lang:type=MemoryPool,name=PS Perm Gen
? ? java.lang:type=Runtime
? ? MyMBean:name=htmladapter,port=8082
? ? java.nio:type=BufferPool,name=direct
? ? java.lang:type=GarbageCollector,name=PS MarkSweep
? ? java.nio:type=BufferPool,name=mapped
? ? java.lang:type=Threading
? ? com.sun.management:type=HotSpotDiagnostic
? ? java.lang:type=GarbageCollector,name=PS Scavenge
? ? MyMBean:name=HelloWorld
? ? java.lang:type=ClassLoading
? ? java.lang:type=MemoryPool,name=PS Survivor Space
? ? java.lang:type=MemoryManager,name=CodeCacheManager
? ? java.lang:type=MemoryPool,name=Code Cache
? ? java.util.logging:type=Logging
? ? java.lang:type=MemoryPool,name=PS Eden Space
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
這是客戶端的運行結(jié)果，由于在客戶端調(diào)用了服務(wù)端的方法，可以在服務(wù)端看到打印結(jié)果：
Hello world, zzh
Hello, jizhi boy
Hello world, zzh
Hello, jizhi gril
1
2
3
4
上面代碼涉及到輔助原數(shù)據(jù)的概念：輔助元數(shù)據(jù)類用來描述管理構(gòu)件。輔助元數(shù)據(jù)類不僅被用來內(nèi)省標(biāo)準管理構(gòu)件，也被動態(tài)管理構(gòu)件用來進行自我描述。這些類根據(jù)屬性、操作、構(gòu)建器和通告描述了管理接口。JMX代理通過這些元數(shù)據(jù)類管理所有管理構(gòu)件，而不管這些管理構(gòu)件的類型。部分輔助元類如下：
MBeanInfo–包含了屬性、操作、構(gòu)建器和通知的信息。
MBeanFeatureInfo–為下面類的超類。
MBeanAttributeInfo–用來描述管理構(gòu)件中的屬性。
MBeanConstructorInfo–用來描述管理構(gòu)件中的構(gòu)建器。
MBeanOperationInfo–用來描述管理構(gòu)件中的操作。
MBeanParameterInfo–用來描述管理構(gòu)件操作或構(gòu)建器的參數(shù)。
MBeanNotificationInfo–用來描述管理構(gòu)件發(fā)出的通知。
有關(guān)Notication, Dynamic MBean, Model MBean以及Apache Common Modeler由于篇幅限制將后面文章中講述。
參考資料
JMX整理
JMX簡介
http://blog.csdn.net/DryKillLogic/article/category/762777
用Apache的commons-modeler來輔助開發(fā)JMX
---------------------?
作者：朱小廝?
來源：CSDN?
原文：https://blog.csdn.net/u013256816/article/details/52800742?
版權(quán)聲明：本文為博主原創(chuàng)文章，轉(zhuǎn)載請附上博文鏈接！
總結(jié)
以上是生活随笔為你收集整理的从零开始玩转JMX(一)——简介和Standard MBean的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 消息中间件和JMS介绍
- 下一篇： 用 JMX 检测应用程序