src/org/objectweb/cjdbc/console/monitoring/MonitoringGraph.java

説明を見る。

package org.objectweb.cjdbc.console.monitoring;

import java.io.File;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;

import javax.swing.JFrame;

import org.jfree.chart.ChartFactory;
import org.jfree.chart.ChartPanel;
import org.jfree.chart.ChartUtilities;
import org.jfree.chart.JFreeChart;
import org.jfree.chart.plot.PlotOrientation;
import org.jfree.data.XYSeries;
import org.jfree.data.XYSeriesCollection;
import org.jfree.ui.RefineryUtilities;
import org.objectweb.cjdbc.common.monitor.AbstractDataCollector;
import org.objectweb.cjdbc.console.jmx.DataCollectorJmxClient;

public class MonitoringGraph extends Thread
{
  /*
   * Graph Components
   */
  private AbstractDataCollector  collector;
  private JFreeChart             chart;
  private ChartPanel             panel;
  private XYSeries               series;
  private XYSeriesCollection     dataset;
  private DataCollectorJmxClient jmxClient;
  private JFrame                 frame;

  /*
   * Graph settings
   */
  private int                    frameHeight           = 250;
  private int                    frameWidth            = 600;
  private long                   frequency             = 1000;
  private long                   displayFrequency      = 10;
  private long                   poolingSpeed          = 1;
  private long                   timeStarted;
  private int                    timeFrame             = 10;
  private long                   repeat                = -1;
  private boolean                stop                  = false;
  private boolean                framed                = true;
  private boolean                saveOnFinish          = false;
  private boolean                display               = true;
  private String                 text                  = "";

  // Buffer values
  private long                   displayFrequencyCount = 0;
  private XYSeries               buffer;

  public MonitoringGraph(AbstractDataCollector collector,
      DataCollectorJmxClient jmxClient)
  {
    this.collector = collector;
    this.jmxClient = jmxClient;

    buffer = new XYSeries("Buffer");

    series = new XYSeries(collector.getTargetName());
    series.setMaximumItemCount(timeFrame);
    dataset = new XYSeriesCollection(series);
    chart = ChartFactory.createXYLineChart(collector.getDescription(), "Time",
        "", dataset, PlotOrientation.VERTICAL, true, false, false);
    panel = new ChartPanel(chart);
    panel.setSize(frameWidth, frameHeight);

    if (display)
      display();
  }

  public void display()
  {
    chart.setBorderVisible(false);
    panel.setVisible(true);
    if (framed)
    {
      frame = new JFrame(collector.getDescription());
      frame.getContentPane().add(panel);
      frame.setSize(new java.awt.Dimension(frameWidth, frameHeight));
      RefineryUtilities.centerFrameOnScreen(frame);
      frame.setVisible(true);
      frame.setDefaultCloseOperation(JFrame.HIDE_ON_CLOSE);
    }
  }

  public void addData(long newValue)
  {
    long now = (System.currentTimeMillis() / 1000) - timeStarted;
    if (displayFrequency == 0)
    {
      series.add(now, newValue);
    }
    else if (displayFrequencyCount < displayFrequency)
    {
      displayFrequencyCount++;
      buffer.add(now, newValue);
    }
    else
    {
      int count = buffer.getItemCount();
      for (int i = 0; i < count; i++)
      {
        series.add(buffer.getDataItem(i));
      }
      buffer = new XYSeries("buffer");
      displayFrequencyCount = 0;
    }
  }

  public void saveAs() throws IOException
  {
    String fileName = collector.getTargetName() + "-"
        + new SimpleDateFormat().format(new Date());
    ChartUtilities.saveChartAsJPEG(new File(fileName), this.chart, frameWidth,
        frameHeight);
  }

  public void run()
  {
    timeStarted = System.currentTimeMillis() / 1000;
    int count = 0;
    while (repeat == -1 || count < repeat)
    {
      count++;
      synchronized (this)
      {
        try
        {
          addData(jmxClient.retrieveData(collector));
          wait(frequency);
          if (stop)
            break;

          if (display == true && panel.isShowing() == false)
          {
            if (panel.getParent().isShowing() == false)
              stop = true;
          }

        }
        catch (Exception e)
        {
          stop = true;
          throw new RuntimeException(e.getMessage());
        }
      }
    }
    if (saveOnFinish)
    {
      try
      {
        saveAs();
      }
      catch (Exception e)
      {
        //ignore
      }
    }
  }

  public AbstractDataCollector getCollector()
  {
    return collector;
  }

  public void setCollector(AbstractDataCollector collector)
  {
    this.collector = collector;
  }

  public JFrame getFrame()
  {
    return frame;
  }

  public void setFrame(JFrame frame)
  {
    this.frame = frame;
  }

  public boolean getFramed()
  {
    return framed;
  }

  public void setFramed(boolean framed)
  {
    this.framed = framed;
  }

  public long getFrequency()
  {
    return frequency;
  }

  public void setFrequency(long frequency)
  {
    this.frequency = frequency;
  }

  public long getRepeat()
  {
    return repeat;
  }

  public void setRepeat(long repeat)
  {
    this.repeat = repeat;
  }

  public boolean getStop()
  {
    return stop;
  }

  public void setStop(boolean stop)
  {
    this.stop = stop;
  }

  public int getTimeFrame()
  {
    return timeFrame;
  }

  public void setTimeFrame(int timeFrame)
  {
    this.timeFrame = timeFrame;
    series.setMaximumItemCount(timeFrame);
  }

  public JFreeChart getChart()
  {
    return chart;
  }

  public ChartPanel getPanel()
  {
    return panel;
  }

  public long getTimeStarted()
  {
    return timeStarted;
  }

  public boolean getDisplay()
  {
    return display;
  }

  public void setDisplay(boolean display)
  {
    this.display = display;
  }

  public int getFrameHeight()
  {
    return frameHeight;
  }

  public void setFrameHeight(int frameHeight)
  {
    this.frameHeight = frameHeight;
  }

  public int getFrameWidth()
  {
    return frameWidth;
  }

  public void setFrameWidth(int frameWidth)
  {
    this.frameWidth = frameWidth;
  }

  public boolean getSaveOnFinish()
  {
    return saveOnFinish;
  }

  public void setSaveOnFinish(boolean saveOnFinish)
  {
    this.saveOnFinish = saveOnFinish;
  }

  public String getText()
  {
    return text;
  }

  public void setText(String text)
  {
    this.text = text;
  }

  public long getPoolingSpeed()
  {
    return poolingSpeed;
  }

  public void setPoolingSpeed(long poolingSpeed)
  {
    this.poolingSpeed = poolingSpeed;
  }

  public long getDisplayFrequency()
  {
    return displayFrequency;
  }

  public void setDisplayFrequency(long displayFrequency)
  {
    this.displayFrequency = displayFrequency;
  }
}

---