Java获取Liunx服务器的cpu使用率、内存使用率以及磁盘使用率

柔光的暖阳◎ 2023-01-10 15:56 973阅读 0赞

前言：

本篇博客主要说明使用java程序如何获取liunx系统中的cpu使用率、内存使用率以及磁盘使用率，效果图如下：在这里插入图片描述

1.创建三个实体类，分别为cpu、内存以及磁盘相关信息：

cpu相关信息实体

  1. package com.gdhengdian.monitorservice.domain.server;
  4. import org.springframework.stereotype.Component;
  6. import java.io.Serializable;
  8. /** * CPU相关信息 * * */
  9. @Component
  10. public class Cpu implements Serializable { 
  12.     /** * 核心数 */
  13.     private int cpuNum;
  15.     /** * CPU总的使用率 */
  16.     private String total;
  18.     /** * CPU系统使用率 */
  19.     private String sys;
  21.     /** * CPU用户使用率 */
  22.     private String used;
  24.     /** * CPU当前等待率 */
  25.     private String wait;
  27.     /** * CPU当前空闲率 */
  28.     private String free;
  31.     @Override
  32.     public String toString() { 
  33.         return "Cpu{" +
  34.                 "核心数=" + getCpuNum() +
  35.                 ", CPU总的使用率=" + getTotal() +
  36.                 ", CPU系统使用率=" + getSys() +
  37.                 ", CPU用户使用率=" + getUsed() +
  38.                 ", CPU当前等待率=" + getWait() +
  39.                 ", CPU当前空闲率=" + getFree() +
  40.                 '}';
  41.     }
  43.     public int getCpuNum() { 
  44.         return cpuNum;
  45.     }
  47.     public void setCpuNum(int cpuNum) { 
  48.         this.cpuNum = cpuNum;
  49.     }
  51.     public String getTotal() { 
  52.         return total;
  53.     }
  55.     public void setTotal(String total) { 
  56.         this.total = total;
  57.     }
  59.     public String getSys() { 
  60.         return sys;
  61.     }
  63.     public void setSys(String sys) { 
  64.         this.sys = sys;
  65.     }
  67.     public String getUsed() { 
  68.         return used;
  69.     }
  71.     public void setUsed(String used) { 
  72.         this.used = used;
  73.     }
  75.     public String getWait() { 
  76.         return wait;
  77.     }
  79.     public void setWait(String wait) { 
  80.         this.wait = wait;
  81.     }
  83.     public String getFree() { 
  84.         return free;
  85.     }
  87.     public void setFree(String free) { 
  88.         this.free = free;
  89.     }
  90. }

内存相关信息实体:

  1. package com.gdhengdian.monitorservice.domain.server;
  4. import org.springframework.stereotype.Component;
  6. import java.io.Serializable;
  8. /** * 內存相关信息 * * @author ruoyi */
  9. @Component
  10. public class Mem implements Serializable { 
  11.     private String usedRate;
  13.     /** * 内存总量 */
  14.     private long total;
  16.     /** * 已用内存 */
  17.     private long used;
  19.     /** * 剩余内存 */
  20.     private long free;
  22.     @Override
  23.     public String toString() { 
  24.         return "Mem{" +
  25.                 "内存总量=" + getTotal() +
  26.                 ",同上=" + getUsed() +
  27.                 ", 剩余内存=" + getFree() +
  28.                 ", 使用率="+ getUsedRate() +
  29.                 '}';
  30.     }
  32.     public double getTotal()
  33.     { 
  34.         return Arith.div(total, (1024 * 1024 * 1024), 2);
  35.     }
  37.     public void setTotal(long total)
  38.     { 
  39.         this.total = total;
  40.     }
  42.     public double getUsed()
  43.     { 
  44.         return Arith.div(used, (1024 * 1024 * 1024), 2);
  45.     }
  47.     public void setUsed(long used)
  48.     { 
  49.         this.used = used;
  50.     }
  52.     public double getFree()
  53.     { 
  54.         return Arith.div(free, (1024 * 1024 * 1024), 2);
  55.     }
  57.     public void setFree(long free)
  58.     { 
  59.         this.free = free;
  60.     }
  62.     public double getUsage()
  63.     { 
  64.         return Arith.mul(Arith.div(used, total, 4), 100);
  65.     }
  67.     public String getUsedRate() { 
  68.         return usedRate;
  69.     }
  71.     public void setUsedRate(String usedRate) { 
  72.         this.usedRate = usedRate;
  73.     }
  74. }

