Sigar java 服务器信息探针、监控

package org.fh.controller.tools; import java.net.InetAddress; import java.util.HashMap; import java.util.Map; import java.util.Properties; import org.fh.controller.base.BaseController; import org.fh.entity.PageData; import org.hyperic.sigar.CpuInfo; import org.hyperic.sigar.CpuPerc; import org.hyperic.sigar.FileSystem; import org.hyperic.sigar.FileSystemUsage; import org.hyperic.sigar.Mem; import org.hyperic.sigar.NetInterfaceConfig; import org.hyperic.sigar.NetInterfaceStat; import org.hyperic.sigar.Sigar; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; /**  * 说明：服务器信息监控  * 作者：FH Admin  * from：fhadmin.cn  */ @Controller @RequestMapping("/serverRunstate") public class ServerRunstateController extends BaseController {   /**获取常量数据  * @return  */  @RequestMapping(value="/getData")  @ResponseBody  public Object getData() throws Exception{  Map<String,Object> map = new HashMap<String,Object>();  Sigar sigar = new Sigar();  String errInfo = "success";  PageData pd = new PageData();  property(pd);         //基本信息  gethardDiskData(pd,sigar);    //硬盘使用情况  map.put("pd", pd);  map.put("result", errInfo);  return map;  }   /**获取事实数据  * @return  */  @RequestMapping(value="/realTimeData")  @ResponseBody  public Object realTimeData() throws Exception{  Map<String,Object> map = new HashMap<String,Object>();  Sigar sigar = new Sigar();  String errInfo = "success";  PageData pd = new PageData();  getJvmMemoryData(pd);     //JVM内存  getServerMemoryData(pd,sigar);  //服务器内存  getCpuData(pd,sigar);     //CPU  map.put("pd", pd);  map.put("result", errInfo);  return map;  }   /**获取网速  * @return  */  @RequestMapping(value="/networkspeed")  @ResponseBody  public Object networkspeed() throws Exception{  Map<String,Object> map = new HashMap<String,Object>();  Sigar sigar = new Sigar();  String errInfo = "success";  PageData pd = new PageData();  long[] fhbytes1 = getNet(sigar);  Thread.sleep(1000);  long[] fhbytes2 = getNet(sigar);  long rxspeed = fhbytes2[0] - fhbytes1[0];  long txspeed = fhbytes2[1] - fhbytes1[1];  pd.put("rxspeed", (double) Math.round((rxspeed/2014.0) * 100) / 100);   //下载网速  pd.put("txspeed", (double) Math.round((txspeed/1024.0) * 100) / 100);   //上传网速  map.put("pd", pd);  map.put("result", errInfo);  return map;  }   /**获取JVM内存数据  * @param pd  * @return  * @throws Exception  */  private PageData getJvmMemoryData(PageData pd){  double byteToMb = 1024.0 * 1024.0;  double jvmTotal = 0;  double jvmFree = 0;  double jvmUse = 0;  Runtime rt = Runtime.getRuntime();  jvmTotal = rt.totalMemory() / byteToMb;  jvmFree = rt.freeMemory() / byteToMb;  jvmUse = jvmTotal - jvmFree;  pd.put("totalJvmMemory", (double) Math.round(jvmTotal * 100) / 100);    //JVM总内存空间  pd.put("useJvmMemory", (double) Math.round(jvmUse * 100) / 100);      //JVM已使用的内存  return pd;  }   /**获取服务器内存数据  * @param pd  * @param sigar  * @throws Exception  */  private void getServerMemoryData(PageData pd, Sigar sigar) throws Exception {  double byteToGb = 1024.0 * 1024.0 * 1024.0;  double serveotal = 0;  double serverUse = 0;  Mem mem = sigar.getMem();  serveotal = mem.getTotal() / byteToGb;  serverUse = mem.getUsed() / byteToGb;  pd.put("totalServerMemory", (double) Math.round(serveotal * 100) / 100);    //服务器总内存空间  pd.put("useServerMemory", (double) Math.round(serverUse * 100) / 100);      //服务器已使用的内存  }   /**获取服务器CUP使用率  * @param pd  * @param sigar  * @throws Exception  */  private void getCpuData(PageData pd, Sigar sigar) throws Exception {  CpuInfo infos[] = sigar.getCpuInfoList();  CpuPerc cpuList[] = null;  cpuList = sigar.getCpuPercList();  double cpuuse = 0;  for (int i = 0; i < infos.length; i++) {        //多块或者多核心CPU  cpuuse += cpuList[i].getCombined() * 100.00;  }  pd.put("cpuuse", (double) Math.round(((cpuuse/(infos.length * 100))*100) * 100) / 100 );//使用率  }   /**获取服务器硬盘情况  * @param pd  * @param sigar  * @throws Exception  */  private void gethardDiskData(PageData pd, Sigar sigar) throws Exception {  double byteToGb = 1024.0 * 1024.0;  long totalSize = 0;  long useSize = 0;  FileSystem fslist[] = sigar.getFileSystemList();  for (int i = 0; i < fslist.length; i++) {  FileSystem fs = fslist[i];  FileSystemUsage usage = null;  usage = sigar.getFileSystemUsage(fs.getDirName());  switch (fs.getType()) {  case 0: // TYPE_UNKNOWN ：未知  break;  case 1: // TYPE_NONE  break;  case 2: // TYPE_LOCAL_DISK : 本地硬盘  totalSize += usage.getTotal();  //总大小  useSize += usage.getUsed();   //已经使用量  break;  case 3:// TYPE_NETWORK ：网络  break;  case 4:// TYPE_RAM_DISK ：闪存  break;  case 5:// TYPE_CDROM ：光驱  break;  case 6:// TYPE_SWAP ：页面交换  break;  }  }  pd.put("totalDiskSize",(double) Math.round((totalSize / byteToGb) * 10) / 10);  //硬盘总大小  pd.put("useDiskSize",(double) Math.round((useSize / byteToGb) * 10) / 10);    //硬盘已使用大小  }   /**获取基础信息  * @param pd  * @return  * @throws Exception  */  private PageData property(PageData pd) throws Exception {  Runtime r = Runtime.getRuntime();  Properties props = System.getProperties();  InetAddress addr;  addr = InetAddress.getLocalHost();  String ip = addr.getHostAddress();  Map<String, String> map = System.getenv();  String userName = map.get("USERNAME");// 获取用户名  pd.put("userName", userName);     //计算机用户  pd.put("IP", ip);           //本地ip地址  pd.put("HostName", addr.getHostName()); //本地主机名  pd.put("availableProcessors", r.availableProcessors());   //JVM可以使用的处理器个数  pd.put("javaversion", props.getProperty("java.version")); //Java的运行环境版本  pd.put("javahome", props.getProperty("java.home"));     //Java的安装路径  pd.put("javavmversion", props.getProperty("java.vm.specification.version"));  //Java的虚拟机规范版本  pd.put("javavmname", props.getProperty("java.vm.name"));        //Java的虚拟机实现名称  pd.put("javaclassversion", props.getProperty("java.class.version"));  //Java的类格式版本号  pd.put("osarch", props.getProperty("os.arch"));   //操作系统的构架  pd.put("userdir", props.getProperty("user.dir")); //用户的当前工作目录  return pd;  }  /**获取接收字节数  * @return  * @throws Exception  */  private static long[] getNet(Sigar sigar) throws Exception {  long[] fhbytes = new long[2];  String ifNames[] = sigar.getNetInterfaceList();  for (int i = 0; i < ifNames.length; i++) {  String name = ifNames[i];  NetInterfaceConfig ifconfig = sigar.getNetInterfaceConfig(name);  if ((ifconfig.getFlags() & 1L) <= 0L) {  continue;  }  NetInterfaceStat ifstat = sigar.getNetInterfaceStat(name);  long fhRxBytes = ifstat.getRxBytes();  long fhTxBytes = ifstat.getTxBytes();  if(fhRxBytes > 0) {  fhbytes[0] = fhRxBytes;  fhbytes[1] = fhTxBytes;  return fhbytes;  }  }  fhbytes[0] = 0;  fhbytes[1] = 0;  return fhbytes;  }  }