JVM 默認(rèn)會通過 JMX 的方式暴露基礎(chǔ)指標(biāo)，很多中間件也會通過 JMX 的方式暴露業(yè)務(wù)指標(biāo)，比如 Kafka、Zookeeper、ActiveMQ、Cassandra、Spark、Tomcat、Flink 等等。掌握了 JMX 監(jiān)控方式，就掌握了一批程序的監(jiān)控方式。本節(jié)介紹 JMX-Exporter 的使用，利用 JMX-Exporter 把 JMX 監(jiān)控?cái)?shù)據(jù)暴露為 Prometheus 可識別的格式。

JMX

JMX（Java Management Extensions）是 Java 管理擴(kuò)展的簡稱，是一種為 Java 應(yīng)用程序植入管理功能的框架。Java 類程序經(jīng)常使用 JMX 暴露監(jiān)控指標(biāo)數(shù)據(jù)，也可以通過 JMX 來控制 Java 類程序，典型的比如通過 JMX 觸發(fā)程序 GC。

Java 程序里，某個類如果實(shí)現(xiàn)了 MBean 接口，那么這個類就可以通過 JMX 來讀取和修改這個類的屬性，也可以調(diào)用這個類的方法。JMX 通過 MBeanServer 來管理 MBean，MBeanServer 是一個管理器，它可以管理多個 MBean，每個 MBean 都有一個 ObjectName，用來唯一標(biāo)識這個 MBean。

更新信息可以參考 JMX Specification。非本文重點(diǎn)。

JMX-Exporter 簡介

JMX-Exporter 是 Prometheus 社區(qū)提供的一個工具，用來把 JMX 暴露的監(jiān)控指標(biāo)數(shù)據(jù)轉(zhuǎn)換為 Prometheus 可識別的格式。JMX-Exporter 通過 HTTP 服務(wù)的方式暴露監(jiān)控指標(biāo)數(shù)據(jù)，Prometheus 通過 HTTP 協(xié)議來拉取監(jiān)控指標(biāo)數(shù)據(jù)。

JMX-Exporter 就是個 jar 包，以 javaagent（何為 javaagent，需要讀者自行 Google） 的方式運(yùn)行，和業(yè)務(wù) Java（或 Scala） 程序運(yùn)行在一個 JVM 虛擬機(jī)里。有了 JMX-Exporter，業(yè)務(wù)程序無需暴露 JMX 端口了，JMX-Exporter 會把 JMX 暴露的監(jiān)控指標(biāo)數(shù)據(jù)轉(zhuǎn)換為 Prometheus 可識別的格式，然后通過 HTTP 只讀方式暴露出去，也更為安全。

JMX-Exporter 安裝

因?yàn)?JMX-Exporter 是個 jar 包，所以安裝非常簡單，只需要把 jar 包下載到服務(wù)器上就可以了。JMX-Exporter 的下載地址是 https://repo1.maven.org/maven2/io/prometheus/jmx/jmx_prometheus_javaagent/，下載最新版本的 jar 包即可。

比如我們把下載的 jar 包放在 /opt/jmx-exporter 目錄，另外，建立 /etc/jmx-exporter 目錄放置 JMX-Exporter 所需配置文件。像 Kafka，暴露的 JMX 指標(biāo)非常非常多，我們不需要全部采集，只需要采集我們關(guān)心的指標(biāo)即可。所以，我們需要配置文件來告訴 JMX-Exporter，我們需要采集哪些指標(biāo)。

JMX-Exporter 提供了很多樣例配置，地址在這里：https://github.com/prometheus/jmx_exporter/tree/main/example_configs。

使用 JMX 監(jiān)控 Zookeeper

實(shí)際上，新版 Zookeeper 已經(jīng)直接暴露了 Prometheus 協(xié)議的監(jiān)控?cái)?shù)據(jù)，無需通過 JMX 方式采集了。另外，Zookeeper 還提供了四字命令的監(jiān)控?cái)?shù)據(jù)采集方式，比如 Categraf 的 input.zookeeper 插件就是采用的這種方式。

不過，本文主要是演示 JMX 的方式，所以還是使用 JMX 的方式來采集 Zookeeper 的監(jiān)控?cái)?shù)據(jù)。

