1. 從一次線上告警說起為什么我們需要JMX那天下午我正在處理一個(gè)常規(guī)需求監(jiān)控系統(tǒng)的告警突然響了。告警信息顯示線上某核心服務(wù)的堆內(nèi)存使用率在半小時(shí)內(nèi)從60%穩(wěn)步爬升到了85%并且沒有回落的跡象。這通常意味著存在內(nèi)存泄漏的風(fēng)險(xiǎn)。運(yùn)維同學(xué)在群里我問能不能在不重啟服務(wù)的情況下先看看是哪個(gè)對(duì)象在“吃”內(nèi)存或者臨時(shí)調(diào)整一下JVM參數(shù)比如把年輕代的 Survivor 區(qū)比例調(diào)一下看看能不能緩解。如果放在幾年前我可能只能回復(fù)“重啟一下服務(wù)吧或者等個(gè)幾分鐘我打個(gè)堆轉(zhuǎn)儲(chǔ)文件下來分析?！?但這次我回復(fù)的是“稍等我連上去看一下?！?我用的工具就是 JMX。JMX全稱 Java Management Extensions翻譯過來是 Java 管理擴(kuò)展。這個(gè)名字聽起來很官方有點(diǎn)距離感。但你可以把它理解為你家服務(wù)器的“遠(yuǎn)程控制面板”。就像你可以通過電視遙控器調(diào)整音量、切換頻道而不需要跑到電視機(jī)后面去擰按鈕一樣JMX 允許你在應(yīng)用運(yùn)行時(shí)遠(yuǎn)程查看它的內(nèi)部狀態(tài)比如內(nèi)存使用量、線程數(shù)、緩存命中率甚至動(dòng)態(tài)修改一些配置比如日志級(jí)別、線程池大小。那次線上問題我通過 JMX 連接工具如 JConsole 或 VisualVM連接到出問題的 Java 進(jìn)程。在java.lang域下找到了Memory這個(gè) MBean實(shí)時(shí)查看了堆內(nèi)存各個(gè)區(qū)域Eden, Survivor, Old Gen的使用情況確認(rèn)了是老年代在持續(xù)增長(zhǎng)。接著我通過HotSpotDiagnostic這個(gè) MBean 動(dòng)態(tài)生成了一個(gè)堆轉(zhuǎn)儲(chǔ)文件下載到本地用 MAT 工具分析快速定位到了一個(gè)第三方庫(kù)的靜態(tài) Map 沒有正確清理。同時(shí)為了應(yīng)急我通過MemoryPool相關(guān)的 MBean 觀察了 GC 頻率臨時(shí)調(diào)整了一個(gè)業(yè)務(wù)開關(guān)減少了某些非實(shí)時(shí)任務(wù)的并發(fā)度降低了內(nèi)存創(chuàng)建壓力為徹底修復(fù)爭(zhēng)取了時(shí)間。整個(gè)過程服務(wù)沒有重啟沒有影響用戶。這就是 JMX 在運(yùn)維和診斷中的核心價(jià)值提供了一套標(biāo)準(zhǔn)的、遠(yuǎn)程的、動(dòng)態(tài)的管理和監(jiān)控 Java 應(yīng)用的機(jī)制。而圍繞 JMX 的一系列概念——MBean、MXBean、MBeanServer——就是構(gòu)建這套機(jī)制的基石。理解它們是你從“只會(huì)寫業(yè)務(wù)代碼”向“能掌控應(yīng)用運(yùn)行時(shí)狀態(tài)”的開發(fā)者邁進(jìn)的關(guān)鍵一步。2. JMX 架構(gòu)三層模型管理端、代理端與被管資源要理解 MBean 是什么必須先搞清楚 JMX 的整體架構(gòu)。JMX 的設(shè)計(jì)采用了經(jīng)典的三層模型這個(gè)模型清晰地將管理功能、通信協(xié)議和實(shí)際資源分離開非常優(yōu)雅。2.1 分布式服務(wù)層管理工具在哪里這一層是 JMX 的客戶端也就是我們用來進(jìn)行監(jiān)控和管理的工具。它可以是圖形化的也可以是命令行的。最常見的有JConsoleJDK 自帶的圖形化工具開箱即用功能全面是入門首選。VisualVM功能更強(qiáng)大的性能分析工具也支持 JMX 連接插件生態(tài)豐富。JMC (Java Mission Control)Oracle 推出的商業(yè)級(jí)但對(duì)于開發(fā)環(huán)境免費(fèi)監(jiān)控和管理套件提供更深入的飛行記錄器功能。編程式客戶端你也可以通過JMXConnector等 API編寫自己的管理程序集成到公司的監(jiān)控系統(tǒng)中。這些工具通過特定的協(xié)議如 RMI 或 JMXMP與中間層通信發(fā)送請(qǐng)求并接收數(shù)據(jù)。2.2 代理層MBeanServer 的核心舞臺(tái)這是 JMX 架構(gòu)的心臟也是我們編程時(shí)主要打交道的部分。它的核心是一個(gè)叫做MBeanServer的組件。你可以把 MBeanServer 想象成一個(gè)注冊(cè)中心或者經(jīng)紀(jì)人。它的核心職責(zé)包括注冊(cè)與管理所有被管理的資源即 MBean都需要在 MBeanServer 中注冊(cè)獲得一個(gè)唯一的對(duì)象名。請(qǐng)求路由當(dāng)管理工具想要獲取某個(gè) MBean 的屬性比如當(dāng)前線程數(shù)或調(diào)用其方法比如執(zhí)行一次 GC時(shí)請(qǐng)求會(huì)發(fā)送到 MBeanServer由它找到對(duì)應(yīng)的 MBean 實(shí)例完成操作并返回結(jié)果。通知分發(fā)MBean 可以發(fā)出事件通知例如當(dāng)緩存命中率低于閾值時(shí)MBeanServer 負(fù)責(zé)將這些通知轉(zhuǎn)發(fā)給已注冊(cè)的監(jiān)聽器。代理層還包含一些其他組件如動(dòng)態(tài)加載 MBean 的類加載器、以及將協(xié)議請(qǐng)求轉(zhuǎn)換為對(duì) MBeanServer 調(diào)用的協(xié)議適配器/連接器。我們常說的“開啟 JMX 遠(yuǎn)程連接”主要就是在配置這些連接器讓外部的管理工具能夠訪問到 MBeanServer。2.3 設(shè)備層被管理的資源——MBean這一層就是被監(jiān)控和管理的 Java 對(duì)象本身也就是MBean。一個(gè) MBean 就是一個(gè)遵循了特定設(shè)計(jì)模式的 Java 對(duì)象它通過一組定義良好的接口向外界暴露其管理接口。這個(gè)接口通常包括屬性可以被讀取或修改的數(shù)據(jù)項(xiàng)。例如內(nèi)存使用量、活動(dòng)會(huì)話數(shù)、開關(guān)狀態(tài)。操作可以被調(diào)用的方法。例如“清空緩存”、“重新加載配置”、“生成報(bào)告”。通知可以主動(dòng)發(fā)出的事件。例如“配置已更新”、“錯(cuò)誤率超限”。MBean 是 JMX 體系的基石。你編寫的任何一個(gè) MBean都需要在 MBeanServer 中注冊(cè)后才能被管理工具發(fā)現(xiàn)和操作。接下來我們就深入看看 MBean 的具體實(shí)現(xiàn)形式。3. 標(biāo)準(zhǔn) MBean基于接口約定的經(jīng)典模式標(biāo)準(zhǔn) MBean 是 JMX 中最傳統(tǒng)、最符合直覺的一種實(shí)現(xiàn)方式。它的核心規(guī)則是一個(gè) MBean 由一個(gè)具體的實(shí)現(xiàn)類和一個(gè)與之配對(duì)的接口組成且接口的命名必須是在實(shí)現(xiàn)類類名后加上MBean。這個(gè)命名約定是強(qiáng)制性的MBeanServer 和客戶端工具都依賴這個(gè)規(guī)則來發(fā)現(xiàn)管理接口。3.1 如何定義一個(gè)標(biāo)準(zhǔn) MBean假設(shè)我們要管理一個(gè)簡(jiǎn)單的應(yīng)用緩存我們可以這樣設(shè)計(jì)首先定義管理接口CacheManagerMBean。這個(gè)接口定義了外界可以訪問的所有屬性和操作。// 管理接口命名必須為 [實(shí)現(xiàn)類名]MBean public interface CacheManagerMBean { // 屬性緩存最大容量可讀可寫 int getMaxCacheSize(); void setMaxCacheSize(int size); // 屬性當(dāng)前緩存條目數(shù)只讀 int getCurrentCacheSize(); // 屬性緩存命中率只讀 double getCacheHitRate(); // 操作清空所有緩存 void clearCache(); // 操作根據(jù)Key移除特定緩存項(xiàng) void removeCacheEntry(String key); // 操作獲取緩存統(tǒng)計(jì)信息報(bào)告 String generateStatsReport(); }然后提供該接口的實(shí)現(xiàn)類CacheManager。這個(gè)類包含實(shí)際的業(yè)務(wù)邏輯。// MBean 實(shí)現(xiàn)類 public class CacheManager implements CacheManagerMBean { private int maxCacheSize 1000; private MapString, Object cache new ConcurrentHashMap(); private long hitCount 0; private long missCount 0; Override public int getMaxCacheSize() { return maxCacheSize; } Override public void setMaxCacheSize(int size) { if (size 0) { throw new IllegalArgumentException(緩存大小不能為負(fù)數(shù)); } this.maxCacheSize size; // 這里可以添加邏輯例如當(dāng)新大小小于當(dāng)前大小時(shí)觸發(fā)緩存清理 System.out.println(緩存最大容量已更新為: size); } Override public int getCurrentCacheSize() { return cache.size(); } Override public double getCacheHitRate() { long total hitCount missCount; return total 0 ? 0.0 : (double) hitCount / total; } Override public void clearCache() { cache.clear(); System.out.println(緩存已清空); } Override public void removeCacheEntry(String key) { if (cache.remove(key) ! null) { System.out.println(緩存項(xiàng) key 已移除); } } Override public String generateStatsReport() { return String.format(緩存統(tǒng)計(jì): 最大容量%d, 當(dāng)前條目%d, 命中率%.2f%%, maxCacheSize, cache.size(), getCacheHitRate() * 100); } // 以下是業(yè)務(wù)方法不屬于MBean接口 public Object getFromCache(String key) { Object value cache.get(key); if (value ! null) { hitCount; } else { missCount; } return value; } public void putIntoCache(String key, Object value) { if (cache.size() maxCacheSize) { // 簡(jiǎn)單的LRU淘汰邏輯示例 // 實(shí)際項(xiàng)目可能需要更復(fù)雜的策略 IteratorString it cache.keySet().iterator(); if (it.hasNext()) { cache.remove(it.next()); } } cache.put(key, value); } }3.2 注冊(cè)與訪問標(biāo)準(zhǔn) MBean定義了 MBean 之后我們需要在應(yīng)用啟動(dòng)時(shí)將它注冊(cè)到 MBeanServer 中。import javax.management.*; import java.lang.management.ManagementFactory; public class JmxBootstrap { public static void main(String[] args) throws Exception { // 1. 獲取平臺(tái)級(jí)的 MBeanServer MBeanServer mbs ManagementFactory.getPlatformMBeanServer(); // 2. 為我們的 MBean 構(gòu)造一個(gè)唯一的對(duì)象名 // 格式通常為域名:type類型名[,其他屬性] // 域名通常用你的包名或組織名防止沖突 ObjectName objectName new ObjectName(com.yourcompany.app:typeCacheManager,nameDefaultCache); // 3. 創(chuàng)建 MBean 實(shí)例 CacheManager cacheManager new CacheManager(); // 4. 將 MBean 注冊(cè)到 MBeanServer mbs.registerMBean(cacheManager, objectName); System.out.println(CacheManager MBean 已注冊(cè)對(duì)象名: objectName); // 保持主線程運(yùn)行模擬一個(gè)長(zhǎng)期運(yùn)行的應(yīng)用 Thread.sleep(Long.MAX_VALUE); } }啟動(dòng)這個(gè)應(yīng)用后打開 JConsole連接到這個(gè) Java 進(jìn)程。在MBeans標(biāo)簽頁(yè)下你會(huì)看到域名com.yourcompany.app展開后找到CacheManager再點(diǎn)擊nameDefaultCache。右側(cè)面板就會(huì)顯示出我們?cè)诮涌谥卸x的所有屬性和操作。你可以直接查看CurrentCacheSize、CacheHitRate也可以修改MaxCacheSize或者點(diǎn)擊clearCache按鈕來調(diào)用操作。實(shí)操心得對(duì)象名的設(shè)計(jì)ObjectName的命名非常重要。好的命名能讓管理界面清晰易懂。建議的格式是域名:type大類名,name具體實(shí)例名。例如對(duì)于數(shù)據(jù)庫(kù)連接池可以用com.yourcompany.app:typeDataSource,nameOrderDB。type和name是慣用的關(guān)鍵屬性你還可以添加其他屬性如componentservice。3.3 標(biāo)準(zhǔn) MBean 的優(yōu)缺點(diǎn)優(yōu)點(diǎn)結(jié)構(gòu)清晰接口與實(shí)現(xiàn)分離符合面向接口編程的原則管理契約明確。工具支持好所有 JMX 客戶端工具都能完美識(shí)別和展示標(biāo)準(zhǔn) MBean。類型安全基于 Java 接口編譯時(shí)就能檢查類型匹配。缺點(diǎn)不夠靈活每增加一個(gè)管理屬性或操作都需要修改接口并重新編譯。命名約束必須嚴(yán)格遵守類名MBean的接口命名規(guī)則略顯死板。元信息有限無(wú)法通過接口為屬性或操作添加描述信息比如在 JConsole 里顯示的說明文字。正因?yàn)檫@些缺點(diǎn)在需要更動(dòng)態(tài)、更靈活管理的場(chǎng)景下動(dòng)態(tài) MBean 和模型 MBean 被引入。但對(duì)于大多數(shù)靜態(tài)的、結(jié)構(gòu)穩(wěn)定的管理需求標(biāo)準(zhǔn) MBean 因其簡(jiǎn)單直觀仍然是首選。4. MXBean解決復(fù)雜類型的“外交官”在使用標(biāo)準(zhǔn) MBean 時(shí)你可能會(huì)遇到一個(gè)棘手的問題如果你的 MBean 方法返回或接收一個(gè)自定義的復(fù)雜對(duì)象比如ListYourBusinessObject或者一個(gè)包含多種字段的Config類客戶端尤其是遠(yuǎn)程客戶端可能無(wú)法正確反序列化它因?yàn)樗赡軟]有這個(gè)自定義類的類定義。這會(huì)引發(fā)java.io.NotSerializableException或類找不到的錯(cuò)誤。MXBean 就是為了解決這個(gè)問題而生的。你可以把 MXBean 看作是一個(gè)“聰明”的 MBean它自帶了一個(gè)“翻譯官”。這個(gè)翻譯官負(fù)責(zé)將復(fù)雜的 Java 類型轉(zhuǎn)換成一組有限的、JMX 客戶端普遍認(rèn)識(shí)的“開放類型”。4.1 開放類型與 MXBean 的轉(zhuǎn)換規(guī)則JMX 定義了一套標(biāo)準(zhǔn)的“開放類型”O(jiān)pen Types如SimpleType對(duì)應(yīng)基本類型和String、CompositeData、TabularData等。MXBean 框架會(huì)自動(dòng)幫你完成轉(zhuǎn)換String,int,boolean等基本類型和其包裝類以及java.util.Date等會(huì)直接映射。一個(gè)包含name(String) 和value(int) 屬性的自定義Config類會(huì)被自動(dòng)轉(zhuǎn)換成CompositeData類型進(jìn)行傳輸。ListConfig會(huì)被轉(zhuǎn)換成TabularData類型進(jìn)行傳輸。這樣遠(yuǎn)程的 JConsole 不需要知道你的Config類具體是什么它只需要知道如何展示標(biāo)準(zhǔn)的CompositeData和TabularData即可。4.2 如何定義一個(gè) MXBean定義 MXBean 和定義標(biāo)準(zhǔn) MBean 非常相似唯一的區(qū)別是接口命名后綴為MXBean。// MXBean 接口 public interface SystemConfigMXBean { // 返回一個(gè)復(fù)雜對(duì)象 CacheConfig getCacheConfig(); void updateCacheConfig(CacheConfig config); // 返回一個(gè)復(fù)雜對(duì)象列表 ListThreadPoolStats getAllThreadPoolStats(); } // 自定義的復(fù)雜類型 - 不需要實(shí)現(xiàn)任何特殊接口 public class CacheConfig { private String name; private int maxSize; private long ttlSeconds; // 存活時(shí)間 // 必須有無(wú)參構(gòu)造函數(shù) public CacheConfig() {} // 以及 getter 和 setter public String getName() { return name; } public void setName(String name) { this.name name; } public int getMaxSize() { return maxSize; } public void setMaxSize(int maxSize) { this.maxSize maxSize; } public long getTtlSeconds() { return ttlSeconds; } public void setTtlSeconds(long ttlSeconds) { this.ttlSeconds ttlSeconds; } } public class ThreadPoolStats { private String poolName; private int activeCount; private long completedTaskCount; // ... getters and setters }實(shí)現(xiàn)類SystemConfig實(shí)現(xiàn)SystemConfigMXBean接口。注冊(cè)方式與標(biāo)準(zhǔn) MBean 完全一樣只是接口名后綴不同。MBeanServer mbs ManagementFactory.getPlatformMBeanServer(); ObjectName name new ObjectName(com.yourcompany.app:typeSystemConfig); SystemConfig mbean new SystemConfig(); mbs.registerMBean(mbean, name);在 JConsole 中查看時(shí)你會(huì)發(fā)現(xiàn)CacheConfig屬性被展開成一個(gè)復(fù)合視圖你可以看到其內(nèi)部的name、maxSize等字段。ListThreadPoolStats則會(huì)顯示為一個(gè)表格。踩坑實(shí)錄MXBean 的序列化限制雖然 MXBean 解決了類定義問題但轉(zhuǎn)換過程有約束。你的自定義類如CacheConfig必須遵循 JavaBean 規(guī)范有無(wú)參構(gòu)造、有 getter/setter。此外嵌套結(jié)構(gòu)不能太深或包含循環(huán)引用否則轉(zhuǎn)換可能失敗。我曾遇到一個(gè)包含MapString, Object的屬性其中Object又是另一個(gè)復(fù)雜類型導(dǎo)致在遠(yuǎn)程連接時(shí)數(shù)據(jù)無(wú)法正確顯示。解決方案是將這個(gè)屬性設(shè)計(jì)得更扁平或者為這個(gè)復(fù)雜類型單獨(dú)實(shí)現(xiàn)一個(gè)CompositeDataView接口來定制轉(zhuǎn)換邏輯。4.3 何時(shí)使用 MXBean需要暴露復(fù)雜數(shù)據(jù)結(jié)構(gòu)給遠(yuǎn)程監(jiān)控端時(shí)優(yōu)先使用 MXBean。你的 MBean 會(huì)被多種不同語(yǔ)言或版本的客戶端訪問時(shí)MXBean 的開放類型提供了更好的兼容性。JDK 自帶的很多管理接口如java.lang.management.MemoryMXBean本身就是 MXBean這足以說明其重要性。簡(jiǎn)單來說對(duì)于大多數(shù)現(xiàn)代應(yīng)用尤其是需要遠(yuǎn)程監(jiān)控的推薦使用 MXBean 代替標(biāo)準(zhǔn) MBean它能避免很多不必要的序列化麻煩。5. 動(dòng)態(tài) MBean 與模型 MBean運(yùn)行時(shí)定義的靈活性標(biāo)準(zhǔn) MBean 和 MXBean 都是“靜態(tài)”的管理接口在編譯期就通過 Java 接口固定了。但有些場(chǎng)景下我們需要管理的資源其接口是動(dòng)態(tài)的或者在運(yùn)行時(shí)才能確定。例如你想為一個(gè)通用的配置管理器創(chuàng)建 MBean它能管理的配置項(xiàng)在應(yīng)用啟動(dòng)時(shí)從數(shù)據(jù)庫(kù)加載每個(gè)配置項(xiàng)都是一個(gè)屬性。這時(shí)就需要?jiǎng)討B(tài) MBean和模型 MBean。5.1 動(dòng)態(tài) MBean完全編程式控制動(dòng)態(tài) MBean 通過實(shí)現(xiàn)javax.management.DynamicMBean接口來工作。這個(gè)接口要求你手動(dòng)實(shí)現(xiàn)所有管理邏輯public interface DynamicMBean { // 獲取某個(gè)屬性的值 Object getAttribute(String attribute); // 設(shè)置某個(gè)屬性的值 void setAttribute(Attribute attribute); // 獲取多個(gè)屬性的值 AttributeList getAttributes(String[] attributes); // 設(shè)置多個(gè)屬性的值 AttributeList setAttributes(AttributeList attributes); // 調(diào)用一個(gè)操作 Object invoke(String actionName, Object[] params, String[] signature); // 返回此 MBean 的元數(shù)據(jù)描述這是關(guān)鍵 MBeanInfo getMBeanInfo(); }核心在于getMBeanInfo()方法。你需要在這個(gè)方法中返回一個(gè)MBeanInfo對(duì)象這個(gè)對(duì)象完整描述了你的 MBean 有哪些屬性、操作和通知。這意味著你可以在運(yùn)行時(shí)動(dòng)態(tài)地構(gòu)建這個(gè)描述信息。下面是一個(gè)極簡(jiǎn)的動(dòng)態(tài) MBean 示例它暴露一個(gè)可動(dòng)態(tài)管理的配置 Mappublic class DynamicConfigMBean implements DynamicMBean { private MapString, String configStore new ConcurrentHashMap(); private final MBeanInfo mBeanInfo; public DynamicConfigMBean() { // 1. 動(dòng)態(tài)構(gòu)建屬性描述 MBeanAttributeInfo[] attributes new MBeanAttributeInfo[1]; // 這里我們只定義一個(gè)名為“config”的 Map 類型屬性實(shí)際中會(huì)更復(fù)雜 attributes[0] new MBeanAttributeInfo( config, // 屬性名 java.util.Map, // 屬性類型 Dynamic configuration store, // 描述 true, // 可讀 true, // 可寫 false // 不是 isGetter ); // 2. 動(dòng)態(tài)構(gòu)建操作描述一個(gè) reload 操作 MBeanOperationInfo[] operations new MBeanOperationInfo[1]; operations[0] new MBeanOperationInfo( reloadFromDB, // 操作名 Reload all configurations from database, // 描述 null, // 無(wú)參數(shù) void, // 返回類型 MBeanOperationInfo.ACTION // 操作類型 ); // 3. 組裝 MBeanInfo mBeanInfo new MBeanInfo( this.getClass().getName(), Dynamic Configuration MBean, attributes, null, // 無(wú)構(gòu)造器 operations, null // 無(wú)通知 ); } Override public MBeanInfo getMBeanInfo() { return mBeanInfo; } Override public Object getAttribute(String attribute) { if (config.equals(attribute)) { return new HashMap(configStore); // 返回副本 } throw new AttributeNotFoundException(Attribute not found: attribute); } Override public void setAttribute(Attribute attribute) { if (config.equals(attribute.getName())) { if (attribute.getValue() instanceof Map) { configStore.clear(); configStore.putAll((Map? extends String, ? extends String) attribute.getValue()); } else { throw new InvalidAttributeValueException(Value must be a Map); } } else { throw new AttributeNotFoundException(Attribute not found: attribute.getName()); } } Override public Object invoke(String actionName, Object[] params, String[] signature) { if (reloadFromDB.equals(actionName)) { // 模擬從數(shù)據(jù)庫(kù)加載 configStore.put(keyFromDB, valueLoadedAt System.currentTimeMillis()); return null; } throw new ReflectionException(new NoSuchMethodException(actionName)); } // ... 其他方法實(shí)現(xiàn)getAttributes, setAttributes通常有通用模板此處略 }注冊(cè)和使用方式與之前類似。在 JConsole 中你會(huì)看到一個(gè)名為config的屬性雖然顯示和編輯一個(gè) Map 在 JConsole 里不太方便以及一個(gè)reloadFromDB按鈕。5.2 模型 MBeanRequiredModelMBean 的便利性動(dòng)態(tài) MBean 需要自己實(shí)現(xiàn)所有細(xì)節(jié)比較繁瑣。而模型 MBean提供了一個(gè)現(xiàn)成的、功能更強(qiáng)大的實(shí)現(xiàn)類javax.management.modelmbean.RequiredModelMBean。RequiredModelMBean本身就是一個(gè)DynamicMBean但它將管理信息屬性、操作、通知的描述與被管理的目標(biāo)資源對(duì)象分離開來。你可以將一個(gè)普通的 Java 對(duì)象POJO作為“資源”掛載到它上面然后通過元數(shù)據(jù)來描述如何管理這個(gè)資源。import javax.management.modelmbean.*; public class ModelMBeanDemo { public static void main(String[] args) throws Exception { MBeanServer mbs ManagementFactory.getPlatformMBeanServer(); ObjectName name new ObjectName(com.yourcompany.app:typeModelExample); // 1. 創(chuàng)建目標(biāo)資源一個(gè)普通的POJO MyManagedResource resource new MyManagedResource(); // 2. 創(chuàng)建 RequiredModelMBean RequiredModelMBean modelMBean new RequiredModelMBean(); // 3. 設(shè)置模型 MBean 的管理信息 ModelMBeanInfo info createMBeanInfo(); modelMBean.setModelMBeanInfo(info); // 4. 將資源對(duì)象設(shè)置為模型 MBean 的管理目標(biāo) modelMBean.setManagedResource(resource, ObjectReference); // 5. 注冊(cè) mbs.registerMBean(modelMBean, name); } static class MyManagedResource { private String status RUNNING; public String getStatus() { return status; } public void setStatus(String s) { status s; } public void doTask() { System.out.println(Task executed.); } } static ModelMBeanInfo createMBeanInfo() throws Exception { // 創(chuàng)建屬性描述 ModelMBeanAttributeInfo statusAttr new ModelMBeanAttributeInfo( Status, java.lang.String, Current status of the resource, true, // readable true, // writable false // not a boolean ); // 創(chuàng)建操作描述 ModelMBeanOperationInfo taskOp new ModelMBeanOperationInfo( Execute Task, Execute the main task, null, // no parameters void, ModelMBeanOperationInfo.ACTION ); // 組裝信息 ModelMBeanInfoSupport info new ModelMBeanInfoSupport( MyManagedResource.class.getName(), Example Model MBean, new ModelMBeanAttributeInfo[]{statusAttr}, null, // constructors new ModelMBeanOperationInfo[]{taskOp}, null // notifications ); return info; } }RequiredModelMBean的強(qiáng)大之處在于它支持更豐富的元數(shù)據(jù)比如可以為屬性設(shè)置默認(rèn)值、合法性檢查、持久化存儲(chǔ)甚至可以定義“獲取器方法”和“設(shè)置器方法”的名稱從而將 MBean 的屬性映射到資源對(duì)象的不同方法上。5.3 動(dòng)態(tài)/模型 MBean 的應(yīng)用場(chǎng)景與選擇動(dòng)態(tài) MBean當(dāng)你需要最高級(jí)別的靈活性管理接口完全由運(yùn)行時(shí)數(shù)據(jù)驅(qū)動(dòng)時(shí)使用。例如管理一個(gè)插件系統(tǒng)每個(gè)插件注冊(cè)時(shí)都向一個(gè)統(tǒng)一的動(dòng)態(tài) MBean 添加屬性和操作。模型 MBean當(dāng)你需要將管理能力“附加”到一個(gè)已有的、未按照 MBean 規(guī)范設(shè)計(jì)的類上時(shí)RequiredModelMBean是很好的選擇。它也常用于需要聲明式管理如通過 XML 文件定義 MBean 信息的場(chǎng)景。不過在常規(guī)業(yè)務(wù)開發(fā)中標(biāo)準(zhǔn) MBean 和 MXBean 已經(jīng)覆蓋了 90% 的需求。動(dòng)態(tài)和模型 MBean 更多用于框架或底層基礎(chǔ)設(shè)施的開發(fā)。6. MBeanServer注冊(cè)中心與運(yùn)行時(shí)樞紐前面我們多次提到MBeanServer并簡(jiǎn)單地通過ManagementFactory.getPlatformMBeanServer()獲取它。現(xiàn)在我們來深入看看這個(gè) JMX 體系的核心樞紐。6.1 MBeanServer 的獲取與層次在一個(gè) JVM 中可以存在多個(gè) MBeanServer但通常我們只與平臺(tái) MBeanServer打交道。它是 JVM 內(nèi)置的、全局共享的單例。MBeanServer mbs ManagementFactory.getPlatformMBeanServer();這個(gè)mbs就是我們注冊(cè)和查找 MBean 的主要入口。所有 JDK 內(nèi)置的 MXBean如MemoryMXBean,ThreadMXBean也都注冊(cè)在這個(gè)服務(wù)器上。6.2 核心操作注冊(cè)、查詢與調(diào)用注冊(cè) MBean我們已經(jīng)很熟悉了。MyMBean mbean new MyMBean(); ObjectName name new ObjectName(com.example:typeMyType,nameinstance1); mbs.registerMBean(mbean, name);查詢 MBean這是監(jiān)控系統(tǒng)自動(dòng)發(fā)現(xiàn) MBean 的基礎(chǔ)。// 查詢所有 MBean SetObjectName allNames mbs.queryNames(null, null); // 查詢指定域和類型的 MBean ObjectName pattern new ObjectName(com.example:typeMyType,*); SetObjectName myTypeBeans mbs.queryNames(pattern, null); // 獲取特定的 MBean 實(shí)例注意返回的是動(dòng)態(tài)代理不是原對(duì)象 MyMBean proxy JMX.newMBeanProxy(mbs, name, MyMBean.class); int value proxy.getSomeAttribute();調(diào)用操作與訪問屬性 除了通過代理也可以直接使用MBeanServer的方法。// 獲取屬性 Object attribute mbs.getAttribute(name, CacheHitRate); // 設(shè)置屬性 Attribute attr new Attribute(MaxCacheSize, 2000); mbs.setAttribute(name, attr); // 調(diào)用操作 Object result mbs.invoke(name, clearCache, null, null); // 無(wú)參數(shù)操作6.3 通知機(jī)制讓 MBean 主動(dòng)“說話”MBean 不僅可以被動(dòng)地響應(yīng)查詢和調(diào)用還可以主動(dòng)發(fā)出事件這就是通知。典型的應(yīng)用場(chǎng)景包括配置變更、閾值告警、狀態(tài)遷移。要讓一個(gè) MBean 支持通知它需要實(shí)現(xiàn)javax.management.NotificationBroadcaster接口或繼承NotificationBroadcasterSupport類。import javax.management.*; public class AlertingCacheManager extends CacheManager implements NotificationBroadcaster { private final NotificationBroadcasterSupport broadcaster new NotificationBroadcasterSupport(); private double warningThreshold 0.8; // 使用率警告閾值 Override public void setMaxCacheSize(int size) { int oldSize getMaxCacheSize(); super.setMaxCacheSize(size); // 當(dāng)容量調(diào)低時(shí)發(fā)出通知 if (size oldSize) { Notification notif new Notification( cache.size.reduced, // 通知類型 this, // 通知源 System.currentTimeMillis(), // 序列號(hào)時(shí)間戳 String.format(Cache max size reduced from %d to %d, oldSize, size) ); // 可以設(shè)置用戶數(shù)據(jù) notif.setUserData(new int[]{oldSize, size}); broadcaster.sendNotification(notif); } } // 一個(gè)模擬方法檢查使用率并可能發(fā)出警告 public void checkUsage() { double usage (double) getCurrentCacheSize() / getMaxCacheSize(); if (usage warningThreshold) { Notification notif new Notification( cache.usage.high, this, System.currentTimeMillis(), String.format(Cache usage is high: %.1f%%, usage * 100) ); notif.setUserData(usage); broadcaster.sendNotification(notif); } } // 實(shí)現(xiàn) NotificationBroadcaster 接口的方法 Override public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) { broadcaster.addNotificationListener(listener, filter, handback); } Override public void removeNotificationListener(NotificationListener listener) { broadcaster.removeNotificationListener(listener); } Override public MBeanNotificationInfo[] getNotificationInfo() { // 描述此 MBean 會(huì)發(fā)出哪些類型的通知 String[] types {cache.size.reduced, cache.usage.high}; String description Notifications for cache management events; MBeanNotificationInfo info new MBeanNotificationInfo(types, Notification.class.getName(), description); return new MBeanNotificationInfo[]{info}; } }在客戶端可以注冊(cè)一個(gè)NotificationListener來監(jiān)聽這些事件。在 JConsole 中你可以在 MBean 的選項(xiàng)卡里看到“通知”子節(jié)點(diǎn)并可以訂閱它們。6.4 MBeanServer 在架構(gòu)中的意義MBeanServer是 JMX 代理層的核心。它解耦了管理請(qǐng)求的發(fā)起者客戶端和管理資源的實(shí)現(xiàn)者M(jìn)Bean。這種設(shè)計(jì)帶來了巨大的好處集中管理所有管理功能通過一個(gè)統(tǒng)一的入口進(jìn)行。安全性可以在MBeanServer層面實(shí)現(xiàn)訪問控制。協(xié)議無(wú)關(guān)性無(wú)論是通過 RMI、JMXMP 還是進(jìn)程內(nèi)調(diào)用最終都轉(zhuǎn)化為對(duì)MBeanServer的調(diào)用。動(dòng)態(tài)性MBean 可以在運(yùn)行時(shí)注冊(cè)和注銷實(shí)現(xiàn)了系統(tǒng)的動(dòng)態(tài)擴(kuò)展。理解MBeanServer你就理解了 JMX 內(nèi)部通信的橋梁。7. 實(shí)戰(zhàn)將 Spring Boot Actuator 端點(diǎn)暴露為 MBean在現(xiàn)代 Spring Boot 應(yīng)用中我們經(jīng)常使用 Actuator 來暴露健康檢查、指標(biāo)等信息通常通過 HTTP 端點(diǎn)訪問。但有時(shí)我們可能希望將這些信息也集成到統(tǒng)一的 JMX 監(jiān)控體系中。Spring Boot 對(duì)此提供了良好的支持。7.1 默認(rèn)的 JMX 暴露在 Spring Boot 項(xiàng)目中只需添加spring-boot-starter-actuator依賴并在application.properties中配置許多端點(diǎn)會(huì)自動(dòng)作為 MBean 暴露。# application.yml management: endpoints: jmx: exposure: include: * # 暴露所有端點(diǎn)生產(chǎn)環(huán)境應(yīng)謹(jǐn)慎 web: exposure: include: health,info,metrics # HTTP暴露部分端點(diǎn) endpoint: health: show-details: always啟動(dòng)應(yīng)用后連接 JConsole你會(huì)發(fā)現(xiàn)多了一個(gè)org.springframework.boot域下面有Endpoint類型。例如Health端點(diǎn)對(duì)應(yīng)的 MBean 對(duì)象名可能是org.springframework.boot:typeEndpoint,nameHealth。你可以通過 JMX 操作來獲取健康狀態(tài)。7.2 自定義 MBean 與 Spring 集成更常見的是我們想將自己業(yè)務(wù)組件的管理接口暴露為 MBean。Spring 讓這一切變得非常簡(jiǎn)單——只需要將你的類標(biāo)注為Component同時(shí)實(shí)現(xiàn)一個(gè)以MBean或MXBean結(jié)尾的接口。// 1. 定義 MXBean 接口 public interface OrderServiceMetricsMXBean { long getTotalOrdersProcessed(); double getOrdersPerMinute(); MapString, Integer getOrdersByStatus(); void resetStatistics(); } // 2. 實(shí)現(xiàn)業(yè)務(wù)邏輯和 MXBean 接口 Component // 讓 Spring 管理 ManagedResource(objectName com.yourcompany.app:typeMetrics,nameOrderService, description Order Service Performance Metrics) public class OrderService implements OrderServiceMXBean { private final AtomicLong totalOrders new AtomicLong(0); private final MapString, Integer statusCount new ConcurrentHashMap(); private long startTime System.currentTimeMillis(); Override public long getTotalOrdersProcessed() { return totalOrders.get(); } Override public double getOrdersPerMinute() { long minutes (System.currentTimeMillis() - startTime) / (1000 * 60); return minutes 0 ? (double) totalOrders.get() / minutes : 0.0; } Override public MapString, Integer getOrdersByStatus() { return new HashMap(statusCount); } Override public void resetStatistics() { totalOrders.set(0); statusCount.clear(); startTime System.currentTimeMillis(); } // 業(yè)務(wù)方法 public void processOrder(Order order) { // ... 業(yè)務(wù)處理邏輯 totalOrders.incrementAndGet(); statusCount.merge(order.getStatus(), 1, Integer::sum); } }關(guān)鍵點(diǎn)在于ManagedResource注解它指定了注冊(cè)到 MBeanServer 時(shí)使用的ObjectName。Spring 在應(yīng)用啟動(dòng)后會(huì)自動(dòng)檢測(cè)到實(shí)現(xiàn)了*MBean或*MXBean接口的Component并將其注冊(cè)到平臺(tái) MBeanServer 中。7.3 暴露自定義指標(biāo)結(jié)合 Spring Boot Actuator 的MeterRegistry我們可以輕松地將 Micrometer 指標(biāo)也通過 JMX 暴露。Component public class CustomMetricsExporter { private final MeterRegistry meterRegistry; public CustomMetricsExporter(MeterRegistry meterRegistry) { this.meterRegistry meterRegistry; } PostConstruct public void init() { // 創(chuàng)建一個(gè)自定義的計(jì)數(shù)器它也會(huì)通過Actuator的/metrics端點(diǎn)和JMX暴露 Counter.builder(app.orders.created) .description(Total number of orders created) .tag(region, cn-east-1) .register(meterRegistry); } }配置management.endpoints.jmx.exposure.includemetrics后這個(gè)app.orders.created計(jì)數(shù)器就會(huì)作為一個(gè) MBean 屬性出現(xiàn)你可以通過 JMX 工具監(jiān)控它。集成經(jīng)驗(yàn)對(duì)象名沖突與安全當(dāng) Spring 自動(dòng)注冊(cè) MBean 時(shí)務(wù)必確保ManagedResource中的objectName是唯一的否則會(huì)導(dǎo)致注冊(cè)失敗。在生產(chǎn)環(huán)境不要通過 JMX 暴露所有端點(diǎn)或允許匿名遠(yuǎn)程連接。務(wù)必配置 JMX 的認(rèn)證和 SSL。在application.properties中可以設(shè)置spring.jmx.enabledfalse來完全禁用 JMX或者通過java.rmi.server.hostname和com.sun.management.jmxremote.*系列系統(tǒng)屬性進(jìn)行細(xì)粒度控制。通過 Spring Boot 的集成我們可以用最少的代碼將應(yīng)用的管理和監(jiān)控能力無(wú)縫接入 JMX 生態(tài)讓運(yùn)維同學(xué)在熟悉的 JConsole 或公司統(tǒng)一的 JMX 采集平臺(tái)中看到我們應(yīng)用的核心狀態(tài)。