JMX監(jiān)控的具體使用

更新時(shí)間：2024年02月19日 09:29:59 作者：randy.lou

JMX最常見(jiàn)的場(chǎng)景是監(jiān)控Java程序的基本信息和運(yùn)行情況,本文主要介紹了JMX監(jiān)控的具體使用,具有一定的參考價(jià)值,感興趣的可以了解一下

1. 定義和意義

JMX是Java Management Extention的縮寫(xiě)，出發(fā)點(diǎn)是讓外部通過(guò)屬性/方法來(lái)讀取或設(shè)置程序狀態(tài)。對(duì)于提供對(duì)外服務(wù)的程序來(lái)說(shuō)，天生就有這樣的能力，Web程序通過(guò)HTTP接口對(duì)外暴露，RPC應(yīng)用通過(guò)RPC接口暴露。不過(guò)帶來(lái)的問(wèn)題，一是依賴環(huán)境，不同的環(huán)境能力不同；二是需要單獨(dú)處理安全性問(wèn)題，尤其是對(duì)公網(wǎng)暴露的情況下。JMX從某種程度上來(lái)說(shuō)，解決了上述兩個(gè)問(wèn)題，無(wú)論什么應(yīng)用都能通過(guò)JMX對(duì)外暴露管理功能，單獨(dú)的非業(yè)務(wù)含義的協(xié)議和通道，可以避免非必要的公網(wǎng)暴露。

2. 架構(gòu)

JDK官網(wǎng)上介紹，JMX在架構(gòu)上分為3層: Instrumentation、JMX Agent、Remote Management

2.1 Instrumentation

Instrumentation定義了MBean的創(chuàng)建規(guī)范，JDK自帶一組叫做MXBean的特殊MBean，對(duì)外提供JVM信息及操作。

2.2 JMX Agent

JMX Agent用來(lái)管理Instrument，核心是MBeanServer(用來(lái)注冊(cè)MBean)，并至少提供一組adaptor和connector，可以理解為通信協(xié)議和通信方式，允許外部程序或者客戶端和JMX Agent通信。

2.3 Remote Management

可以把它理解為JMX Agent的客戶端，通過(guò)不同的adapter和connect(協(xié)議和通信方式)連接到JMX Agent，進(jìn)行遠(yuǎn)程調(diào)用。

3. 服務(wù)端

3.1 注冊(cè)MBean

MBeanServer server = ManagementFactory.getPlatformMBeanServer();
String domain = "MyMBean";
// 注冊(cè)hello
ObjectName helloName = new ObjectName(domain + ":name=hello");
server.registerMBean(new Hello(),helloName);

3.2 啟動(dòng)服務(wù)

使用JVM參數(shù)

-Dcom.sun.management.jmxremote 
-Dcom.sun.management.jmxremote.port=1099 
-Dcom.sun.management.jmxremote.local.only=false 
-Dcom.sun.management.jmxremote.authenticate=false 
-Dcom.sun.management.jmxremote.ssl=false

使用Java代碼

String domain = "jmxrmi"
int rmiPort = 1099;
Registry registry = LocateRegistry.createRegistry(rmiPort);
JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:" + rmiPort + "/" + domain);
JMXConnectorServer jmxConnector = JMXConnectorServerFactory.newJMXConnectorServer(url,null,server);
jmxConnector.start();

如果是代碼或者是遠(yuǎn)程連接JMX Agent，后續(xù)會(huì)用到JMXServiceURL的地址。和使用Java代碼創(chuàng)建不同，JVM參數(shù)的domain值固定為jmxrm

4. 客戶端

JMX的客戶端有兩類，一類是現(xiàn)成的GUI工具，如JConsole、VisualVM等；另一類是通過(guò)代碼操作。通過(guò)GUI程序啟動(dòng)的客戶端，只需要直接選擇對(duì)應(yīng)進(jìn)程ID，或者填入注冊(cè)MBean時(shí)提供的JMXServiceURL即可，如下圖所示。這里我們主要聚焦通過(guò)代碼操作MBean。

4.1 建立連接

和啟動(dòng)JMXConnectorServer一樣，先建立JMXServiceURL，不同的是這里創(chuàng)建的是JMXConnector對(duì)象。

String domain = "jmxrmi";
int rmiPort = 1099;
JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:" + rmiPort + "/" + domain);
JMXConnector jmxc = JMXConnectorFactory.connect(url);
MBeanServerConnection mbsc = jmxc.getMBeanServerConnection();

4.2 MBean列表

Set<ObjectInstance> ins = mbsc.queryMBeans(null,null);
for(ObjectInstance i : ins) {    
    System.out.println("object: " + i.getObjectName());
}

4.3 Domain列表

String[] domains = mbsc.getDomains();
for (String d : domains) {    
    System.out.println(d);
}

4.4 MBean計(jì)數(shù)

System.out.println("MBeanCount:" + mbsc.getMBeanCount());

4.5 屬性讀寫(xiě)

String domain = "MyMBean";
ObjectName helloName = new ObjectName(domain + ":name=hello");
System.out.println("getAttribute:--->" + mbsc.getAttribute(helloName, "Slogan")); // 獲取
mbsc.setAttribute(helloName, new Attribute("Slogan", "" + System.nanoTime())); // 設(shè)置
System.out.println("getAttribute modified--->" + mbsc.getAttribute(helloName, "Slogan")); // 獲取

4.6 方法調(diào)用

有兩種方式可以調(diào)用MBean的方法，一種是直接使用MBeanServerConnection調(diào)用

String domain = "MyMBean";
ObjectName helloName = new ObjectName(domain + ":name=hello");
 // 無(wú)返回
