java - 如何以编程方式调用目标进程的 MBeans 操作

Question

我想通过以下方式模拟jconsole：

1. 识别暴露 jmx 功能的正在运行的进程（例如pid: 14796 FreshProject.jar：）

2. 列出可用的 MBean 库（例如org.jacoco：）

3. 调用操作（例如：单击dump）

我试过使用这里simplejmx提到的库，但我对应该使用什么感到困惑。我尝试通过，当我读到这些是默认值但它错误。hostNameportlocalhost1099java.net.ConnectException: Connection refused: connect

请不要将我指向另一个软帖子并关闭它，因为我很可能已经阅读并尝试了几次。

标签： javajmxjacocojconsolembeans

Answer 1

我想模拟 jconsole 的作用

看看 jconsole 的实现 - 见http://openjdk.java.net/tools/svc/jconsole/和https://github.com/openjdk/jdk/tree/master/src/jdk.jconsole/share /类

我对应该使用什么主机名和端口感到困惑。我尝试传递 localhost 和 1099，因为我读过这些是默认值，但它错误 java.net.ConnectException: Connection denied: connect.

根据https://docs.oracle.com/en/java/javase/11/management/monitoring-and-management-using-jmx-technology.html默认情况下没有端口。JConsole 使用Attach API - 请参阅https://github.com/openjdk/jdk/blob/master/src/jdk.jconsole/share/classes/sun/tools/jconsole/LocalVirtualMachine.java在此代码中，您还会发现回答

识别公开 jmx 功能的正在运行的进程

要通过端口连接，您需要指定适当的参数。例如以下Example.java

class Example {
    public static void main(String[] args) {
        while (true) {
        }
    }
}

可以开始为

java \
    -Dcom.sun.management.jmxremote.port=1099 \
    -Dcom.sun.management.jmxremote.authenticate=false \
    -Dcom.sun.management.jmxremote.ssl=false \
    Example

然后

列出可用的 MBean

可以做为

import javax.management.MBeanServer;
import javax.management.MBeanServerConnection;
import javax.management.MBeanServerInvocationHandler;
import javax.management.ObjectInstance;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;

import java.lang.management.ManagementFactory;
import java.util.Iterator;
import java.util.Set;

class GetMBeans {
    public static void main(final String[] args) throws Exception {
       final JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi");
       final JMXConnector jmxc = JMXConnectorFactory.connect(url, null);
       final MBeanServerConnection connection = jmxc.getMBeanServerConnection();

       Set<ObjectInstance> instances = connection.queryMBeans(null, null);
       Iterator<ObjectInstance> iterator = instances.iterator();
       while (iterator.hasNext()) {
           ObjectInstance instance = iterator.next();
           System.out.println(instance.getClassName() + " " + instance.getObjectName());
       }
    }
}

在上述开始后Example也与 JaCoCo

java \
    -Dcom.sun.management.jmxremote.port=1099 \
    -Dcom.sun.management.jmxremote.authenticate=false \
    -Dcom.sun.management.jmxremote.ssl=false \
    -javaagent:jacoco-0.8.4/lib/jacocoagent.jar=jmx=true \
    Example

执行javac GetMBeans.java && java GetMBeans | grep jacoco产品

org.jacoco.agent.rt.internal_035b120.Agent org.jacoco:type=Runtime

调用操作

MBeanClient.java显示在JaCoCo 文档中 - 参见https://www.jacoco.org/jacoco/trunk/doc/api.html

import javax.management.MBeanServer;
import javax.management.MBeanServerConnection;
import javax.management.MBeanServerInvocationHandler;
import javax.management.ObjectInstance;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;

import java.lang.management.ManagementFactory;
import java.util.Iterator;
import java.util.Set;

class MBeanClient {
    public static void main(final String[] args) throws Exception {
       final JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi");
       final JMXConnector jmxc = JMXConnectorFactory.connect(url, null);
       final MBeanServerConnection connection = jmxc.getMBeanServerConnection();

       final IProxy proxy = (IProxy) MBeanServerInvocationHandler.newProxyInstance(connection, new ObjectName("org.jacoco:type=Runtime"), IProxy.class, false);

       final byte[] data = proxy.getExecutionData(false);
       System.out.println("Got " + data.length + " bytes");
    }

    public interface IProxy {
        String getVersion();
        String getSessionId();
        void setSessionId(String id);
        byte[] getExecutionData(boolean reset);
        void dump(boolean reset);
        void reset();
    }
}

执行javac MBeanClient.java && java MBeanClient产品

Got 84 bytes