devbox
bf789
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

cat 中几个统计jvm 和system 的类_jvm.memory:jvm.memory.used.percent

作者：bf789 | 2024-02-04 14:00:00

赞

踩

jvm.memory:jvm.memory.used.percent
ClassLoadingInfoCollector
  1. private Map<String, Number> doClassLoadingCollect() {
  2.         ClassLoadingMXBean classLoadingMXBean = ManagementFactory.getClassLoadingMXBean();
  3.         Map<String, Number> map = new LinkedHashMap<String, Number>();
  4.  
  5.         map.put("jvm.classloading.loaded.count", classLoadingMXBean.getLoadedClassCount());
  6.         map.put("jvm.classloading.totalloaded.count", classLoadingMXBean.getTotalLoadedClassCount());
  7.         map.put("jvm.classloading.unloaded.count", classLoadingMXBean.getUnloadedClassCount());
  8.  
  9.         return map;
  10.     }
JvmInfoCollector
  1. private Set<String> youngGcAlgorithm = new LinkedHashSet<String>() {
  2.         private static final long serialVersionUID = -2953196532584721351L;
  3.  
  4.         {
  5.             add("Copy");
  6.             add("ParNew");
  7.             add("PS Scavenge");
  8.             add("G1 Young Generation");
  9.         }
  10.     };
  11.  
  12. private Set<String> oldGcAlgorithm = new LinkedHashSet<String>() {
  13.         private static final long serialVersionUID = -8267829533109860610L;
  14.  
  15.         {
  16.             add("MarkSweepCompact");
  17.             add("PS MarkSweep");
  18.             add("ConcurrentMarkSweep");
  19.             add("G1 Old Generation");
  20.         }
  21.     };
  22.  
  23.  
  24. private Map<String, Number> doGcCollect() {
  25.         long gcCount = 0;
  26.         long gcTime = 0;
  27.         long oldGCount = 0;
  28.         long oldGcTime = 0;
  29.         long youngGcCount = 0;
  30.         long youngGcTime = 0;
  31.         Map<String, Number> map = new LinkedHashMap<String, Number>();
  32.  
  33.         for (final GarbageCollectorMXBean garbageCollector : ManagementFactory.getGarbageCollectorMXBeans()) {
  34.             gcTime += garbageCollector.getCollectionTime();
  35.             gcCount += garbageCollector.getCollectionCount();
  36.             String gcAlgorithm = garbageCollector.getName();
  37.  
  38.             if (youngGcAlgorithm.contains(gcAlgorithm)) {
  39.                 youngGcTime += garbageCollector.getCollectionTime();
  40.                 youngGcCount += garbageCollector.getCollectionCount();
  41.             } else if (oldGcAlgorithm.contains(gcAlgorithm)) {
  42.                 oldGcTime += garbageCollector.getCollectionTime();
  43.                 oldGCount += garbageCollector.getCollectionCount();
  44.             } else {
  45.                 Cat.logEvent("UnknownGcAlgorithm", gcAlgorithm);
  46.             }
  47.         }
  48.  
  49.         map.put("jvm.gc.count", gcCount - lastGcCount);
  50.         map.put("jvm.gc.time", gcTime - lastGcTime);
  51.         final long value = oldGCount - lastFullGcCount;
  52.  
  53.         if (value > 0) {
  54.             hasOldGc = true;
  55.         }
  56.  
  57.         map.put("jvm.fullgc.count", value);
  58.         map.put("jvm.fullgc.time", oldGcTime - lastFullGcTime);
  59.         map.put("jvm.younggc.count", youngGcCount - lastYoungGcCount);
  60.         map.put("jvm.younggc.time", youngGcTime - lastYoungGcTime);
  61.  
  62.         if (youngGcCount > lastYoungGcCount) {
  63.             map.put("jvm.younggc.meantime", (youngGcTime - lastYoungGcTime) / (youngGcCount - lastYoungGcCount));
  64.         } else {
  65.             map.put("jvm.younggc.meantime", 0);
  66.         }
  67.  
  68.         lastGcCount = gcCount;
  69.         lastGcTime = gcTime;
  70.         lastYoungGcCount = youngGcCount;
  71.         lastYoungGcTime = youngGcTime;
  72.         lastFullGcCount = oldGCount;
  73.         lastFullGcTime = oldGcTime;
  74.  
  75.         return map;
  76.     }
  77.  
  78.     private Map<String, Number> doMemoryCollect() {
  79.         MemoryInformation memInfo = new MemoryInformation();
  80.         Map<String, Number> map = new LinkedHashMap<String, Number>();
  81.  
  82.         map.put("jvm.memory.used", memInfo.getUsedMemory());
  83.         map.put("jvm.memory.used.percent", memInfo.getUsedMemoryPercentage());
  84.         map.put("jvm.memory.nonheap.used", memInfo.getUsedNonHeapMemory());
  85.         map.put("jvm.memory.nonheap.used.percent", memInfo.getUsedNonHeapPercentage());
  86.         map.put("jvm.memory.oldgen.used", memInfo.getUsedOldGen());
  87.         map.put("jvm.memory.oldgen.used.percent", memInfo.getUsedOldGenPercentage());
  88.  
  89.         if (hasOldGc) {
  90.             map.put("jvm.memory.oldgen.used.percent.after.fullgc", memInfo.getUsedOldGenPercentage());
  91.             hasOldGc = false;
  92.         } else {
  93.             map.put("jvm.memory.oldgen.used.percent.after.fullgc", 0);
  94.         }
  95.  
  96.         map.put("jvm.memory.eden.used", memInfo.getUsedEdenSpace());
  97.         map.put("jvm.memory.eden.used.percent", memInfo.getUsedEdenSpacePercentage());
  98.         map.put("jvm.memory.survivor.used", memInfo.getUsedSurvivorSpace());
  99.         map.put("jvm.memory.survivor.used.percent", memInfo.getUsedSurvivorSpacePercentage());
  100.         map.put("jvm.memory.perm.used", memInfo.getUsedPermGen());
  101.         map.put("jvm.memory.perm.used.percent", memInfo.getUsedPermGenPercentage());
  102.         map.put("jvm.memory.metaspace.used", memInfo.getUsedMetaSpace());
  103.         map.put("jvm.memory.metaspace.used.percent", memInfo.getUsedMetaSpacePercentage());
  104.         map.put("jvm.memory.codecache.used", memInfo.getUsedCodeCache());
  105.         map.put("jvm.memory.codecache.used.percent", memInfo.getUsedCodeCachePercentage());
  106.         map.put("jvm.nio.directbuffer.used", memInfo.getUsedDirectBufferSize());
  107.         map.put("jvm.nio.mapped.used", memInfo.getUsedMappedSize());
  108.  
  109.         return map;
  110.     }
