RRD_rrd4j的使用说明

本文参考：

rrd4j的介绍和使用：http://blog.chinaunix.net/uid-29962463-id-4568454.html

rrdtool的介绍和使用：http://www.cnblogs.com/smallcoderhujin/p/3796599.html

rrdtool官网：http://oss.oetiker.ch/rrdtool/doc/rrdtool.en.html

rrd4j的maven依赖：

<dependency><groupId>org.rrd4j</groupId><artifactId>rrd4j</artifactId><version>3.1</version>
</dependency>

RRD说明和注意事项

1.RRD数据库是一种环形数据库，使用rrd4j存储只能存储double类型的值

2.RRD数据库的存储是基于时间的，比如时间间隔是5分钟，在9点0分和9点5分可以存储，如果9点3分传入一个值而指针又指在9点0分的时候，

这个值会记录在9点0分（指针看3），如果指针指在9点5分，这个插入的值失效。

3.RRD数据库创建需要一个时间，这个时间可以自己指定，也可以使用默认时间（默认时间是当前时间-10秒，默认步长是5分钟），

之后RRD数据库会有一个类似指针的标记，创建数据库时指针会指在初始时间点上。这时候如果插入数据会有以下几种情况：

1.如果我们插入的数据的时间和指针所指的时间一致，那么就会顺利插入到数据中。2.如果我们插入的数据的时间在指针所指的时间之后，比如指针指在9点0分，我们插入的数据在9点30分，那么这个时候的插入是失效的（即9点30分的值还是之前的值），但是会将指针拨到9点35分。（因为更新了一次，所以指针向下移动了一位，这样之后在9点35分插入的值就可以顺利入库了。）3.指针只能前移，不能向回移动，也就是4所说的，除非指针循环了一圈，不然库中的数据更改不了。

4.向数据库中插入数据后，指针会向下移动，这时如果想更改指针之前的值无效，指针不会向回移动。

Demo

1.rrd数据库的创建

//全局常量
private static final String file_path = "D:/demo.rrd"; public String createRrd() throws Exception{//设置创建时间（unix时间戳）long start = 1494378000L;//创建RrdDef，每300s接受一个新数据(unix时间戳)，如果不传入创建时间，默认为当前时间的前10秒RrdDef rrdDef = new RrdDef(file_path, start, 300);//添加数据源,"score"相当于数据源名称，第二个参数为数据源类型，第三个参数为心跳，一般设置为step的两倍rrdDef.addDatasource("score", DsType.GAUGE, 600, 0, Double.NaN);//一个数据库可以添加多个数据源rrdDef.addDatasource("class", DsType.GAUGE, 600, 0, Double.NaN);//创建RRA档，AVERAGE是取平均值，xff为0.5（不用管），steps表示几个PDP合成一个CDP，rows表示数据库一共有多少列数据，RRA档在绘图的时候会用到rrdDef.addArchive(ConsolFun.AVERAGE, 0.5, 1, 30*24*12);//环形数据库一共存储一个月的数据//可以创建多个RRA，比如我要记录5个人成绩的平均分和总分，可以如下：rrdDef.addArchive(ConsolFun.AVERAGE, 0.5, 5, 30*24*12);rrdDef.addArchive(ConsolFun.TOTAL, 0.5, 5, 30*24*12);//根据数据库的定义创建rrd数据库RrdDb db = new RrdDb(rrdDef);//数据库需要关闭db.close();return null;
}

2.rrd数据库的数据添加

public String addOrUpdateRrdResource(Student student) throws Exception {RrdDb db = new RrdDb(file_path);//创建样本Sample sample = db.createSample(); sample.setTime(student.getTime());  //设置样本的创建时间sample.setValues("score", student.getScore()); //添加值sample.setValues("class", student.getClass());//保存至数据库中sample.update();//数据库必须关闭，否则样本无法存入到数据库中db.close();return null;
}

3.rrd数据库的数据查询

public List<Student> selectRrdResource(long startTime, long endTime) throws Exception {RrdDb db = new RrdDb(file_path);//设置查询条件，这个AVERAGE必须和创建RRA档的类型对上，不然会出错FetchRequest request = db.createFetchRequest(ConsolFun.AVERAGE, startTime/1000, endTime/1000);FetchData fetchData = request.fetchData();List<Student> stuList = new ArrayList<Student>();double[] scoreArr = fetchData.getValues("score"); //获取分数double[] classArr = fetchData.getValues("class"); //获取班级编号try {for (int i = 0; i < scoreArr.length; i++) {Student stu = new Student();stu.setScore(scoreArr[i]);stu.setClass(classArr[i]);stuList.add(stu);               }} catch (Exception e) {e.printStackTrace();}finally {try {db.close();} catch (IOException e) {}}return stuList;
}

4.绘制图表

public String showRrdGraph(String imgPath, long startTime, long endTime) throws Exception {RrdGraphDef gDef = new RrdGraphDef();gDef.setWidth(600);gDef.setHeight(400);gDef.setFilename(imgPath);  //设置图片的保存路径gDef.setStartTime(startTime/1000);gDef.setEndTime(endTime/1000);gDef.setTitle("Student-Score-Class");gDef.setImageFormat("png"); //设置图片格式，可以设置为png，pdf等//从数据库中获取数据：Score表示你取的数据的别名，file_path：数据库路径，score：数据源，AVERAGE：类型gDef.datasource("Score", file_path, "score", ConsolFun.AVERAGE);gDef.datasource("Class", file_path, "class", ConsolFun.AVERAGE);//定义线状图:Score代表上一步你取的别名，Green是颜色，score表示在图片上的显示的这条线的名称gDef.line("Score", Color.GREEN, "score");gDef.line("Class", Color.BLACK, "class");       //rrd4j提供了定义面积图形，和定义线状图差不多//gDef.area(...);//创建图表new RrdGraph(gDef);return null;
}