一、获取负载信息部分：
结果部分数据展示：
==⭐==
详情请看点这里↓
相关代码如下：
pojo
import java.util.Date;
import com.geespace.microservices.calculate.execute.engine.bean.ModelField;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.ToString;
/**
* ResourInformation
*
* @Author: liudz
* @Date: 2019-11-07
**/
@Data
@EqualsAndHashCode(callSuper = false)
@ToString(callSuper = true)
public class MachineResourceInfo {
/**
* cpuLoadDetails
*/
@ModelField(name = "CPU负载详情信息", comment = "CPU负载详情信息", size = "500", required = false)
String cpuLoadDetails;
/**
* memoryLoadTotalUsePercent
*/
@ModelField(name = "内存总使用百分比", comment = "内存总使用百分比", size = "500", required = false)
String memoryLoadTotalUsePercent;
/**
* memoryLoadTotal
*/
@ModelField(name = "内存总量", comment = "内存总量", size = "500", required = false)
String memoryLoadTotal;
/**
* memoryLoadUsed
*/
@ModelField(name = "当前内存使用量", comment = "当前内存使用量", size = "500", required = false)
String memoryLoadUsed;
/**
* memoryLoadFree
*/
@ModelField(name = "当前内存剩余量", comment = "当前内存剩余量", size = "500", required = false)
String memoryLoadFree;
/**
* memoryExchangeTotal
*/
@ModelField(name = "内存交换区总量", comment = "内存交换区总量", size = "500", required = false)
String memoryExchangeTotal;
/**
* memoryExchangeUsed
*/
@ModelField(name = "内存当前交换区使用量", comment = "内存当前交换区使用量", size = "500", required = false)
String memoryExchangeUsed;
/**
* memoryExchangeFree
*/
@ModelField(name = "内存当前交换区剩余量", comment = "内存当前交换区剩余量", size = "500", required = false)
String memoryExchangeFree;
/**
* diskLoad
*/
@ModelField(name = "磁盘使用情况", comment = "磁盘使用情况", size = "500", required = false)
String diskLoad;
/**
* diskReadOrWrite
*/
@ModelField(name = "磁盘读写", comment = "磁盘读写", size = "500", required = false)
String diskReadOrWrite;
/**
* jvmHeapMemoryMax
*/
@ModelField(name = "JVM堆内存信息Max", comment = "JVM堆内存信息Max", size = "500", required = false)
String jvmHeapMemoryMax;
/**
* jvmHeapMemoryInit
*/
@ModelField(name = "JVM堆内存信息Init", comment = "JVM堆内存信息Init", size = "500", required = false)
String jvmHeapMemoryInit;
/**
* jvmHeapMemoryCommitted
*/
@ModelField(name = "JVM堆内存信息Committed", comment = "JVM堆内存信息Committed", size = "500", required = false)
String jvmHeapMemoryCommitted;
/**
* jvmHeapMemoryUsed
*/
@ModelField(name = "JVM堆内存信息Used", comment = "JVM堆内存信息Used", size = "500", required = false)
String jvmHeapMemoryUsed;
/**
* jvmNonHeapMemoryMax
*/
@ModelField(name = "JVM非堆内存信息Max", comment = "JVM非堆内存信息Max", size = "500", required = false)
String jvmNonHeapMemoryMax;
/**
* jvmNonHeapMemoryInit
*/
@ModelField(name = "JVM非堆内存信息Init", comment = "JVM非堆内存信息Init", size = "500", required = false)
String jvmNonHeapMemoryInit;
/**
* jvmNonHeapMemoryCommitted
*/
@ModelField(name = "JVM非堆内存信息Committed", comment = "JVM非堆内存信息Committed", size = "500", required = false)
String jvmNonHeapMemoryCommitted;
/**
* jvmNonHeapMemoryUsed
*/
@ModelField(name = "JVM非堆内存信息Used", comment = "JVM非堆内存信息Used", size = "500", required = false)
String jvmNonHeapMemoryUsed;
/**
* jvmTotalMemory
*/
@ModelField(name = "JVM已申请的内存量", comment = "JVM已申请的内存量", size = "500", required = false)
String jvmTotalMemory;
/**
* jvmFreeMemory
*/
@ModelField(name = "JVM空闲的内存量", comment = "JVM空闲的内存量", size = "500", required = false)
String jvmFreeMemory;
/**
* jvmMaxMemory
*/
@ModelField(name = "JVM最大可使用的内存量", comment = "JVM最大可使用的内存量", size = "500", required = false)
String jvmMaxMemory;
/**
* 数据产生时间
*/
private Date createTime;
}
接口
/**
* 获取机器资源信息
*
* @return MachineResourInformation 结果
* @author: liudz
* @date: 2020/4/25 16:45
*/
MachineResourceInfo getMachineResourceInfo();
接口实现类
/**
* 向ES写机器负载信息，并返回给前端
*
* @return
* @author: liudz
* @date: 2020/4/25 16:53
*/
@Override
public MachineResourceInfo getMachineResourceInfo() {
MachineResourceInfo machineResourInfo = null;
try {
machineResourInfo = addParameter1();
MachineResourceInfo finalMachineResourInfo = machineResourInfo;
esExecutorService.submit(() -> {
JSONObject params = (JSONObject) JSONObject.toJSON(finalMachineResourInfo);
ResponseEntity<JSONObject> response = HttpUtils.sendPostRequest(monitorUrl, params);
if (!response.getStatusCode().equals(HttpStatus.CREATED)) {
log.error("spark write ES error:{}", response);
}
});
} catch (SigarException e) {
log.error("AccessEsLogServiceImpl--getMachineResourInfo--error!");
}
return machineResourInfo;
}
/**
* addParameter
*
* @return 结果
* @throws SigarException
* SigarException
* @author: liudz
* @date: 16:52
*/
public MachineResourceInfo addParameter1() throws SigarException {
MachineResourceInfo machineResourceInfo = new MachineResourceInfo();
Sigar sigar = new Sigar();
CpuInfo[] infos = sigar.getCpuInfoList();
CpuPerc[] cpuList = null;
cpuList = sigar.getCpuPercList();
String cpuLoadDetailsUsed = "";
for (int i = 0; i < infos.length; i++) {
cpuLoadDetailsUsed += "第" + (i + 1) + "块CPU总的使用率: " + CpuPerc.format(cpuList[i].getCombined()) + ", ";
}
Mem mem = sigar.getMem();
DecimalFormat df = new DecimalFormat("0.00");
Swap swap = sigar.getSwap();
FileSystem[] fslist = sigar.getFileSystemList();
String diskLoad = "";
String diskReadOrWrite = "";
for (int i = 0; i < fslist.length; i++) {
FileSystem fs = fslist[i];
FileSystemUsage usage = null;
usage = sigar.getFileSystemUsage(fs.getDirName());
double usePercent = usage.getUsePercent() * Double.parseDouble("100D");
diskLoad += fs.getDevName() + "总大小: " + usage.getTotal() + "KB, " + fs.getDevName() + "已经使用量: "
+ usage.getUsed() + "KB, " + fs.getDevName() + "剩余大小: " + usage.getFree() + "KB, " + fs.getDevName()
+ "资源的利用率: " + usePercent + "%";
diskReadOrWrite += fs.getDevName() + "读出：" + usage.getDiskReads() + "扇区, " + fs.getDevName() + "写入："
+ usage.getDiskWrites() + "扇区";
}
machineResourceInfo = addParameter2(df, mem, swap, diskLoad, diskReadOrWrite);
machineResourceInfo.setCpuLoadDetails(cpuLoadDetailsUsed);
return machineResourceInfo;
}
/**
* addParameter2
*
* @param df
* df
* @param mem
* mem
* @param swap
* swap
* @param diskLoad
* diskLoad
* @param diskReadOrWrite
* diskReadOrWrite
* @return machineResourceInfo
* @author: liudz
* @date: 2020/4/27 10:27
*/
public MachineResourceInfo addParameter2(DecimalFormat df, Mem mem, Swap swap, String diskLoad,
String diskReadOrWrite) {
MemoryMXBean memorymbean = ManagementFactory.getMemoryMXBean();
MachineResourceInfo machineResourceInfo = new MachineResourceInfo();
machineResourceInfo.setCreateTime(new Date());
machineResourceInfo.setMemoryLoadTotalUsePercent(
"内存总使用百分比: " + df.format((float) mem.getUsed() / mem.getTotal() * Integer.parseInt("100")) + "%");
machineResourceInfo.setMemoryLoadTotal("内存总量: " + mem.getTotal() / Integer.parseInt("1024") + "K av");
machineResourceInfo.setMemoryLoadUsed("当前内存使用量: " + mem.getUsed() / Integer.parseInt("1024") + "K used");
machineResourceInfo.setMemoryLoadFree("当前内存剩余量: " + mem.getFree() / Integer.parseInt("1024") + "K free");
machineResourceInfo.setMemoryExchangeTotal("内存交换区总量: " + swap.getTotal() / Integer.parseInt("1024") + "K av");
machineResourceInfo
.setMemoryExchangeUsed("内存当前交换区使用量: " + swap.getUsed() / Integer.parseInt("1024") + "K used");
machineResourceInfo
.setMemoryExchangeFree("内存当前交换区剩余量: " + swap.getFree() / Integer.parseInt("1024") + "K free");
machineResourceInfo.setDiskLoad(diskLoad);
machineResourceInfo.setDiskReadOrWrite(diskReadOrWrite);
machineResourceInfo.setJvmHeapMemoryMax("堆内存信息Max: "
+ memorymbean.getHeapMemoryUsage().getMax() / Integer.parseInt("1024") / Integer.parseInt("1024") + " MB");
machineResourceInfo.setJvmHeapMemoryInit("堆内存信息Init: "
+ memorymbean.getHeapMemoryUsage().getInit() / Integer.parseInt("1024") / Integer.parseInt("1024") + " MB");
machineResourceInfo.setJvmHeapMemoryCommitted("堆内存信息Committed: "
+ memorymbean.getHeapMemoryUsage().getCommitted() / Integer.parseInt("1024") / Integer.parseInt("1024")
+ " MB");
machineResourceInfo.setJvmHeapMemoryUsed("堆内存信息Used: "
+ memorymbean.getHeapMemoryUsage().getUsed() / Integer.parseInt("1024") / Integer.parseInt("1024") + " MB");
machineResourceInfo.setJvmNonHeapMemoryMax("非堆内存信息Max: "
+ memorymbean.getNonHeapMemoryUsage().getMax() / Integer.parseInt("1024") / Integer.parseInt("1024")
+ " MB");
machineResourceInfo.setJvmNonHeapMemoryInit("非堆内存信息Init: "
+ memorymbean.getNonHeapMemoryUsage().getInit() / Integer.parseInt("1024") / Integer.parseInt("1024")
+ " MB");
machineResourceInfo.setJvmNonHeapMemoryCommitted("非堆内存信息Committed: "
+ memorymbean.getNonHeapMemoryUsage().getCommitted() / Integer.parseInt("1024") / Integer.parseInt("1024")
+ " MB");
machineResourceInfo.setJvmNonHeapMemoryUsed("非堆内存信息Used: "
+ memorymbean.getNonHeapMemoryUsage().getUsed() / Integer.parseInt("1024") / Integer.parseInt("1024")
+ " MB");
machineResourceInfo.setJvmTotalMemory("JVM已申请的内存量: "
+ Runtime.getRuntime().totalMemory() / Integer.parseInt("1024") / Integer.parseInt("1024") + " MB");
machineResourceInfo.setJvmFreeMemory("JVM空闲的内存量: "
+ Runtime.getRuntime().freeMemory() / Integer.parseInt("1024") / Integer.parseInt("1024") + " MB");
machineResourceInfo.setJvmMaxMemory("JVM最大可使用的内存量: "
+ Runtime.getRuntime().maxMemory() / Integer.parseInt("1024") / Integer.parseInt("1024") + " MB");
return machineResourceInfo;
}
二、使用问题解答
第一种问题：在华为云ARM部署报错：
org.hyperic.sigar.SigarException: no libsigar-aarch64-linux.so in java.libra
解决办法：遇到华为ARM服务器时，需要libsigar-aarch64-linux.so库支持aarch64平台，把“libsigar-aarch64-linux.so”放在linux下的 /usr/lib 和 /usr/lib64 下（都要进行拷贝）
该朋友已经具体介绍，详情点击这里
第二种问题：使用该类常常会遇到问题：
java.lang.UnsatisfiedLinkError: org.hyperic.sigar.SysInfo.gather(Lorg/hyperic/sigar/Sigar;)V
org.hyperic.sigar.SysInfo.gather(Native Method)
org.hyperic.sigar.OperatingSystem.getInstance(OperatingSystem.java:90)
com.shuhaiserver.page.servlet.LoginServlet.doLogin(LoginServlet.java:146)
com.shuhaiserver.page.servlet.LoginServlet.doPost(LoginServlet.java:54)
javax.servlet.http.HttpServlet.service(HttpServlet.java:637)
javax.servlet.http.HttpServlet.service(HttpServlet.java:717)
com.shuhaiserver.page.servlet.MyFilter.doFilter(MyFilter.java:82)
解决办法：
第一种办法：此时，需要将libsigar-amd64-linux.so、libsigar-x86-linux.so、sigar-amd64-winnt.dll、sigar-x86-winnt.dll、sigar-x86-winnt.lib文件放在项目的lib文件夹下
第二种办法：将上面的5个文件放在linux下的 /usr/lib 和 /usr/lib64 下（都要进行拷贝） -----使用场景是linux下启动springboot的jar包 以命令： java -jar xx.jar 运行才会这么做
补充：至于有的水友说的放在tomcat目录或者其他目录，因为我没碰到，需要你们自己测试
还有的朋友说放在java.library.path库下面，我感觉我的/usr/lib或/usr/lib64应该就是这个，具体是不是我不清楚（另外，查看linux下的java.library.path可新建springboot项目，在Application下新建一行打印输出，并打包在linux下以命令 java -jar xx.jar运行即可显示，帖图如下）