首先，從 https://github.com/prometheus/jmx_exporter/tree/main/example_configs 這里找到 Zookeeper 的配置樣例文件，下載到 /etc/jmx-exporter/zookeeper.yml。然后把 jmx-exporter 的 jar 包作為 javaagent 啟動參數(shù)加入 Zookeeper 的啟動命令即可。

# zookeeper-env.sh
SERVER_JVMFLAGS="-javaagent:/opt/jmx-exporter/jmx-exporter.jar=7070:/etc/jmx-exporter/zookeeper.yml"

Zookeeper 有個 zookeeper-env.sh 控制 Zookeeper 的啟動參數(shù)，我們在這里加入 javaagent 啟動參數(shù)，然后重啟 Zookeeper 即可。上例是把 JMX-Exporter 的 HTTP 服務(wù)端口設(shè)置為 7070，可以根據(jù)實(shí)際情況修改，配置文件指定為 /etc/jmx-exporter/zookeeper.yml。

OK，現(xiàn)在可以測試了，先看 7070 端口是否在監(jiān)聽，如果在監(jiān)聽，就可以請求這個端口的 /metrics 接口采集 Prometheus 協(xié)議的監(jiān)控?cái)?shù)據(jù)了。

$ netstat -tlnp | grep 7070
tcp        0      0 0.0.0.0:7070            0.0.0.0:*               LISTEN      892/java

$ curl -s localhost:7070/metrics | head
# HELP jvm_threads_current Current thread count of a JVM
# TYPE jvm_threads_current gauge
jvm_threads_current 16.0
# HELP jvm_threads_daemon Daemon thread count of a JVM
# TYPE jvm_threads_daemon gauge
jvm_threads_daemon 12.0
# HELP jvm_threads_peak Peak thread count of a JVM
# TYPE jvm_threads_peak gauge
jvm_threads_peak 16.0
# HELP jvm_threads_started_total Started thread count of a JVM

可以看到，Zookeeper 的監(jiān)控?cái)?shù)據(jù)已經(jīng)暴露出來了，接下來就可以采集這些數(shù)據(jù)了，抓取 Prometheus 協(xié)議的監(jiān)控?cái)?shù)據(jù)有很多方式，可以直接使用 Prometheus 自身來抓取，也可以通過 Categraf 的 input.prometheus 插件來抓取，也可以通過 vmagent 來抓取，大家自行決策即可。

使用 JMX 監(jiān)控 Kafka

從 JMX-Exporter 提供的樣例配置目錄，下載 kafka.yml，然后導(dǎo)出 KAFKA_OPTS 環(huán)境變量即可。

$ export KAFKA_OPTS='-javaagent:/opt/jmx-exporter/jmx-exporter.jar=7071:/etc/jmx-exporter/kafka.yml'
$ /opt/kafka_2.11-0.10.1.0/bin/kafka-server-start.sh /opt/kafka_2.11-0.10.1.0/conf/server.properties

上例中，我們把端口換成了7071，配置文件指定為 /etc/jmx-exporter/kafka.yml。測試一下端口是否成功監(jiān)聽：

$ netstap -tlnp | grep 7071
tcp6       0      0 :::7071                 :::*                    LISTEN      19288/java

$ curl -s localhost:7071 | grep -i kafka | head
# HELP kafka_server_replicafetchermanager_minfetchrate Attribute exposed for management (kafka.server<type=ReplicaFetcherManager, name=MinFetchRate, clientId=Replica><>Value)
# TYPE kafka_server_replicafetchermanager_minfetchrate untyped
kafka_server_replicafetchermanager_minfetchrate{clientId="Replica",} 0.0
# HELP kafka_network_requestmetrics_totaltimems Attribute exposed for management (kafka.network<type=RequestMetrics, name=TotalTimeMs, request=OffsetFetch><>Count)
# TYPE kafka_network_requestmetrics_totaltimems untyped
kafka_network_requestmetrics_totaltimems{request="OffsetFetch",} 0.0
kafka_network_requestmetrics_totaltimems{request="JoinGroup",} 0.0
kafka_network_requestmetrics_totaltimems{request="DescribeGroups",} 0.0
kafka_network_requestmetrics_totaltimems{request="LeaveGroup",} 0.0
kafka_network_requestmetrics_totaltimems{request="GroupCoordinator",} 0.0

