Java中的JMX的使用_代码007(未授权)

本文介绍: JMX是Jav a Mana g em ent Ex t ent ion的缩写，本质的出发点是让外部能获取、设置应用的信息及操作。如果是We b 应用可以通过HTTP接口暴露，如果RPC应用可以通过RPC调用暴露，但是不通用。JMX就是为这类管理接口提供一个统一的访问方式。

JMX是Ja va Managem ent Ex tention的缩写，本质的出发点是让外部能获取、设置应用的信息及操作。如果是Web 应用可以通过HTTP接口暴露，如果RPC应用可以通过RPC调用暴露，但是不通用。JMX就是为这类管理接口提供一个统一的访问方式。

JMX在架构上分为3层:

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

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

可以理解为JMX Agent的客户端，通过不同的adapter和connect(协议和通信方式)连接到JMX Agent。

MBeanServer server = ManagementFactory.getPlatformMBeanServer();
String domain = "MyMBean";
// 注册hello
ObjectName helloName = new ObjectName(domain + ":name=hello");
server.registerMBean(new Hello(),helloName);

-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

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

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

Set<ObjectInstance> ins = mbsc.queryMBeans(null,null);
for(ObjectInstance i : ins) {
    System.out.println("object: " + i.getObjectName());
}

String[] domains = mbsc.getDomains();
for (String d : domains) {
    System.out.println(d);
}

System.out.println("MBeanCount:" + mbsc.getMBeanCount());

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 after modified--->" + mbsc.getAttribute(helloName, "Slogan")); // 获取

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

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

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