磁盘相关信息实体

  1. package com.gdhengdian.monitorservice.domain.server;
  3. import org.springframework.stereotype.Component;
  5. import java.io.Serializable;
  7. /** * 系统文件相关信息 * */
  8. @Component
  9. public class SysFile implements Serializable { 
  10.     /** * 盘符路径 */
  11.     private String dirName;
  13.     /** * 盘符类型 */
  14.     private String sysTypeName;
  16.     /** * 文件类型 */
  17.     private String typeName;
  19.     /** * 总大小 */
  20.     private String total;
  22.     /** * 剩余大小 */
  23.     private String free;
  25.     /** * 已经使用量 */
  26.     private String used;
  28.     /** * 资源的使用率 */
  29.     private String usage;
  31.     @Override
  32.     public String toString() { 
  33.         return "SysFile{" +
  34.                 "盘符路径='" + getDirName() + '\'' +
  35.                 ", 盘符类型='" + getSysTypeName() + '\'' +
  36.                 ", 文件类型='" + getTypeName() + '\'' +
  37.                 ", 总大小='" + getTotal() + '\'' +
  38.                 ", 剩余大小='" + getFree()+ '\'' +
  39.                 ", 已经使用量='" + getUsed() + '\'' +
  40.                 ", 资源的使用率=" + getUsage() +
  41.                 '}';
  42.     }
  44.     public String getDirName()
  45.     { 
  46.         return dirName;
  47.     }
  49.     public void setDirName(String dirName)
  50.     { 
  51.         this.dirName = dirName;
  52.     }
  54.     public String getSysTypeName()
  55.     { 
  56.         return sysTypeName;
  57.     }
  59.     public void setSysTypeName(String sysTypeName)
  60.     { 
  61.         this.sysTypeName = sysTypeName;
  62.     }
  64.     public String getTypeName()
  65.     { 
  66.         return typeName;
  67.     }
  69.     public void setTypeName(String typeName)
  70.     { 
  71.         this.typeName = typeName;
  72.     }
  74.     public String getTotal()
  75.     { 
  76.         return total;
  77.     }
  79.     public void setTotal(String total)
  80.     { 
  81.         this.total = total;
  82.     }
  84.     public String getFree()
  85.     { 
  86.         return free;
  87.     }
  89.     public void setFree(String free)
  90.     { 
  91.         this.free = free;
  92.     }
  94.     public String getUsed()
  95.     { 
  96.         return used;
  97.     }
  99.     public void setUsed(String used)
  100.     { 
  101.         this.used = used;
  102.     }
  104.     public String getUsage()
  105.     { 
  106.         return usage;
  107.     }
  109.     public void setUsage(String usage)
  110.     { 
  111.         this.usage = usage;
  112.     }
  113. }

