JMX的使用

1. 定义和意义 

JMX是Java Management Extention的缩写，出发点是让外部通过属性/方法来读取或设置程序状态。对于提供对外服务的程序来说，天生就有这样的能力，Web程序通过HTTP接口对外暴露，RPC应用通过RPC接口暴露。不过带来的问题，一是依赖环境，不同的环境能力不同；二是需要单独处理安全性问题，尤其是对公网暴露的情况下。JMX从某种程度上来说，解决了上述两个问题，无论什么应用都能通过JMX对外暴露管理功能，单独的非业务含义的协议和通道，可以避免非必要的公网暴露。

2. 架构 

JDK官网上介绍，JMX在架构上分为3层: Instrumentation、JMX Agent、Remote Management

2.1 Instrumentation 

Instrumentation定义了MBean的创建规范，JDK自带一组叫做MXBean的特殊MBean，对外提供JVM信息及操作。

2.2 JMX Agent

JMX Agent用来管理Instrument，核心是MBeanServer(用来注册MBean)，并至少提供一组adaptor和connector，可以理解为通信协议和通信方式，允许外部程序或者客户端和JMX Agent通信。

2.3 Remote Management

可以把它理解为JMX Agent的客户端，通过不同的adapter和connect(协议和通信方式)连接到JMX Agent，进行远程调用。

3. 服务端

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 启动服务
  1. 使用JVM参数
-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
  1. 使用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();

如果是代码或者是远程连接JMX Agent，后续会用到JMXServiceURL的地址。和使用Java代码创建不同，JVM参数的domain值固定为jmxrm

4. 客户端

JMX的客户端有两类，一类是现成的GUI工具，如JConsole、VisualVM等；另一类是通过代码操作。通过GUI程序启动的客户端，只需要直接选择对应进程ID，或者填入注册MBean时提供的JMXServiceURL即可，如下图所示。这里我们主要聚焦通过代码操作MBean。

4.1 建立连接

和启动JMXConnectorServer一样，先建立JMXServiceURL，不同的是这里创建的是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计数
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())); // 设置
System.out.println("getAttribute modified--->" + mbsc.getAttribute(helloName, "Slogan")); // 获取
4.6 方法调用

有两种方式可以调用MBean的方法，一种是直接使用MBeanServerConnection调用

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生成代理对象，再用这个对象直接调用

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));

第二种方式的使用体验会好一些，尤其是需要频繁、多次使用MBean的方法时。

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实现类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，允许我们声明配置并创建MBeanServer对象

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

提供了ConnectorServerFactoryBean对象，用于配置并创建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应用的话，在@Configuration类上添加一个注解@EnableMBeanExport，注册MBean有两种方案可选，一种方式是使用MBeanExporter，可以用正常的Spring Bean配置为MBean，比如这里的globalProduct bean，后面被做为MBean的目标对象。

@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();}@ManagedOperationpublic void resetSystemProperties() {System.getProperties().setProperty("appInfo","lws");}
}

6. 效果和评估

通过JConsole连接到我们的应用，查看MBean效果如下图。除了我们自己注册的MBean，Java默认提供一对内置MBean，用来读取系统、JVM的信息，包括类加载、内存使用、GC、ClassPath、环境变量等等信息，甚至可以通过JFR的MBean来启动JFR记录，打线程堆栈、手工执行GC等等。

单纯的从Java用户的角度来说，这不失为一种不错的Java管理的扩展能力(Java Management Extension)，有一定的基础设施，使用也算方便。但是在跨语言方法就显得有点弱势，网上也可以看到各种从JMX适配到其他协议的工具，以便将JMX数据暴露给其他中间件，比如Promethus和JMX 之间就有个JMX Exporter，让Promethus能获取JMX的数据。

经过上面的学习和试验后，我们对JMX态度是可以了解和使用，不必要过多深入，学完本文的内容已经够用。有具体使用场景，比如希望通过JMX监控Kafka，再详细了解Kafka提供的MBean即可。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/238139.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【C语言】与文件有关的操作

【C语言】与文件有关的操作

目录 1. 前言2. 什么是文件&#xff1f;2.1 程序文件2.2 数据文件2.3 文件名 3. 二进制文件和文本文件&#xff1f;4. 文件的打开和关闭4.1 流和标准流4.1.1 流4.1.2 标准流 4.2 文件指针4.3 文件的打开和关闭 5. 文件的顺序读写5.1 顺序读写函数介绍5.2 对比一组函数 6. 文件的…
阅读更多...
[SWPUCTF 2022 新生赛]ez_sql

[SWPUCTF 2022 新生赛]ez_sql

参数为1的时候没有报错&#xff0c;为2和任何数的时候报&#xff0c;发现空格被过滤了&#xff0c;然后union需要双拼写 4/**/ununionion/**/select/**/1,2,3;# 发现存在3个 数据库为NSS_db 它的表有两个为&#xff0c;NSS_tb和users nss2/**/ununionion/**/select/**/1,dat…
阅读更多...
Redis缓存——Spring Cache入门学习