ThreadInfoCollector
  1. private Map<String, Number> doThreadCollect() {
  2.         final ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();
  3.         Map<String, Number> map = new LinkedHashMap<String, Number>();
  4.         map.put("jvm.thread.count", threadBean.getThreadCount());
  5.         map.put("jvm.thread.daemon.count", threadBean.getDaemonThreadCount());
  6.         map.put("jvm.thread.totalstarted.count", threadBean.getTotalStartedThreadCount());
  7.         ThreadInfo[] threadInfos = threadBean.getThreadInfo(threadBean.getAllThreadIds());
  8.  
  9.         int newThreadCount = 0;
  10.         int runnableThreadCount = 0;
  11.         int blockedThreadCount = 0;
  12.         int waitThreadCount = 0;
  13.         int timeWaitThreadCount = 0;
  14.         int terminatedThreadCount = 0;
  15.  
  16.         if (threadInfos != null) {
  17.             for (ThreadInfo threadInfo : threadInfos) {
  18.                 if (threadInfo != null) {
  19.                     switch (threadInfo.getThreadState()) {
  20.                         case NEW:
  21.                             newThreadCount++;
  22.                             break;
  23.                         case RUNNABLE:
  24.                             runnableThreadCount++;
  25.                             break;
  26.                         case BLOCKED:
  27.                             blockedThreadCount++;
  28.                             break;
  29.                         case WAITING:
  30.                             waitThreadCount++;
  31.                             break;
  32.                         case TIMED_WAITING:
  33.                             timeWaitThreadCount++;
  34.                             break;
  35.                         case TERMINATED:
  36.                             terminatedThreadCount++;
  37.                             break;
  38.                         default:
  39.                             break;
  40.                     }
  41.                 } else {
  42.                     /**
  43.                      * If a thread of a given ID is not alive or does not exist, the corresponding element in the returned array will,
  44.                      * contain null,because is mut exist ,so the thread is terminated
  45.                      */
  46.                     terminatedThreadCount++;
  47.                 }
  48.             }
  49.         }
  50.  
  51.         map.put("jvm.thread.new.count", newThreadCount);
  52.         map.put("jvm.thread.runnable.count", runnableThreadCount);
  53.         map.put("jvm.thread.blocked.count", blockedThreadCount);
  54.         map.put("jvm.thread.waiting.count", waitThreadCount);
  55.         map.put("jvm.thread.time_waiting.count", timeWaitThreadCount);
  56.         map.put("jvm.thread.terminated.count", terminatedThreadCount);
  57.  
  58.         long[] ids = threadBean.findDeadlockedThreads();
  59.  
  60.         map.put("jvm.thread.deadlock.count", ids == null ? 0 : ids.length);
  61.  
  62.         if (threadInfos != null) {
  63.             int tomcatThreadsCount = countThreadsByPrefix(threadInfos, "http-", "catalina-exec-");
  64.             int jettyThreadsCount = countThreadsBySubstring(threadInfos, "@qtp");
  65.  
  66.             map.put("jvm.thread.http.count", tomcatThreadsCount + jettyThreadsCount);
  67.             map.put("jvm.thread.cat.count", countThreadsByPrefix(threadInfos, "Cat-", "cat-"));
  68.             map.put("jvm.thread.pigeon.count",
  69.                     countThreadsByPrefix(threadInfos, "Pigeon-", "DPSF-", "Client-ResponseProcessor"));
  70.         }
  71.  
  72.         return map;
  73.     }
