Java Heap Size 监控解决方案

Question

我想在几天内监控在 Windows 上运行的 jboss 服务使用的 Java 堆大小。我首先尝试从 Windows 中使用 perfmon，但没有得到我期望的值。我可以使用 jmx（服务器：端口）将 jvisualvm 连接到这个服务，我也可以使用 jconsole 或 jmc（java 任务控制）。事实上，由于 jvm 版本，我无法使用飞行记录。 使用 jcmd 或 jstat，我看不到我感兴趣的过程。由于我是 Java 新手，有人可以建议一个应用程序或脚本，它可以让我捕获这些值并将它们推送到文本文件中。如果存在库，我也可以在 .Net 中编写代码。

谢谢

Answer 1

下面的 java 代码将 Java Heap 的使用情况（默认为 2 分钟一次）记录到一个文本文件中。您可以根据需要更改代码。根据您的环境更改private String jmxUrl = ...。

package com.heap.monitor;

import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.lang.management.*;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import javax.management.*;
import javax.management.remote.*;

public class HeapMonitor extends Thread {

private JMXServiceURL jmxService = null;
private JMXConnector jmxConnector = null;
protected MBeanServerConnection beanServerConn = null;
private long frequency = 2 * 60 * 1000L; // 2 mins only collects Heap metrics
private String jmxUrl = "service:jmx:rmi:///jndi/rmi://192.168.8.252:12222/jmxrmi";
private String userName = "none";
private String passWord = "none";

public static void main(String[] args) throws InterruptedException {
    HeapMonitor heapMonitor = new HeapMonitor();
    heapMonitor.join();
}

public HeapMonitor() {
    this.start();
}

public void run() {
    boolean flag = true;
    while(flag) {
        try {
            beanServerConn = connectToJVM(jmxUrl, userName, passWord);
            if(beanServerConn!=null) {
                MemoryMXBean mxbean = (MemoryMXBean) ManagementFactory.newPlatformMXBeanProxy(beanServerConn, ManagementFactory.MEMORY_MXBEAN_NAME, MemoryMXBean.class);
                try
                {
                    MemoryUsage heapUsage = mxbean.getHeapMemoryUsage();
                    long used = heapUsage.getUsed();
                    long max = heapUsage.getMax();
                    long commited = heapUsage.getCommitted();
                    long init = heapUsage.getInit();
                    StringBuffer buffer = new StringBuffer();
                    Date date = new Date();
                    buffer.append(date).append(" - ");
                    buffer.append(init).append("   ").append(commited).append("   ").append(max).append("   ").append(used);
                    //System.out.println(buffer.toString());
                    appendStrToFile("heap.txt" , buffer.toString());
                }
                catch(Exception ee) {
                    ee.printStackTrace();
                }
            }
        }
        catch(Exception e) {
            e.printStackTrace();
        }

        try {
            Thread.sleep(frequency);
        }
        catch(Exception e) {
            e.printStackTrace();
        }
    }
}

protected MBeanServerConnection connectToJVM(String jvmURL, String user, String pass)
{
    beanServerConn = null ;  
    try
    {
        jmxService = new JMXServiceURL(jvmURL);
        Map environment = new HashMap();
        int jmxconnect_timeout = 30000;
        environment.put("jmx.remote.x.request.waiting.timeout", Long.toString(jmxconnect_timeout));


        if(user.equalsIgnoreCase("none")|| (pass.equalsIgnoreCase("none"))){
            try{
                jmxConnector = JMXConnectorFactory.connect(jmxService,environment);
                beanServerConn = jmxConnector.getMBeanServerConnection();
            }
            catch(IOException ioe){
            }
        }
        else
        {
            String [] credentials={user,pass};
            environment.put(JMXConnector.CREDENTIALS, credentials);
            try{
                jmxConnector = JMXConnectorFactory.connect(jmxService,environment);
                beanServerConn = jmxConnector.getMBeanServerConnection();

            }
            catch(IOException ioe){
            }
        }

        beanServerConn = jmxConnector.getMBeanServerConnection();

        if(beanServerConn == null)
        {
            System.out.println("Connection to JVM is not established for jvmURL : " + jvmURL);
            closeJVMConn();
        }
    }
    catch(Exception ex)
    {
        System.out.println("Connection to JVM is not established for jvmURL : " + jvmURL);
        closeJVMConn();
    }
    return beanServerConn;
}

public void closeJVMConn(){
    try{
        beanServerConn = null;
        if(jmxConnector != null)
            jmxConnector.close();
    }
    catch(Exception ex){
        return;
    }
}

 public void appendStrToFile(String fileName, String str) { 
    try { 
        // Open given file in append mode. 
        BufferedWriter out = new BufferedWriter(new FileWriter(fileName, true)); 
        out.write(str); 
        out.newLine();
        out.close(); 
    } 
    catch (IOException e) { 
        System.out.println("exception occoured" + e); 
    } 
 } 
}

Answer 2

使用 Jconsole，您可以查看和捕获堆/非堆内存使用情况（还有 CPU、线程等）。在Jconsole 中，当右键单击堆内存使用图表 时会出现一个小的弹出窗口，如屏幕截图所示。您可以将所选时间范围内的数据保存为 .csv 格式。