Redis缓存——Spring Cache入门学习

Spring Cache 介绍 Spring Cache 是一个框架&#xff0c;实现了基于注解的缓存功能&#xff0c;只需要简单地加一个注解&#xff0c;就能实现缓存功能。 Spring Cache 提供了一层抽象&#xff0c;底层可以切换不同的缓存实现&#xff0c;例如&#xff1a; EHCacheCaffeineR…
阅读更多...
Python基础学习快速入门

Python基础学习快速入门

文章目录 Number变量String字符串Def函数Class类List列表Tuple元组Dictionary字典Set集合值与引用类型if条件控制Loop循环 Number变量 python直接赋值&#xff0c;不需要定义变量类型。不需要**,逗号结尾符 使用print**直接进行输出 #赋值 a 1.0 print(a)a 7 print(a)p…
阅读更多...
TZOJ 1402 Bitset

TZOJ 1402 Bitset

答案&#xff1a; #include <stdio.h> int main() {int n 0, j 0; while (scanf("%d", &n) ! EOF && (n>0 && n<1000)) //多组输入{int arr[32], i 0;while (n > 0) {arr[i] n % 2; //除2取余法n / 2;}for (j i -…
阅读更多...
知虾平台丨优化Shopee店铺运营，提升销售利润——了解知虾平台

知虾平台丨优化Shopee店铺运营，提升销售利润——了解知虾平台

在如今竞争激烈的电商市场中&#xff0c;Shopee作为一家快速发展的平台&#xff0c;吸引了众多卖家加入。然而&#xff0c;要在Shopee上取得成功并实现可观的销售利润&#xff0c;并不是一件容易的事情。为了帮助卖家更好地了解市场趋势、优化商品关键词、监控竞争对手等&#…
阅读更多...
SQL 算术运算符：加法、减法、乘法、除法和取模的用法

SQL 算术运算符：加法、减法、乘法、除法和取模的用法

SQL Server中的存储过程 什么是存储过程&#xff1f; 存储过程是一段预先编写好的 SQL 代码&#xff0c;可以保存在数据库中以供反复使用。它允许将一系列 SQL 语句组合成一个逻辑单元&#xff0c;并为其分配一个名称&#xff0c;以便在需要时调用执行。存储过程可以接受参数…
阅读更多...
稻盛和夫：毕生经验总结出的36条管理经验，总有一条能戳中你。

稻盛和夫：毕生经验总结出的36条管理经验，总有一条能戳中你。

大家好&#xff0c;我是老原。 进入职场&#xff0c;每个道理在每个人身上都有不同的理解。 大家经理不同&#xff0c;血泪自然不同&#xff0c;毕竟人类的悲喜并不相通&#xff0c;只有总结下来的经验才最有用。 我平时给你们分享的硬干货比较多&#xff0c;这种软道理写的…
阅读更多...
FL Studio(水果软件)2024最新中文版云盘下载

FL Studio(水果软件)2024最新中文版云盘下载

如今&#xff0c;越来越多的音乐人选择使用音乐制作软件来进行音乐的创作&#xff0c;一台电脑、一款软件以及一个外接MIDI就是一个小型的音乐工作站。FL Studio成了音乐界萌新的首选&#xff0c;目前最新的版本为FL Studio2024版本。 你可以不知道如何做音乐&#xff0c;但是…
阅读更多...
Linux环境下ARM开发

Linux环境下ARM开发

目录 前言ARM启动及开发基础1.Cortex-A架构2.启动方式3.汇编基础4.Makefile语法基础5.Makefile补充6.编译下载 结语 前言 主要介绍基于linux开发环境下&#xff0c;如何开发ARM A7 ARM启动及开发基础 1.Cortex-A架构 1&#xff09;Cortex-A7运行模式 模式说明User(USR)用户模…
阅读更多...
Neo4j 数据库管理 数据备份与恢复（头歌）

Neo4j 数据库管理 数据备份与恢复（头歌）

文章目录 第1关&#xff1a;数据备份与恢复任务描述相关知识数据备份数据导入 编程要求测试说明答案测试前准备Cypher 代码数据备份与导入 第1关&#xff1a;数据备份与恢复 任务描述 本关任务&#xff1a;熟练掌握数据备份与恢复。 相关知识 为了完成本关任务&#xff0c;…
阅读更多...
你好！插值查找【JAVA】

你好！插值查找【JAVA】

1.初次相识 插值查找&#xff08;interpolation search&#xff09;是一种根据待查找关键字在有序数组中的大致位置决定查找范围的查找算法。插值查找与二分查找类似&#xff0c;区别在于插值查找对于待查找关键字在数组中的位置进行估计&#xff0c;从而更精准地定位到待查找关…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023