2.再创建一个初始化服务器相关信息类：

  1. package com.gdhengdian.monitorservice.domain;
  4. import com.gdhengdian.monitorservice.domain.server.Arith;
  5. import com.gdhengdian.monitorservice.domain.server.Cpu;
  6. import com.gdhengdian.monitorservice.domain.server.Mem;
  7. import com.gdhengdian.monitorservice.domain.server.SysFile;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.stereotype.Component;
  10. import oshi.SystemInfo;
  11. import oshi.hardware.CentralProcessor;
  12. import oshi.hardware.GlobalMemory;
  13. import oshi.hardware.HardwareAbstractionLayer;
  14. import oshi.software.os.FileSystem;
  15. import oshi.software.os.OSFileStore;
  16. import oshi.software.os.OperatingSystem;
  17. import oshi.util.Util;
  18. import oshi.hardware.CentralProcessor.TickType;
  20. import java.text.NumberFormat;
  22. /** * 服务器相关信息 * */
  23. @Component
  24. public class Server
  25. { 
  27.     private static final int OSHI_WAIT_SECOND = 2000;
  29.     /** * CPU相关信息 */
  30.     @Autowired
  31.     private Cpu cpu;
  32.     /** * 內存相关信息 */
  33.     @Autowired
  34.     private Mem mem;
  36.     /** * 磁盘相关信息 */
  37.     @Autowired
  38.     private SysFile sysFiles;
  40.     /** * 获取磁盘，CPU，运行内存等数据 * @throws Exception */
  41.     public void copyTo() throws Exception
  42.     { 
  43.         SystemInfo si = new SystemInfo();
  44.         HardwareAbstractionLayer hal = si.getHardware();
  45.         //cpux信息
  46.         setCpuInfo(hal.getProcessor());
  47.         //内存信息
  48.         setMemInfo(hal.getMemory());
  49.         //磁盘信息
  50.         setSysFiles(si.getOperatingSystem());
  51.     }
  53.     /** * 设置CPU信息 */
  54.     private void setCpuInfo(CentralProcessor processor)
  55.     { 
  56.         // CPU信息
  57.         long[] prevTicks = processor.getSystemCpuLoadTicks();//cpu时钟1的计算出来的cpu各项指标（单位：节拍数）
  58.         Util.sleep(OSHI_WAIT_SECOND);
  59.         long[] ticks = processor.getSystemCpuLoadTicks(); //cpu时钟2的计算出来的cpu各项值（单位：节拍数）
  60.         //以高优先级在用户级别执行时发生的CPU节拍数。
  61.         Long nice = ticks[CentralProcessor.TickType.NICE.getIndex()] - prevTicks[TickType.NICE.getIndex()];
  62.         //CPU中断花销的节拍
  63.         Long irq = ticks[TickType.IRQ.getIndex()] - prevTicks[TickType.IRQ.getIndex()];
  64.         //软中断花销的节拍
  65.         Long softirq = ticks[TickType.SOFTIRQ.getIndex()] - prevTicks[TickType.SOFTIRQ.getIndex()];
  66.         //系统监控程序为其它用户开启的cpu节拍，Only supported on Linux.
  67.         Long steal = ticks[TickType.STEAL.getIndex()] - prevTicks[TickType.STEAL.getIndex()];
  68.         //CPU在内核空间运行的节拍花销
  69.         Long cSys = ticks[TickType.SYSTEM.getIndex()] - prevTicks[TickType.SYSTEM.getIndex()];
  70.         //用户进程对CPU的节拍花销
  71.         Long user = ticks[TickType.USER.getIndex()] - prevTicks[TickType.USER.getIndex()];
  72.         //CPU调用IO操作的节拍花销
  73.         Long iowait = ticks[TickType.IOWAIT.getIndex()] - prevTicks[TickType.IOWAIT.getIndex()];
  74.         //CPU处于空闲状态节拍花销
  75.         Long idle = ticks[TickType.IDLE.getIndex()] - prevTicks[TickType.IDLE.getIndex()];
  76.         Long totalCpu = user + nice + cSys + idle + iowait + irq + softirq + steal;
  77.         Long cpuUsed = (cSys + user);
  78.         double usedRate = cpuUsed.doubleValue() / totalCpu.doubleValue();
  79.         // 创建一个数值格式化对象
  80.         NumberFormat numberFormat = NumberFormat.getInstance();
  81.         // 设置精确到小数点后2位
  82.         numberFormat.setMaximumFractionDigits(2);
  83.         String totalRate = numberFormat.format( usedRate * 100) ;//所占百分比
  84.         cpu.setCpuNum(processor.getLogicalProcessorCount());
  85.         cpu.setTotal(totalRate);
  86.     }
  88.     /** * 设置内存信息 */
  89.     private void setMemInfo(GlobalMemory memory) { 
  91.         long totalMem = memory.getTotal();
  92.         mem.setTotal(totalMem);
  93.         mem.setUsed(memory.getTotal() - memory.getAvailable());
  94.         mem.setFree(memory.getAvailable());
  95.         // 创建一个数值格式化对象
  96.         NumberFormat numberFormat = NumberFormat.getInstance();
  97.         // 设置精确到小数点后2位
  98.         numberFormat.setMaximumFractionDigits(2);
  99.         String usedRate = numberFormat.format(mem.getUsed() /  mem.getTotal() * 100);//所占百分比
  100.         mem.setUsedRate(usedRate);
  101.     }
  105.     /** * 设置磁盘信息 */
  106.     private void setSysFiles(OperatingSystem os)
  107.     { 
  108.         FileSystem fileSystem = os.getFileSystem();
  109.         OSFileStore[] fsArray = fileSystem.getFileStores();
  110.         long total = 0;
  111.         long used = 0;
  112.         long free = 0;
  113.         for (OSFileStore fs : fsArray)
  114.         { 
  115.             free += fs.getUsableSpace();
  116.             total += fs.getTotalSpace();
  117.         }
  118.         used = total - free;
  119.         double rate = Arith.mul(Arith.div(used, total, 4), 100);
  120.         sysFiles.setUsage(new StringBuffer().append(rate).toString());
  121.     }
  123.     @Override
  124.     public String toString() { 
  125.         return "Server{" +
  126.                 "cpu=" + getCpu() +
  127.                 "\n, memory=" + getMem() +
  128.                 ",\n sysFiles=" + getSysFiles() +
  129.                 '}';
  130.     }
  132.     public Cpu getCpu() { 
  133.         return cpu;
  134.     }
  136.     public void setCpu(Cpu cpu) { 
  137.         this.cpu = cpu;
  138.     }
  140.     public Mem getMem() { 
  141.         return mem;
  142.     }
  144.     public void setMem(Mem mem) { 
  145.         this.mem = mem;
  146.     }
  148.     public SysFile getSysFiles() { 
  149.         return sysFiles;
  150.     }
  152.     public void setSysFiles(SysFile sysFiles) { 
  153.         this.sysFiles = sysFiles;
  154.     }
  155. }

