0
rrd4j를 사용하여 세션 수를 주기적으로 (1 시간주기) 저장하고 있습니다. xml을 보면 데이터가 성공적으로 업데이트 된 것으로 보이지만 RrdGraph를 호출하면 프로세스가 중단됩니다. 초기화, 수정 및 생성을위한 코드는 다음과 같습니다.rrd4j로 그래프를 그릴 때 문제가 발생했습니다.
nodeCount를 2로 설정하고 random 함수를 사용하여 데이터를 채 웁니다.
import static org.rrd4j.ConsolFun.AVERAGE;
import static org.rrd4j.ConsolFun.MAX;
import java.awt.Color;
import java.io.IOException;
import java.util.Date;
import org.rrd4j.DsType;
import org.rrd4j.core.RrdDb;
import org.rrd4j.core.RrdDef;
import org.rrd4j.core.Sample;
import org.rrd4j.core.Util;
import org.rrd4j.graph.RrdGraph;
import org.rrd4j.graph.RrdGraphDef;
public class Add2RRD {
static final String FILE = "sessionCount";
static final Date currentDate = new Date();
static final long SECINDAY = 24 * 3600;
static final long MAX_STEP = 3600L;// one hour
static final int IMG_WIDTH = 700;
static final int IMG_HEIGHT = 500;
private String rrdPath = null;
private String xmlPath = null;
private String imgPath = null;
private String rrdRestoredPath = null;
private long debugTimestamp = 0L;
private int nodeCount;
private int rows;
private static Add2RRD add2rrd = null;
private Add2RRD() {
debugTimestamp = Util.getTimestamp();
rrdPath = Util.getRrd4jDemoPath(FILE + ".rrd");
xmlPath = Util.getRrd4jDemoPath(FILE + ".xml");
imgPath = Util.getRrd4jDemoPath(FILE + ".png");
rrdRestoredPath = Util.getRrd4jDemoPath(FILE + "_restored.rrd");
rows = (int) ((JMXProbe.reportRange * 24 * 60 * 60)/MAX_STEP);
// rows = 24;
}
public static Add2RRD getInstance() {
if (null == add2rrd) {
add2rrd = new Add2RRD();
}
return add2rrd;
}
public void initRRD() throws IOException {
long start = Util.getTimestamp();
RrdDef rrdDef = new RrdDef(rrdPath, start, MAX_STEP);
for (int i = 1; i < nodeCount + 1; i++) {
rrdDef.addDatasource("Node" + i, DsType.GAUGE, MAX_STEP * 2, 0,
Double.NaN);
}
rrdDef.addArchive(MAX, 0.5, 1, rows);
println(rrdDef.dump());
println("Estimated file size: " + rrdDef.getEstimatedSize());
RrdDb rrdDb = new RrdDb(rrdDef);
println("RRD file created.");
rrdDb.close();
println("RRD file closed.");
}
public void updateRRD(long timeStamp, Long[] values) throws IOException {
RrdDb rrdDb = new RrdDb(rrdPath);
Sample sample = rrdDb.createSample();
debugTimestamp += MAX_STEP;
// System.out.println(debugTimestamp);
sample.setTime(debugTimestamp);
for (int i = 0; i < values.length; i++) {
sample.setValue("Node" + (i + 1), Math.round(values[i]));
}
println("Update dump" + sample.dump());
sample.update();
rrdDb.close();
println("RRD file updated " + debugTimestamp);
}
public RrdDb createRRDRestorePoint() throws IOException {
RrdDb rrdDb = new RrdDb(rrdPath);
rrdDb.exportXml(xmlPath);
println("Creating RRD file " + rrdRestoredPath + " from XML file "
+ xmlPath);
RrdDb rrdRestoredDb = new RrdDb(rrdRestoredPath, xmlPath);
println("== Closing both RRD files");
rrdDb.close();
return rrdRestoredDb;
}
public void createRRDGraph() throws IOException {
RrdDb rrdRestoredDb = createRRDRestorePoint();
RrdDef rrdDef = rrdRestoredDb.getRrdDef();
int dsCount = rrdDef.getDsCount();
System.out.println(" dsCount " + dsCount);
RrdGraphDef gDef = new RrdGraphDef();
gDef.setWidth(IMG_WIDTH);
gDef.setHeight(IMG_HEIGHT);
gDef.setFilename(imgPath);
long start = Util.getTimestamp() + + (2 * 60 * 60), end = start + (18 * 60 * 60);
/* FetchRequest request = rrdRestoredDb.createFetchRequest(AVERAGE, start, end);
println(request.dump());
FetchData fetchData = request.fetchData();
println("Data fetched. " + fetchData.getRowCount()
+ " points obtained");
println(fetchData.toString());*/
rrdRestoredDb.close();
//gDef.datasource("nodeName", fetchData);
gDef.setStartTime(start);
gDef.setEndTime(end);
gDef.setTitle(" Session Count : ");//+ new Date().getMonth());
gDef.setVerticalLabel("Session Count");
for (int i = 0; i < dsCount; i++) {
String nodeName = "Node" + (i + 1);
System.out.println(" nodeName " + nodeName);
gDef.datasource(nodeName, rrdPath, nodeName, AVERAGE);
gDef.line(nodeName, Color.GREEN, nodeName + " count");
gDef.gprint(nodeName, MAX, nodeName + " max = %.3f%s");
gDef.gprint(nodeName, AVERAGE, nodeName + " avg = %.3f%S\\r");
gDef.print(nodeName, MAX, nodeName +" max = %.3f%s");
gDef.print(nodeName, AVERAGE, nodeName +" avg = %.3f%S\\r");
}
gDef.setImageInfo("");
gDef.setPoolUsed(false);
gDef.setImageFormat("png");
println("Rendering graph " + Util.getLapTime());
RrdGraph graph = new RrdGraph(gDef);
println(graph.getRrdGraphInfo().dump());
println("Graph created " + Util.getLapTime());
}
public void setNodeCount(int nodeCount) {
this.nodeCount = nodeCount;
}
static void println(String msg) {
System.out.println(msg);
}
static void print(String msg) {
System.out.print(msg);
}
}
내 생성 된 XML은 다음과 같습니다
<rrd>
<!-- RRD4J, version 0.1 -->
<version>0003</version>
<!-- Seconds -->
<step>3600</step>
<!-- Sat Nov 17 15:32:33 GMT+05:30 2012 -->
<lastupdate>1353146553</lastupdate>
<ds>
<name>Node1</name>
<type>GAUGE</type>
<minimal_heartbeat>7200</minimal_heartbeat>
<min>+0.0000000000E00</min>
<max>NaN</max>
<!-- PDP Status -->
<last_ds>+9.4000000000E01</last_ds>
<value>+1.4382000000E04</value>
<unknown_sec>0</unknown_sec>
</ds>
<ds>
<name>Node2</name>
<type>GAUGE</type>
<minimal_heartbeat>7200</minimal_heartbeat>
<min>+0.0000000000E00</min>
<max>NaN</max>
<!-- PDP Status -->
<last_ds>+2.9000000000E01</last_ds>
<value>+4.4370000000E03</value>
<unknown_sec>0</unknown_sec>
</ds>
<rra>
<cf>MAX</cf>
<!-- 3600 seconds -->
<pdp_per_row>1</pdp_per_row>
<xff>+5.0000000000E-01</xff>
<cdp_prep>
<ds>
<value>NaN</value>
<unknown_datapoints>0</unknown_datapoints>
</ds>
<ds>
<value>NaN</value>
<unknown_datapoints>0</unknown_datapoints>
</ds>
</cdp_prep>
<database>
<!-- Thu Nov 15 16:30:00 GMT+05:30 2012/1352977200 -->
<row>
<v>NaN</v>
<v>NaN</v>
</row>
<!-- Thu Nov 15 17:30:00 GMT+05:30 2012/1352980800 -->
<row>
<v>NaN</v>
<v>NaN</v>
</row>
.
.
.
<!-- Sat Nov 17 14:30:00 GMT+05:30 2012/1353142800 -->
<row>
<v>+1.3317000000E02</v>
<v>+5.5107500000E01</v>
</row>
<!-- Sat Nov 17 15:30:00 GMT+05:30 2012/1353146400 -->
<row>
<v>+9.5657500000E01</v>
<v>+3.0147500000E01</v>
</row>
</database>
</rra>
</rrd>
어떤 도움을 주시면 감사하겠습니다.