import org.rrd4j.core.Sample; //导入依赖的package包/类
@Override
public synchronized void onMessage(TelemetryMessage message) {
    try {
        LOGGER.info("onMessage: message[{}]", message);

        Sample sample = rrdDb.createSample();
        sample.setTime(message.getSampleTime());
        sample.setValue("speed", message.getSpeed());
        sample.setValue("odometer", message.getOdometerReading());
        sample.setValue("batteryPercent", message.getBatteryPercent());
        sample.setValue("elevation", message.getElevation());
        sample.setValue("estHeading", message.getEstHeading());
        sample.setValue("heading", message.getHeading());
        sample.setValue("latitude", message.getLatitude());
        sample.setValue("longitude", message.getLongitude());
        sample.setValue("power", message.getPower());
        sample.setValue("ratedRange", message.getRatedRange());
        sample.setValue("estRange", message.getEstRange());
        sample.update();
    } catch (IOException ex) {
        LOGGER.error("onMessage: Unable to process message.", ex);
    }
}
 

import org.rrd4j.core.Sample; //导入依赖的package包/类
public static void store(List<Integer> data, RrdDb db) {
	StringBuilder sb = new StringBuilder();
	for (Integer value : data) {
		sb.append(value);
		sb.append(':');
	}
	sb.deleteCharAt(sb.length() - 1);

	try {
		Sample sample = db.createSample();
		sample.setAndUpdate(sb.toString());
	} catch (IOException ex) {
		Logger.getLogger(RrdHelper.class.getName()).log(Level.SEVERE, null, ex);
	}
}
 

import org.rrd4j.core.Sample; //导入依赖的package包/类
private final void updateSREventCountGraph(RrdDb rrdDb){
	try {
		Sample sample = rrdDb.createSample();
		int j = studentRecordsService.eventCount().getEventCount();
		sample.setAndUpdate("NOW:" + j);
		rrdDb.close();
	} catch (IOException e) {
		System.out.println(e);
	}
}
 

import org.rrd4j.core.Sample; //导入依赖的package包/类
private final void updateMoodleGraph(RrdDb rrdDb){
	try {
		Sample sample = rrdDb.createSample();
		int j = moodleService.moodleUsers().getMoodleUsersCount();
		sample.setAndUpdate("NOW:" + j);
		rrdDb.close();
	} catch (IOException e) {
		System.out.println(e);
	}
}
 

import org.rrd4j.core.Sample; //导入依赖的package包/类
private void logIntoRRD(RrdDb rrdDb, Double value) throws IOException {
	Sample sample = rrdDb.createSample();
	sample.setValue(name, value);
	sample.update();
	rrdDb.close();
}