3.然后创建一个页面显示VO类：

  1. package com.gdhengdian.monitorservice.domain;
  4. import org.springframework.stereotype.Component;
  6. import java.io.Serializable;
  8. @Component
  9. public class SystemResourceInfo implements Serializable { 
  10.     /** * CPU相关信息 */
  11.     private String cpuInfo;
  12.     /** * 內存相关信息 */
  14.     private String ramInfo;
  15.     /** * JVM相关信息 */
  16.     private String fileInfo;
  18.     public String getCpuInfo() { 
  19.         return cpuInfo;
  20.     }
  22.     public void setCpuInfo(String cpuInfo) { 
  23.         this.cpuInfo = cpuInfo;
  24.     }
  26.     public String getRamInfo() { 
  27.         return ramInfo;
  28.     }
  30.     public void setRamInfo(String ramInfo) { 
  31.         this.ramInfo = ramInfo;
  32.     }
  34.     public String getFileInfo() { 
  35.         return fileInfo;
  36.     }
  38.     public void setFileInfo(String fileInfo) { 
  39.         this.fileInfo = fileInfo;
  40.     }
  42.     @Override
  43.     public String toString(){ 
  44.        return getCpuInfo() + "----"+getRamInfo() +"----"+getFileInfo();
  45.     }
  47. }

4.控制器代码如下：

  1. package com.gdhengdian.monitorservice.controller;
  2. import com.gdhengdian.monitorservice.common.HttpRespond;
  3. import com.gdhengdian.monitorservice.domain.SystemResourceInfo;
  4. import com.gdhengdian.monitorservice.service.ServerService;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  10. @RestController
  11. @RequestMapping("/api/v1/monitor")
  12. public class MonitorController { 
  14.     @Autowired
  15.     private ServerService serverService;
  17.     @GetMapping("/system/info")
  18.     public HttpRespond<SystemResourceInfo> getSystemInfo(){ 
  19.         HttpRespond<SystemResourceInfo> respond = serverService.getSystemInfo();
  20.         return respond;
  21.     }
  23. }

5.service代码如下：

  1. package com.gdhengdian.monitorservice.service;
  2. import com.gdhengdian.monitorservice.common.HttpRespond;
  4. public interface ServerService { 
  6.     HttpRespond getSystemInfo();
  7. }

实现类代码如下：

  1. package com.gdhengdian.monitorservice.service.impl;
  4. import com.gdhengdian.monitorservice.common.HttpRespond;
  5. import com.gdhengdian.monitorservice.domain.Server;
  6. import com.gdhengdian.monitorservice.domain.SystemResourceInfo;
  7. import com.gdhengdian.monitorservice.service.ServerService;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.data.redis.core.RedisTemplate;
  10. import org.springframework.data.redis.core.ValueOperations;
  11. import org.springframework.stereotype.Service;
  13. @Service
  14. public class ServerServiceImpl implements ServerService { 
  15.     @Autowired
  16.     private RedisTemplate<String, Object> redisTemplate;
  17.     @Autowired
  18.     Server server;
  19.     @Autowired
  20.     SystemResourceInfo systemResourceInfo;
  21.     /* * 获取系统运行过程的系统数据 */
  22.     @Override
  23.     public HttpRespond<SystemResourceInfo> getSystemInfo() { 
  24.         try { 
  25.             server.copyTo();
  26.             systemResourceInfo.setCpuInfo(server.getCpu().getTotal());
  27.             systemResourceInfo.setRamInfo(server.getMem().getUsedRate());
  28.             systemResourceInfo.setFileInfo(server.getSysFiles().getUsage());
  29.         } catch (Exception e) { 
  30.             e.printStackTrace();
  31.         }
  32.         infoIntoRedis(systemResourceInfo);
  33.         return  HttpRespond.success(systemResourceInfo);
  34.     }
  36.     /** * 将系统运行过程的信息放入Redis * @param systemResourceInfo */
  37.     private void infoIntoRedis(SystemResourceInfo systemResourceInfo) { 
  38.         ValueOperations valueOperations = this.redisTemplate.opsForValue();
  39.         valueOperations.set("systemsource", systemResourceInfo);
  40.     }
  41. }

这里接口返回的格式是使用了自己写的封装类HttpRespond，success方法就是将数据返回给前端页面，这里将所得到的数据存入了redis方便读取，你也可以按照你的业务逻辑进行数据处理。

发表评论

表情：
评论列表 （有 0 条评论，973人围观）

还没有评论，来说两句吧...

相关阅读