xiaochun.zrlog.com 小春 ' s blog

使用JfreeChart与sigar,quartz绘制CPU使用率

/

在社区中看到有人通过 sigar.jar 包读出了操作系统的硬件信息。 于是产生了强烈的兴趣， 于是就有下面这段代码，利用JfreeChart的 DefaultTableXYDataset 图表做显示。 用quartz做定时刷新数据,sigar 读取系统信息。

Job定时调度

  1. package com.fzb.monitoring.job;
  3. import java.util.Date;
  4. import java.util.HashMap;
  5. import java.util.LinkedList;
  6. import java.util.List;
  7. import java.util.Map;
  9. import org.hyperic.sigar.CpuPerc;
  10. import org.hyperic.sigar.NetInterfaceConfig;
  11. import org.hyperic.sigar.NetInterfaceStat;
  12. import org.hyperic.sigar.Sigar;
  13. import org.hyperic.sigar.SigarException;
  14. import org.jfree.data.xy.DefaultTableXYDataset;
  15. import org.jfree.data.xy.XYDataItem;
  16. import org.jfree.data.xy.XYDataset;
  17. import org.jfree.data.xy.XYSeries;
  18. import org.quartz.Job;
  19. import org.quartz.JobExecutionContext;
  20. import org.quartz.JobExecutionException;
  22. public class CPUJob implements Job {
  25.     private static List<Double> l=new LinkedList<Double>();
  27.     @Override
  28.     public void execute(JobExecutionContext context) throws JobExecutionException {
  29.         Sigar sigar=(Sigar) context.getJobDetail().getJobDataMap().get("sigar");
  30.         DefaultTableXYDataset dataset= (DefaultTableXYDataset) context.getJobDetail().getJobDataMap().get("dataset");
  31.             CpuPerc cpu;
  32.             try {
  33.                 cpu = sigar.getCpuPerc();
  34.                 XYSeries s1 = (XYSeries) context.getJobDetail().getJobDataMap().get("series");
  35.                 if(l.size()>30){
  36.                     l.remove(0);
  37.                     l.add(cpu.getCombined());
  38.                     for(int i=0;i<30;i++){
  39.                         s1.update(i, l.get(i));
  40.                     }
  41.                 }
  42.                 else{
  43.                     l.add(cpu.getCombined());
  44.                     s1.add(l.size(), l.get(l.size()-1));
  45.                 }
  49.                 //s1.update(key-60, );
  51.                 System.out.println("CPU用户使用率:    " + CpuPerc.format(cpu.getUser()));// 用户使用率
  52.                 System.out.println("CPU系统使用率:    " + CpuPerc.format(cpu.getSys()));// 系统使用率
  53.                 System.out.println("CPU当前等待率:    " + CpuPerc.format(cpu.getWait()));// 当前等待率
  54.                 System.out.println("CPU当前错误率:    " + CpuPerc.format(cpu.getNice()));//
  55.                 System.out.println("CPU当前空闲率:    " + CpuPerc.format(cpu.getIdle()));// 当前空闲率
  56.                 System.out.println("CPU总的使用率:    " + CpuPerc.format(cpu.getCombined()));// 总的使用率
  57.         } catch (SigarException e1) {
  58.                 e1.printStackTrace();
  59.             }
  62.         /*String ifNames[];
  63.         try {
  64.             ifNames = sigar.getNetInterfaceList();
  65.             for (int i = 0; i < ifNames.length; i++) {
  66.                 String name = ifNames[i];
  67.                 NetInterfaceConfig ifconfig = sigar.getNetInterfaceConfig(name);
  68.                 System.out.println("网络设备名:    " + name);// 网络设备名
  69.                 System.out.println("IP地址:    " + ifconfig.getAddress());// IP地址
  70.                 System.out.println("子网掩码:    " + ifconfig.getNetmask());// 子网掩码
  71.                 if ((ifconfig.getFlags() & 1L) <= 0L) {
  72.                     System.out.println("!IFF_UP...skipping getNetInterfaceStat");
  73.                     continue;
  74.                 }
  75.                 NetInterfaceStat ifstat = sigar.getNetInterfaceStat(name);
  76.                 System.out.println(name + "接收的总包裹数:" + ifstat.getRxPackets());// 接收的总包裹数
  77.                 System.out.println(name + "发送的总包裹数:" + ifstat.getTxPackets());// 发送的总包裹数
  78.                 System.out.println(name + "接收到的总字节数:" + ifstat.getRxBytes());// 接收到的总字节数
  79.                 System.out.println(name + "发送的总字节数:" + ifstat.getTxBytes());// 发送的总字节数
  80.                 System.out.println(name + "接收到的错误包数:" + ifstat.getRxErrors());// 接收到的错误包数
  81.                 System.out.println(name + "发送数据包时的错误数:" + ifstat.getTxErrors());// 发送数据包时的错误数
  82.                 System.out.println(name + "接收时丢弃的包数:" + ifstat.getRxDropped());// 接收时丢弃的包数
  83.                 System.out.println(name + "发送时丢弃的包数:" + ifstat.getTxDropped());// 发送时丢弃的包数    
  84.             }
  85.         }
  86.         catch (SigarException e) {
  87.             // TODO Auto-generated catch block
  88.             e.printStackTrace();
  89.         }*/
  91.     }
  92. }

