如何用JMX连接本地JVM上运行的Java程序

问题:

我需要使用JMX连接本地JVM的Java程序。换句话说,我想开发一个JMX的客户端来配置一个本地Java程序。

  • 请不要推荐使用JConsole!JConsole不合适,因为JConsole是一个通用的JMX客户端,对主程序的性能存在负面影响。
  • Oracle网站上有一个使用RMIConnector和“主机 : 端口号”为参数的例子,但是我不知道在什么地方设置JMX的端口号?
  • JConsole可以选择PID来连接Java进程。但是在JMX的API中,我找不到任何方法是使用PID作为参数的。

回复:

我们使用一些类似下面的程序来连接JMX服务器。不过,需要在运行服务器时指定以下参数:

-Dcom.sun.management.jmxremote
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.port=1234
-Dcom.sun.management.jmxremote.ssl=false

为了绑定特定地址,你需要在增加下面的VM参数:

-Djava.rmi.server.hostname=A.B.C.D

这样,你就可以像下面的JMX客户端代码一样连接你的服务器了:

String host = "localhost";  // or some A.B.C.D
int port = 1234;
String url = "service:jmx:rmi:///jndi/rmi://" + host + ":" + port + "/jmxrmi";
JMXServiceURL serviceUrl = new JMXServiceURL(url);
JMXConnector jmxConnector = JMXConnectorFactory.connect(serviceUrl, null);
try {
   MBeanServerConnection mbeanConn = jmxConnector.getMBeanServerConnection();
   // now query to get the beans or whatever
   Set<ObjectName> beanSet = mbeanConn.queryNames(null, null);
   ...
} finally {
   jmxConnector.close();
}

我们也可以不使用VM参数,代码本身可以通过编程在指定端口号发布。但是我想这个已经比你的需求更复杂了。

如果要根据PID来连接,据我现在所知,你需要使用Java 6以上的版本。我没使用过下面的代码,但是看起是可以正常工作的:

List<VirtualMachineDescriptor> vms = VirtualMachine.list();
for (VirtualMachineDescriptor desc : vms) {
    VirtualMachine vm;
    try {
        vm = VirtualMachine.attach(desc);
    } catch (AttachNotSupportedException e) {
        continue;
    }
    Properties props = vm.getAgentProperties();
    String connectorAddress =
        props.getProperty("com.sun.management.jmxremote.localConnectorAddress");
    if (connectorAddress == null) {
        continue;
    }
    JMXServiceURL url = new JMXServiceURL(connectorAddress);
    JMXConnector connector = JMXConnectorFactory.connect(url);
    try {
        MBeanServerConnection mbeanConn = connector.getMBeanServerConnection();
        Set<ObjectName> beanSet = mbeanConn.queryNames(null, null);
        ...
    } finally {
        jmxConnector.close();
    }
}

我已发布过一个新的SimpleJMX包,该包能帮助很简单的启动一个JMX服务,并向远程客户端发送beans。

//创建一个新的服务器并监听8000端口
JmxServer jmxServer = new JmxServer(8000);
//启动服务器
jmxServer.start();
//注册下面定义的lookupCache对象
jmxServer.register(lookupCache);
jmxServer.register(someOtherObject);
//停止服务
jmxServer.stop();

该包确实有一个客户端的接口,但是当前没有人一种机制是可以通过PID来查找进程的,只支持主机/端口的组合方式查找。

原文链接: stackoverflow 翻译: ImportNew.com - paddx
译文链接: http://www.importnew.com/15982.html
[ 转载请保留原文出处、译者和译文链接。]



相关文章

发表评论

Comment form

(*) 表示必填项

1 条评论

  1. YYChildren 说道:

    public class ClientLocal {
    static final String CONNECTOR_ADDRESS = “com.sun.management.jmxremote.localConnectorAddress”;

    public static void main(String[] args) throws AttachNotSupportedException,
    IOException, AgentLoadException, AgentInitializationException,
    MalformedObjectNameException, InstanceNotFoundException {
    // / Example 2-4 Attaching a JMX tool to a connector and getting the
    // agent’s address
    String id = “5552″;// 进程id
    // attach to the target application
    VirtualMachine vm = VirtualMachine.attach(id);
    // get the connector address
    String connectorAddress = vm.getAgentProperties().getProperty(
    CONNECTOR_ADDRESS);
    // no connector address, so we start the JMX agent
    if (connectorAddress == null) {
    String agent = vm.getSystemProperties().getProperty(“java.home”)
    + File.separator + “lib” + File.separator
    + “management-agent.jar”;
    vm.loadAgent(agent);
    // agent is started, get the connector address
    connectorAddress = vm.getAgentProperties().getProperty(CONNECTOR_ADDRESS);
    }
    // establish connection to connector server
    JMXServiceURL url = new JMXServiceURL(connectorAddress);
    JMXConnector jmxConn = JMXConnectorFactory.connect(url);

    MBeanServerConnection mbs = jmxConn.getMBeanServerConnection();
    if (mbs == null) {
    System.err
    .println(“Failed: could not get mbean server connection.”);
    System.exit(1);
    }
    ObjectName on = new ObjectName(“java.lang:type=Threading”);
    ObjectInstance oi = mbs.getObjectInstance(on);
    ThreadMXBean bean = ManagementFactory.newPlatformMXBeanProxy(mbs,
    “java.lang:type=Threading”, ThreadMXBean.class);
    if (bean == null) {
    System.err.println(“Failed: could not get threading mbean.”);
    System.exit(1);
    }
    System.out.println(“Number of live threads = ” + bean.getThreadCount());
    System.exit(0);
    }
    }

    Thumb up 0 Thumb down 0

跳到底部
返回顶部