ProcessorInfoCollector

  1. private Map<String, Number> doProcessCollect() {
  2.         Map<String, Number> map = new LinkedHashMap<String, Number>();
  3.         OperatingSystemMXBean operatingSystem = ManagementFactory.getOperatingSystemMXBean();
  4.  
  5.         map.put("system.load.average", operatingSystem.getSystemLoadAverage());
  6.  
  7.         if (operatingSystem instanceof com.sun.management.OperatingSystemMXBean) {
  8.             com.sun.management.OperatingSystemMXBean osBean = (com.sun.management.OperatingSystemMXBean) operatingSystem;
  9.  
  10.             map.put("cpu.system.load.percent", osBean.getSystemCpuLoad() * 100);
  11.             map.put("cpu.jvm.load.percent", osBean.getProcessCpuLoad() * 100);
  12.             map.put("system.process.used.phyical.memory",
  13.                     osBean.getTotalPhysicalMemorySize() - osBean.getFreePhysicalMemorySize());
  14.             map.put("system.process.used.swap.size", osBean.getTotalSwapSpaceSize() - osBean.getFreeSwapSpaceSize());
  15.         }
  16.  
  17.         if (isSunOsMBean(operatingSystem)) {
  18.             if (operatingSystem instanceof com.sun.management.UnixOperatingSystemMXBean) {
  19.                 final com.sun.management.UnixOperatingSystemMXBean unixOsBean = (com.sun.management.UnixOperatingSystemMXBean) operatingSystem;
  20.                 try {
  21.                     map.put("jvm.process.filedescriptors", unixOsBean.getOpenFileDescriptorCount());
  22.                 } catch (final Error e) {
  23.                     // pour issue 16 (using jsvc on ubuntu or debian)
  24.                 }
  25.             }
  26.             final com.sun.management.OperatingSystemMXBean osBean = (com.sun.management.OperatingSystemMXBean) operatingSystem;
  27.             long processCpuTime = osBean.getProcessCpuTime() / 1000000;
  28.             map.put("jvm.process.cputime", processCpuTime - lastProcessCputime);
  29.  
  30.             lastProcessCputime = processCpuTime;
  31.         }
  32.  
  33.         return map;
  34.     }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/article/detail/58905
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号