使用JMX监控Zookeeper状态Java API-eolink官网

使用JMX监控Zookeeper状态Java API

一、背景

上一篇通过java自带的JConsole来获取zookeeper状态。主要有几个不方便的地方，zk集群一般会部署3或者5台，在多个JConsole窗口中切换比较麻烦，各个zk服务及历史数据之间，不能直观比较。一般会做一个WEB管理页面来展示集群状态，设置报警阀值来做报警。

二、JVM平台提供Mbeans

在Java5.0以上版本，有一组API可以让Java应用程序和允许的工具监视和管理Java虚拟机（JVM）和虚拟机所在的本机操作系统。该组API在 java.lang.management包。可以通过这些API可以监控local端JVM，同时也可以监控远端JVM。

通过静态工厂方法获取MXBean实例，从本地访问正在运行的虚拟机的MXBean接口。这些Bean我们从ManagementFactory类中定义的静态方法获取；如ManagementFactory.getOperatingSystemMXBean();其中不足就是只能获取本地的JVM状态。无法获取远程的虚拟机数据。

ClassLoadingMXBean Java虚拟机的类加载系统

CompilationMXBean Java虚拟机的编译系统

MemoryMXBean Java虚拟机的内存系统

RuntimeMXBean Java虚拟机的运行时系统

OperatingSystemMXBean Java虚拟机在其上运行的操作系统

GarbageCollectorMXBean Java虚拟机中的垃圾回收器

MemoryManagerMXBean Java虚拟机中的内存管理器

MemoryPoolMXBean Java虚拟机中的内存池

三、Zookeeper提供出来的Mbeans

构造MXBean代理实例，通过代理将方法调用转发到给定的MBeanServe。JConsole能够监控的项目，通过API都能获取到。

具体代码如下：

import java.io.IOException;

import java.lang.management.ClassLoadingMXBean;

import java.lang.management.CompilationMXBean;

import java.lang.management.ManagementFactory;

import java.lang.management.OperatingSystemMXBean;

import java.lang.management.ThreadMXBean;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Collections;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import java.util.Set;

import javax.management.InstanceNotFoundException;

import javax.management.IntrospectionException;

import javax.management.JMX;

import javax.management.MBeanServerConnection;

import javax.management.MalformedObjectNameException;

import javax.management.ObjectName;

import javax.management.ReflectionException;

import javax.management.remote.JMXConnector;

import javax.management.remote.JMXConnectorFactory;

import javax.management.remote.JMXServiceURL;

import org.apache.zookeeper.server.ConnectionMXBean;

import org.apache.zookeeper.server.DataTreeMXBean;

import org.apache.zookeeper.server.ZooKeeperServerMXBean;

