农业网站建设方案 ppt,泰安搜索引擎优化招聘,旅游网站开发方案百度文库,谷歌优化技巧1. 定义和意义
JMX是Java Management Extention的缩写#xff0c;出发点是让外部通过属性/方法来读取或设置程序状态。对于提供对外服务的程序来说#xff0c;天生就有这样的能力#xff0c;Web程序通过HTTP接口对外暴露#xff0c;RPC应用通过RPC接口暴露。不过带来的问…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 :namehello);
server.registerMBean(new Hello(),helloName);
3.2 启动服务
使用JVM参数
-Dcom.sun.management.jmxremote
-Dcom.sun.management.jmxremote.port1099
-Dcom.sun.management.jmxremote.local.onlyfalse
-Dcom.sun.management.jmxremote.authenticatefalse
-Dcom.sun.management.jmxremote.sslfalse
使用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列表
SetObjectInstance 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 :namehello);
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 :namehello);// 无返回
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 :namehello);
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 :namehello);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();MapString, Object beans new HashMap();beans.put(hello:nameglobalProduct, globalProduct());exporter.setBeans(beans);exporter.setServer(mbeanServer().getObject());return exporter;
}
另一种方案是通过注解使用ManagedResource、ManagedAttribute、ManagedOperation注解直接暴露Bean对象
Component
ManagedResource(objectName hello:nameappInfo)
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效果如下图。除了我们自己注册的MBeanJava默认提供一对内置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即可。