一切正常哈，如果你的 Kafka 是通過 systemd 運(yùn)行的，可以類似下面的方式來配置 kafka.service 文件：

...
[Service]
Restart=on-failure
Environment=KAFKA_OPTS=-javaagent:/opt/jmx-exporter/jmx-exporter.jar=7071:/etc/jmx-exporter/kafka.yml
ExecStart=/opt/kafka/bin/kafka-server-start.sh /etc/kafka/server.properties
ExecStop=/opt/kafka/bin/kafka-server-stop.sh
TimeoutStopSec=600
User=kafka
...

加餐

使用 jmx-exporter jar 包的時(shí)候，會引用一個配置文件，不同的 Java 應(yīng)用可能會通過 jmx 的方式暴露特別多的監(jiān)控指標(biāo)，顯然，我們不需要采集所有，具體要采集哪些指標(biāo)，就是靠 jmx-exporter jar 包引用的那個配置文件決定的。我們來看一下 /etc/jmx-exporter/zookeeper.yml 的內(nèi)容：

rules:
  # replicated Zookeeper
  - pattern: "org.apache.ZooKeeperService<name0=ReplicatedServer_id(\\d+)><>(\\w+)"
    name: "zookeeper_$2"
    type: GAUGE
  - pattern: "org.apache.ZooKeeperService<name0=ReplicatedServer_id(\\d+), name1=replica.(\\d+)><>(\\w+)"
    name: "zookeeper_$3"
    type: GAUGE
    labels:
      replicaId: "$2"
  - pattern: "org.apache.ZooKeeperService<name0=ReplicatedServer_id(\\d+), name1=replica.(\\d+), name2=(\\w+)><>(Packets\\w+)"
    name: "zookeeper_$4"
    type: COUNTER
    labels:
      replicaId: "$2"
      memberType: "$3"
  - pattern: "org.apache.ZooKeeperService<name0=ReplicatedServer_id(\\d+), name1=replica.(\\d+), name2=(\\w+)><>(\\w+)"
    name: "zookeeper_$4"
    type: GAUGE
    labels:
      replicaId: "$2"
      memberType: "$3"
  - pattern: "org.apache.ZooKeeperService<name0=ReplicatedServer_id(\\d+), name1=replica.(\\d+), name2=(\\w+), name3=(\\w+)><>(\\w+)"
    name: "zookeeper_$4_$5"
    type: GAUGE
    labels:
      replicaId: "$2"
      memberType: "$3"
  # standalone Zookeeper
  - pattern: "org.apache.ZooKeeperService<name0=StandaloneServer_port(\\d+)><>(\\w+)"
    type: GAUGE
    name: "zookeeper_$2"
  - pattern: "org.apache.ZooKeeperService<name0=StandaloneServer_port(\\d+), name1=InMemoryDataTree><>(\\w+)"
    type: GAUGE
    name: "zookeeper_$2"

這個配置文件里定義了一堆 rules，每個 rule 由四部分組成：pattern、name、type、labels，其中 pattern 是一個正則表達(dá)式，用來匹配 MBean 的 object name（什么是 MBean，什么是 object name 可以自行 Google，這里暫不展開），如果匹配到了就采集對應(yīng)的 MBean 的數(shù)據(jù)，否則就不采集。type 是指定了數(shù)據(jù)類型，labels 是指定了標(biāo)簽，標(biāo)簽值是來自 pattern 中提取到的正則數(shù)據(jù)。

所以，jmx 監(jiān)控?cái)?shù)據(jù)采集的關(guān)鍵點(diǎn)，其實(shí)是這個 rules 的最佳實(shí)踐，也就是說，對于某個 Java 應(yīng)用，你具體要采集哪些指標(biāo)，這是真經(jīng)驗(yàn)，真正有價(jià)值的東西。

文章主要翻譯了 https://alex.dzyoba.com/blog/jmx-exporter/ 并加入了一些個人理解。enjoy…make a better world :)