mbsc.invoke(helloName, "printHello", new String[]{"shit"}, new String[]{String.class.getName()});
 // 有返回
Object resp = mbsc.invoke(helloName, "daydream", new Integer[]{5000}, new String[]{Integer.class.getName()});
System.out.println("daydream:--->" + resp);

還有一種方式是通過(guò)BeanServerInvocationHandler生成代理對(duì)象，再用這個(gè)對(duì)象直接調(diào)用

String domain = "MyMBean";
ObjectName helloName = new ObjectName(domain + ":name=hello");
HelloMBean proxy = MBeanServerInvocationHandler.newProxyInstance(mbsc,helloName,HelloMBean.class,false);
System.out.println("proxy get attribute:" + proxy.getSlogan());
System.out.println("proxy invoke:" + proxy.daydream(9999));

第二種方式的使用體驗(yàn)會(huì)好一些，尤其是需要頻繁、多次使用MBean的方法時(shí)。

4.7 BeanInfo讀寫(xiě)

String domain = "MyMBean";
ObjectName helloName = new ObjectName(domain + ":name=hello");

MBeanInfo beanInfo = mbsc.getMBeanInfo(helloName);
System.out.println("class name:" + beanInfo.getClassName()); // MBean實(shí)現(xiàn)類

MBeanAttributeInfo[] attrinfos = beanInfo.getAttributes();  // MBean的屬性
for(MBeanAttributeInfo a: attrinfos) {
    System.out.println("attribute name:" + a.getName());
}

MBeanOperationInfo[] operationInfos = beanInfo.getOperations(); // MBean上的操作
for(MBeanOperationInfo o: operationInfos) {
    System.out.println("operation name:" + o.getName());
}

5. Spring對(duì)JMX的支持

5.1 MBeanServer

通過(guò)提供MBeanServerFactoryBean，允許我們聲明配置并創(chuàng)建MBeanServer對(duì)象

@Bean
public MBeanServerFactoryBean mbeanServer() {
    MBeanServerFactoryBean mbeanServer = new MBeanServerFactoryBean();
    return mbeanServer;
}

5.2 JMXConnectorServer

提供了ConnectorServerFactoryBean對(duì)象，用于配置并創(chuàng)建JMXConnectorServer

@Bean
public ConnectorServerFactoryBean connectorServer() {
    ConnectorServerFactoryBean factoryBean = new ConnectorServerFactoryBean();
    factoryBean.setServer(mbeanServer().getObject());
    factoryBean.setServiceUrl("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi");
    return factoryBean;
}

5.3 注冊(cè)MBean

要啟用對(duì)MBean的自動(dòng)注冊(cè)，如果是Spring Boot應(yīng)用的話，在@Configuration類上添加一個(gè)注解@EnableMBeanExport，注冊(cè)MBean有兩種方案可選，一種方式是使用MBeanExporter，可以用正常的Spring Bean配置為MBean，比如這里的globalProduct bean，后面被做為MBean的目標(biāo)對(duì)象。

@Bean
public Product globalProduct() {
    Product product = new Product();
    product.setId(1234L);
    product.setStaticScore(1.222F);
    product.setRelationScore(2.333F);
    product.setCategoryId(4321);
    return product;
}

@Bean
public MBeanExporter hello() {
    MBeanExporter exporter = new MBeanExporter();
    Map<String, Object> beans = new HashMap<>();
    beans.put("hello:name=globalProduct", globalProduct());
    exporter.setBeans(beans);
    exporter.setServer(mbeanServer().getObject());
    return exporter;
}

另一種方案是通過(guò)注解，使用@ManagedResource、@ManagedAttribute、@ManagedOperation注解，直接暴露Bean對(duì)象

@Component
@ManagedResource(objectName = "hello:name=appInfo")
public class AppInfo {

    @ManagedAttribute(description = "numbers of processors")
    public int getProcessorCount() {
        return Runtime.getRuntime().availableProcessors();
    }

    @ManagedOperation
    public void resetSystemProperties() {
        System.getProperties().setProperty("appInfo","lws");
    }
}

6. 效果和評(píng)估

通過(guò)JConsole連接到我們的應(yīng)用，查看MBean效果如下圖。除了我們自己注冊(cè)的MBean，Java默認(rèn)提供一對(duì)內(nèi)置MBean，用來(lái)讀取系統(tǒng)、JVM的信息，包括類加載、內(nèi)存使用、GC、ClassPath、環(huán)境變量等等信息，甚至可以通過(guò)JFR的MBean來(lái)啟動(dòng)JFR記錄，打線程堆棧、手工執(zhí)行GC等等。

單純的從Java用戶的角度來(lái)說(shuō)，這不失為一種不錯(cuò)的Java管理的擴(kuò)展能力(Java Management Extension)，有一定的基礎(chǔ)設(shè)施，使用也算方便。但是在跨語(yǔ)言方法就顯得有點(diǎn)弱勢(shì)，網(wǎng)上也可以看到各種從JMX適配到其他協(xié)議的工具，以便將JMX數(shù)據(jù)暴露給其他中間件，比如Promethus和JMX 之間就有個(gè)JMX Exporter，讓Promethus能獲取JMX的數(shù)據(jù)。

經(jīng)過(guò)上面的學(xué)習(xí)和試驗(yàn)后，我們對(duì)JMX態(tài)度是可以了解和使用，不必要過(guò)多深入，學(xué)完本文的內(nèi)容已經(jīng)夠用。有具體使用場(chǎng)景，比如希望通過(guò)JMX監(jiān)控Kafka，再詳細(xì)了解Kafka提供的MBean即可。

到此這篇關(guān)于JMX監(jiān)控的具體使用的文章就介紹到這了,更多相關(guān)JMX 使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: