JMX監(jiān)控的具體使用
1. 定義和意義
JMX是Java Management Extention的縮寫,出發(fā)點(diǎn)是讓外部通過屬性/方法來讀取或設(shè)置程序狀態(tài)。對于提供對外服務(wù)的程序來說,天生就有這樣的能力,Web程序通過HTTP接口對外暴露,RPC應(yīng)用通過RPC接口暴露。不過帶來的問題,一是依賴環(huán)境,不同的環(huán)境能力不同;二是需要單獨(dú)處理安全性問題,尤其是對公網(wǎng)暴露的情況下。JMX從某種程度上來說,解決了上述兩個(gè)問題,無論什么應(yīng)用都能通過JMX對外暴露管理功能,單獨(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,對外提供JVM信息及操作。
2.2 JMX Agent
JMX Agent用來管理Instrument,核心是MBeanServer(用來注冊MBean),并至少提供一組adaptor和connector,可以理解為通信協(xié)議和通信方式,允許外部程序或者客戶端和JMX Agent通信。
2.3 Remote Management
可以把它理解為JMX Agent的客戶端,通過不同的adapter和connect(協(xié)議和通信方式)連接到JMX Agent,進(jìn)行遠(yuǎn)程調(diào)用。
3. 服務(wù)端
3.1 注冊MBean
MBeanServer server = ManagementFactory.getPlatformMBeanServer(); String domain = "MyMBean"; // 注冊hello ObjectName helloName = new ObjectName(domain + ":name=hello"); server.registerMBean(new Hello(),helloName);
3.2 啟動服務(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ù)會用到JMXServiceURL的地址。和使用Java代碼創(chuàng)建不同,JVM參數(shù)的domain值固定為jmxrm
4. 客戶端
JMX的客戶端有兩類,一類是現(xiàn)成的GUI工具,如JConsole、VisualVM等;另一類是通過代碼操作。通過GUI程序啟動的客戶端,只需要直接選擇對應(yīng)進(jìn)程ID,或者填入注冊MBean時(shí)提供的JMXServiceURL即可,如下圖所示。這里我們主要聚焦通過代碼操作MBean。
4.1 建立連接
和啟動JMXConnectorServer一樣,先建立JMXServiceURL,不同的是這里創(chuàng)建的是JMXConnector對象。
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 屬性讀寫
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"); // 無返回 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);
還有一種方式是通過BeanServerInvocationHandler生成代理對象,再用這個(gè)對象直接調(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)會好一些,尤其是需要頻繁、多次使用MBean的方法時(shí)。
4.7 BeanInfo讀寫
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對JMX的支持
5.1 MBeanServer
通過提供MBeanServerFactoryBean,允許我們聲明配置并創(chuàng)建MBeanServer對象
@Bean public MBeanServerFactoryBean mbeanServer() { MBeanServerFactoryBean mbeanServer = new MBeanServerFactoryBean(); return mbeanServer; }
5.2 JMXConnectorServer
提供了ConnectorServerFactoryBean對象,用于配置并創(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 注冊MBean
要啟用對MBean的自動注冊,如果是Spring Boot應(yīng)用的話,在@Configuration類上添加一個(gè)注解@EnableMBeanExport,注冊MBean有兩種方案可選,一種方式是使用MBeanExporter,可以用正常的Spring Bean配置為MBean,比如這里的globalProduct bean,后面被做為MBean的目標(biāo)對象。
@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; }
另一種方案是通過注解,使用@ManagedResource、@ManagedAttribute、@ManagedOperation注解,直接暴露Bean對象
@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. 效果和評估
通過JConsole連接到我們的應(yīng)用,查看MBean效果如下圖。除了我們自己注冊的MBean,Java默認(rèn)提供一對內(nèi)置MBean,用來讀取系統(tǒng)、JVM的信息,包括類加載、內(nèi)存使用、GC、ClassPath、環(huán)境變量等等信息,甚至可以通過JFR的MBean來啟動JFR記錄,打線程堆棧、手工執(zhí)行GC等等。
單純的從Java用戶的角度來說,這不失為一種不錯(cuò)的Java管理的擴(kuò)展能力(Java Management Extension),有一定的基礎(chǔ)設(shè)施,使用也算方便。但是在跨語言方法就顯得有點(diǎn)弱勢,網(wǎng)上也可以看到各種從JMX適配到其他協(xié)議的工具,以便將JMX數(shù)據(jù)暴露給其他中間件,比如Promethus和JMX 之間就有個(gè)JMX Exporter,讓Promethus能獲取JMX的數(shù)據(jù)。
經(jīng)過上面的學(xué)習(xí)和試驗(yàn)后,我們對JMX態(tài)度是可以了解和使用,不必要過多深入,學(xué)完本文的內(nèi)容已經(jīng)夠用。有具體使用場景,比如希望通過JMX監(jiān)控Kafka,再詳細(xì)了解Kafka提供的MBean即可。
到此這篇關(guān)于JMX監(jiān)控的具體使用的文章就介紹到這了,更多相關(guān)JMX 使用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
SpringData關(guān)鍵字查詢實(shí)現(xiàn)方法詳解
這篇文章主要介紹了SpringData關(guān)鍵字查詢實(shí)現(xiàn)方法詳解,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-08-08java實(shí)現(xiàn)識別二維碼圖片功能方法詳解與實(shí)例源碼
這篇文章主要介紹了java實(shí)現(xiàn)識別二維碼圖片,java無法識別二維碼情況下對二維碼圖片調(diào)優(yōu)功能方法與實(shí)例源碼,需要的朋友可以參考下2022-12-12