public class ZkJMXTest {

static JMXConnector connector;

/**

* @param args

* @throws IOException

* @throws MalformedObjectNameException

* @throws InstanceNotFoundException

* @throws ReflectionException

* @throws IntrospectionException

public static void main(String[] args) throws IOException, MalformedObjectNameException,

InstanceNotFoundException, IntrospectionException, ReflectionException {

OperatingSystemMXBean osbean = ManagementFactory.getOperatingSystemMXBean();

System.out.println("体系结构:" + osbean.getArch());//操作系统体系结构

System.out.println("处理器核数:" + osbean.getAvailableProcessors());///核数

System.out.println("名字:" + osbean.getName());//名字

System.out.println(osbean.getVersion());//操作系统版本

ThreadMXBean threadBean=ManagementFactory.getThreadMXBean();

System.out.println("活动线程:" + threadBean.getThreadCount());//总线程数

ClassLoadingMXBean classLoadingMXBean = ManagementFactory.getClassLoadingMXBean();

CompilationMXBean compilationMXBean = ManagementFactory.getCompilationMXBean();

System.out.println("===========");

// 通过 MBeanServer间接地访问 MXBean 接口

MBeanServerConnection mbsc = createMBeanServer("192.168.1.100", "9991", "controlRole", "123456");

// 操作系统

ObjectName os = new ObjectName("java.lang:type=OperatingSystem");

System.out.println("体系结构:" + getAttribute(mbsc, os, "Arch"));//体系结构

System.out.println("处理器核数:" + getAttribute(mbsc, os, "AvailableProcessors"));//核数

System.out.println("总物理内存:" + getAttribute(mbsc, os, "TotalPhysicalMemorySize"));//总物理内存

System.out.println("空闲物理内存:" + getAttribute(mbsc, os, "FreePhysicalMemorySize"));//空闲物理内存

System.out.println("总交换空间:" + getAttribute(mbsc, os, "TotalSwapSpaceSize"));//总交换空间

System.out.println("空闲交换空间:" + getAttribute(mbsc, os, "FreeSwapSpaceSize"));//空闲交换空间

System.out.println("操作系统:" + getAttribute(mbsc, os, "Name")+ getAttribute(mbsc, os, "Version"));//操作系统

System.out.println("提交的虚拟内存:" + getAttribute(mbsc, os, "CommittedVirtualMemorySize"));//提交的虚拟内存

System.out.println("系统cpu使用率:" + getAttribute(mbsc, os, "SystemCpuLoad"));//系统cpu使用率

System.out.println("进程cpu使用率:" + getAttribute(mbsc, os, "ProcessCpuLoad"));//进程cpu使用率

System.out.println("============");//

// 线程

ObjectName Threading = new ObjectName("java.lang:type=Threading");

System.out.println("活动线程:" + getAttribute(mbsc, Threading, "ThreadCount"));// 活动线程

System.out.println("守护程序线程:" + getAttribute(mbsc, Threading, "DaemonThreadCount"));// 守护程序线程

System.out.println("峰值:" + getAttribute(mbsc, Threading, "PeakThreadCount"));// 峰值

System.out.println("启动的线程总数:" + getAttribute(mbsc, Threading, "TotalStartedThreadCount"));// 启动的线程总数

ThreadMXBean threadBean2 = ManagementFactory.newPlatformMXBeanProxy

(mbsc, ManagementFactory.THREAD_MXBEAN_NAME, ThreadMXBean.class);

System.out.println("活动线程:" + threadBean2.getThreadCount());// 活动线程

ThreadMXBean threadBean3 = ManagementFactory.getThreadMXBean();

System.out.println("本地活动线程:" + threadBean3.getThreadCount());// 本地活动线程

System.out.println("============");//

ObjectName Compilation = new ObjectName("java.lang:type=Compilation");

System.out.println("总编译时间毫秒:" + getAttribute(mbsc, Compilation, "TotalCompilationTime"));// 总编译时间毫秒

System.out.println("============");//

ObjectName ClassLoading = new ObjectName("java.lang:type=ClassLoading");

System.out.println("已加载类总数:" + getAttribute(mbsc, ClassLoading, "TotalLoadedClassCount"));// 已加载类总数

System.out.println("已加装当前类:" + getAttribute(mbsc, ClassLoading, "LoadedClassCount"));// 已加装当前类

System.out.println("已卸载类总数:" + getAttribute(mbsc, ClassLoading, "UnloadedClassCount"));// 已卸载类总数

System.out.println("==========================================================");//

// http://zookeeper.apache.org/doc/r3.4.6/zookeeperJMX.html

// org.apache.ZooKeeperService:name0=ReplicatedServer_id1,name1=replica.1,name2=Follower

ObjectName replica = new ObjectName("org.apache.ZooKeeperService:name0=ReplicatedServer_id1,name1=replica.1");

System.out.println("replica.1运行状态:" + getAttribute(mbsc, replica, "State"));// 运行状态

mbsc = createMBeanServer("192.168.1.100", "9992", "controlRole", "123456");

System.out.println("==============节点树对象===========");

ObjectName dataTreePattern = new ObjectName("org.apache.ZooKeeperService:name0=ReplicatedServer_id?,name1=replica.?,name2=*,name3=InMemoryDataTree");

Set dataTreeSets = mbsc.queryNames(dataTreePattern, null);

Iterator dataTreeIterator = dataTreeSets.iterator();

// 只有一个

while (dataTreeIterator.hasNext()) {

ObjectName dataTreeObjectName = dataTreeIterator.next();

DataTreeMXBean dataTree = JMX.newMBeanProxy(mbsc, dataTreeObjectName, DataTreeMXBean.class);

System.out.println("节点总数:" + dataTree.getNodeCount());// 节点总数

System.out.println("Watch总数:" + dataTree.getWatchCount());// Watch总数

System.out.println("临时节点总数:" + dataTree.countEphemerals());// Watch总数

System.out.println("节点名及字符总数:" + dataTree.approximateDataSize());// 节点全路径和值的总字符数

Map dataTreeMap = dataTreeObjectName.getKeyPropertyList();

String replicaId = dataTreeMap.get("name1").replace("replica.SUkIVlR", "");

String role = dataTreeMap.get("name2");// Follower,Leader,Observer,Standalone

String canonicalName = dataTreeObjectName.getCanonicalName();

int roleEndIndex = canonicalName.indexOf(",name3");

ObjectName roleObjectName = new ObjectName(canonicalName.substring(0, roleEndIndex));

System.out.println("==============zk服务状态===========");

ZooKeeperServerMXBean ZooKeeperServer = JMX.newMBeanProxy(mbsc, roleObjectName, ZooKeeperServerMXBean.class);

System.out.println(role + " 的IP和端口:" + ZooKeeperServer.getClientPort());// IP和端口

System.out.println(role + " 活着的连接数:" + ZooKeeperServer.getNumAliveConnections());// 连接数

System.out.println(role + " 未完成请求数:" + ZooKeeperServer.getOutstandingRequests());// 未完成的请求数

System.out.println(role + " 接收的包:" + ZooKeeperServer.getPacketsReceived());// 收到的包

System.out.println(role + " 发送的包:" + ZooKeeperServer.getPacketsSent());// 发送的包

System.out.println(role + " 平均延迟（毫秒）:" + ZooKeeperServer.getAvgRequestLatency());

System.out.println(role + " 最大延迟（毫秒）:" + ZooKeeperServer.getMaxRequestLatency());

System.out.println(role + " 每个客户端IP允许的最大连接数:" + ZooKeeperServer.getMaxClientCnxnsPerHost());

System.out.println(role + " 最大Session超时（毫秒）:" + ZooKeeperServer.getMaxSessionTimeout());

System.out.println(role + " 心跳时间（毫秒）:" + ZooKeeperServer.getTickTime());

System.out.println(role + " 版本:" + ZooKeeperServer.getVersion());// 版本

// 三个重置操作

// ZooKeeperServer.resetLatency(); //重置min/avg/max latency statistics

// ZooKeeperServer.resetMaxLatency(); //重置最大延迟统计

// ZooKeeperServer.resetStatistics(); // 重置包和延迟所有统计

System.out.println("==============所有客户端的连接信息===========");

ObjectName connectionPattern = new ObjectName("org.apache.ZooKeeperService:name0=ReplicatedServer_id?,name1=replica.?,name2=*,name3=Connectihttp://ons,*");

Set connectionSets = mbsc.queryNames(connectionPattern, null);

List connectionList = new ArrayList(connectionSets.size());

connectionList.addAll(connectionSets);

Collections.sort(connectionList);

for (ObjectName connectionON : connectionList) {

System.out.println("=========================");

ConnectionMXBean connectionBean = JMX.newMBeanProxy(mbsc, connectionON, ConnectionMXBean.class);

System.out.println(" IP+Port:" + connectionBean.getSourceIP());//

System.out.println(" SessionId:" + connectionBean.getSessionId());//

System.out.println(" PacketsReceived:" + connectionBean.getPacketsReceived());// 收到的包

System.out.println(" PacketsSent:" + connectionBean.getPacketsSent());// 发送的包

System.out.println(" MinLatency:" + connectionBean.getMinLatency());//

System.out.println(" AvgLatency:" + connectionBean.getAvgLatency());//

System.out.println(" MaxLatency:" + connectionBean.getMaxLatency());//

System.out.println(" StartedTime:" + connectionBean.getStartedTime());//

System.out.println(" EphemeralNodes:" + connectionBean.getEphemeralNodes().length);//

System.out.println(" EphemeralNodes:" + Arrays.asList(connectionBean.getEphemeralNodes()));//

System.out.println(" OutstandingRequests:" + connectionBean.getOutstandingRequests());//

//connectionBean.resetCounters();

//connectionBean.terminateConnection();

//connectionBean.terminateSession();

}

// close connection

if (connector != null) {

connector.close();

}

/**

* 建立连接

* @param ip

* @param jmxport

* @return

public static MBeanServerConnection createMBeanServer(String ip,

String jmxport, String userName, String password) {

try {

String jmxURL = "service:jmx:rmi:///jndi/rmi://" + ip + ":"

+ jmxport + "/jmxrmi";

// jmxurl

JMXServiceURL serviceURL = new JMXServiceURL(jmxURL);

Map map = new HashMap();

String[] credentials = new String[] { userName, password };

map.put("jmx.remote.credentials", credentials);

connector = JMXConnectorFactory.connect(serviceURL, map);

MBeanServerConnection mbsc = connector.getMBeanServerConnection();

return mbsc;

} catch (IOException ioe) {

ioe.printStackTrace();

System.err.println(ip + ":" + jmxport + " 连接建立失败");

}

return null;

}

/**

* 使用MBeanServer获取对象名为[objName]的MBean的[objAttr]属性值

* 静态代码: return MBeanServer.getAttribute(ObjectName name, String attribute)

* @param mbeanServer

* - MBeanServer实例

* @param objName

* - MBean的对象名

* @param objAttr

* - MBean的某个属性名

* @return 属性值

private static String getAttribute(MBeanServerConnection mbeanServer,

ObjectName objName, String objAttr) {

if (mbeanServer == null || objName == null || objAttr == null)

throw new IllegalArgumentException();

try {

return String.valueOf(mbeanServer.getAttribute(objName, objAttr));

} catch (Exception e) {

return null;

}

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对我们的支持。如果你想了解更多相关内容请查看下面相关链接

Flask接口签名sign原理与实例代码浅析

490 2023-01-11

使用JMX监控Zookeeper状态Java API

多平台统一管理软件接口，如何实现多平台统一管理软件接口

Flask接口签名sign原理与实例代码浅析

java中的接口是类吗

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！