quartz和Jfreechart做数据的展示和读取。

  1. package fzb.zcc.my;
  3. import static org.quartz.CronScheduleBuilder.cronSchedule;
  4. import static org.quartz.JobBuilder.newJob;
  5. import static org.quartz.TriggerBuilder.newTrigger;
  7. import java.awt.Font;
  8. import java.util.Date;
  10. import org.hyperic.sigar.Sigar;
  11. import org.jfree.chart.ChartFactory;
  12. import org.jfree.chart.ChartFrame;
  13. import org.jfree.chart.JFreeChart;
  14. import org.jfree.chart.plot.PlotOrientation;
  15. import org.jfree.chart.plot.XYPlot;
  16. import org.jfree.chart.title.LegendTitle;
  17. import org.jfree.chart.title.TextTitle;
  18. import org.jfree.data.xy.DefaultTableXYDataset;
  19. import org.jfree.data.xy.XYDataset;
  20. import org.jfree.data.xy.XYSeries;
  21. import org.quartz.CronTrigger;
  22. import org.quartz.JobDetail;
  23. import org.quartz.ScheduleBuilder;
  24. import org.quartz.Scheduler;
  25. import org.quartz.SchedulerFactory;
  26. import org.quartz.SimpleScheduleBuilder;
  27. import org.quartz.SimpleTrigger;
  28. import org.quartz.Trigger;
  29. import org.quartz.impl.StdSchedulerFactory;
  30. import org.slf4j.Logger;
  31. import org.slf4j.LoggerFactory;
  33. import com.fzb.monitoring.job.CPUJob;
  35. public class FirstCron {
  37.     private static  DefaultTableXYDataset dataset = new DefaultTableXYDataset();
  38.     private static  XYSeries series = new XYSeries("CPU使用率", true, false);
  40.     public void run() throws Exception{
  42.         Logger log=LoggerFactory.getLogger(FirstCron.class);
  44.         SchedulerFactory sf = new StdSchedulerFactory();
  45.         Scheduler scher=sf.getScheduler();
  47.         JobDetail job = newJob(CPUJob.class)
  48.                 .withIdentity("job1", "group1")
  49.                 .build();
  51.         job.getJobDataMap().put("dataset", dataset);
  54.         job.getJobDataMap().put("sigar", new Sigar());
  55.         job.getJobDataMap().put("series", series);
  57.         dataset.addSeries(series);
  59.         JFreeChart chart=ChartFactory.createXYAreaChart("使用JfreeChart与sigar绘制CPU使用率","", "",(XYDataset)job.getJobDataMap().get("dataset") ,PlotOrientation.VERTICAL, true,true,true);
  61.         //title(上部分)
  62.         TextTitle title=chart.getTitle();
  63.         title.setFont(new Font("幼圆", Font.BOLD, 20));
  64.         //legend（底部）
  65.         LegendTitle legend=chart.getLegend();
  66.         legend.setItemFont(new Font("华文彩云", Font.ITALIC, 14));
  67.         //plot(中部)
  68.         XYPlot plot=chart.getXYPlot();
  69.         //plot.set.setLabelFont(new Font("宋体",Font.BOLD,16));
  72.         ChartFrame frame=new ChartFrame("JAVA绘制CPU使用率", chart);
  74.         frame.pack();
  75.         frame.setVisible(true);
  77.         Trigger trigger = newTrigger()
  78.                 .withIdentity("trigger1", "group1") 
  79.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule().repeatSecondlyForever(2))
  80.                 .build();
  82.         scher.scheduleJob(job, trigger);
  84.         log.info(scher.getJobGroupNames()+"");
  87.         scher.start();
  90.     }
  92.     public static void main(String[] args) {
  93.         try {
  94.             new FirstCron().run();
  95.         } catch (Exception e) {
  96.             e.printStackTrace();
  97.         }
  98.     }
  99. }

好像好久都没有做过图形化东西了。 这次总算是给我逮到机会了。上图一张

Reproduced please indicate the author and the source, and error a link to this page.
text link: //xiaochun.zrlog.com/70.html

Next article：Struts2 中拦截器的 invoke(); 和invokeActionOnly()的区别

Last article：SpringMVC 中的上传下载