`
cleaneyes
  • 浏览: 342450 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

简单封装JRobin1.4

 
阅读更多
	// datasource类型	private static final String DS_TYPE = "GAUGE";

	// 默认从多个数据中取综合值的方式
	private static final ConsolFun DEFAULT_CONSOL_FUN = ConsolFun.MAX;

	// 默认曲线形状
	private static final ChartSeries DEFAULT_CHART_SERIES = ChartSeries.LINE;

	// 默认图片格式
	private static final GraphFormat DEFAULT_GRAPH_FORMAT = GraphFormat.PNG;

	// 默认顺序颜色
	private static final Color[] colors = new Color[] { Color.GREEN,
			Color.BLUE, Color.CYAN, Color.ORANGE, Color.PINK, Color.MAGENTA,
			Color.GRAY, Color.DARK_GRAY };
	

	/**
	 * 向RRD文件,插入数据
	 * 
	 * @param rrdPath
	 *            RRD文件路径
	 * @param dsNames dsName数组,类似于数据表的栏位概念
	 * @param values
	 * @param collectTimeUnitsSecond
	 *            数据所在时间,以秒为单位
	 * @throws RrdException
	 * @throws IOException
	 */
	public static void insertRrdData(String rrdPath, String[] dsNames,
			double[] values, long collectTimeUnitsSecond) throws RrdException,
			IOException {
		if (dsNames != null && dsNames.length > 0) {
			// 取得RRD数据库连接池
			RrdDbPool rrdPool = RrdDbPool.getInstance();

			// 取得rrd数据库文件
			RrdDb rrdDb = rrdPool.requestRrdDb(rrdPath);

			// 创建rrd记录
			Sample sample = rrdDb.createSample(collectTimeUnitsSecond);
			for (int i = 0; i < values.length; i++) {
				sample.setValue(dsNames[i], values[i]);
			}
			// update database
			sample.update();
			// release RRD database reference
			rrdPool.release(rrdDb);
		}
	}

	/**
	 * 重新创建RRD文件
	 * @param rrdPath RRD文件路径
	 * @param dsNames dsName数组,类似于数据表的栏位概念
	 * @param archiveModels 
	 * @param startTime 插入的数据不能早于这个时间,为0时,将默认使用当前时间
	 * @param rrdStep RRD文件接收数据的频率,即多少秒接收一次数据
	 * @throws RrdException
	 * @throws IOException
	 */
	public static void createRrdFile(String rrdPath, String[] dsNames,
			Collection<JRobinArchiveModel> archiveModels, long startTime,
			long rrdStep) throws RrdException, IOException {		
		RrdDef rrdDef = null;

		long step = rrdStep;

		// create RRD file since it does not exist
		if (step > 0) {
			if (startTime > 0) {
				rrdDef = new RrdDef(rrdPath, startTime - 1, step);
			} else {
				rrdDef = new RrdDef(rrdPath, startTime - 1);
			}
		} else {
			rrdDef = new RrdDef(rrdPath);
		}

		// (String dsName, String dsType, long heartbeat,double minValue,
		// double maxValue)
		for (int i = 0; i < dsNames.length; i++) {
			rrdDef.addDatasource(dsNames[i], DS_TYPE, 600, Double.NaN,
					Double.NaN);
		}

		for (Iterator<JRobinArchiveModel> iterator = archiveModels.iterator(); iterator
				.hasNext();) {
			JRobinArchiveModel robinArchiveModel = iterator.next();
			ConsolFun consolFun = robinArchiveModel.getConsolFun();
			if (consolFun == null) {
				consolFun = DEFAULT_CONSOL_FUN;
			}
			rrdDef.addArchive(consolFun.toString(), 0.5, robinArchiveModel
					.getSteps(), robinArchiveModel.getRows());
		}

		// create RRD file in the pool
		RrdDbPool rrdPool = RrdDbPool.getInstance();
		RrdDb rrdDb = rrdPool.requestRrdDb(rrdDef);
		
		rrdPool.release(rrdDb);
	}
	

	/**
	 * 返回生成图片的字节码,而不写入文件
	 * @param chartModels 一组曲线定义对象
	 * @param graphingParam 绘图的基本参数
	 * @return
	 * @throws RrdException
	 * @throws IOException
	 */
	public static byte[] graphBytes(Collection<JRobinChartModel> chartModels,
			JRobinGraphingParam graphingParam) throws RrdException, IOException {
		byte[] bytes = null;

		RrdGraph rrdGraph = constructionRrdGraph(chartModels, graphingParam);

		// 取得图形的字节码
		if (!graphingParam.isUseCustomGraphSizeFlag()) {
			bytes = byteGraph(rrdGraph, graphingParam.getGraphFormat());
		} else {
			bytes = byteGraph(rrdGraph, graphingParam.getGraphFormat(),
					graphingParam.getWidth(), graphingParam.getHeight(),
					graphingParam.getQuality());
		}
		return bytes;
	}

	/**
	 * 返回生成图片输出到指定文件(文件位置由JRobinGraphingParam对象的grapfilePath指定)
	 * @param chartModels 一组曲线定义对象
	 * @param graphingParam 绘图的基本参数
	 * @throws RrdException
	 * @throws IOException
	 */
	public static void graphing(Collection<JRobinChartModel> chartModels,
			JRobinGraphingParam graphingParam)
			throws RrdException, IOException {

		RrdGraph rrdGraph = constructionRrdGraph(chartModels, graphingParam);
		// 保存图形到文件
		if (!graphingParam.isUseCustomGraphSizeFlag()) {
			saveGraph(rrdGraph, graphingParam.getGraphFormat(), graphingParam.getGrapfilePath());
		} else {
			saveGraph(rrdGraph, graphingParam.getGraphFormat(), graphingParam
					.getWidth(), graphingParam.getHeight(), graphingParam
					.getQuality(), graphingParam.getGrapfilePath());
		}
	}

	/**
	 * 构建RrdGraph图形对象
	 * @param chartModels
	 * @param graphingParam
	 * @return
	 * @throws RrdException
	 */
	private static RrdGraph constructionRrdGraph(
			Collection<JRobinChartModel> chartModels,
			JRobinGraphingParam graphingParam) throws RrdException {
		// 图形
		RrdGraph rrdGraph = null;
		String defaultRrdPath = graphingParam.getRrdPath();

		int legendColumns = graphingParam.getLegendColumns();
		if (legendColumns == 0) {
			legendColumns = 1;
		}

		// 图形定义
		RrdGraphDef graphDef = new RrdGraphDef();

		// 指定数据的时间跨度
		graphDef.setTimePeriod(graphingParam.getStartTime(), graphingParam
				.getEndTime());

		// 不显示JRobin的签名
		graphDef.setShowSignature(false);
		// 中文字体
		graphDef.setDefaultFont(new Font("Monospaced", Font.PLAIN, 11));
		graphDef.setTitleFont(new Font("SansSerif", Font.BOLD, 14));

		// 标题
		if (graphingParam.getTitle() != null) {
			graphDef.setTitle(graphingParam.getTitle());
		}

		// 指定Y轴取值范围
		if (graphingParam.isUseCustomGridYRangeFlag()) {
			graphDef.setGridRange(graphingParam.getGridYLower(), graphingParam
					.getGridYUpper(), true);
		}

		int i = 0;
		for (Iterator<JRobinChartModel> iterator = chartModels.iterator(); iterator
				.hasNext(); i++) {
			JRobinChartModel robinChartModel = iterator.next();

			// 合并方式
			ConsolFun consolFun = robinChartModel.getConsolFun();
			if (consolFun == null) {
				consolFun = DEFAULT_CONSOL_FUN;
			}

			// 曲线颜色
			Color color = robinChartModel.getColor();
			if (color == null) {
				color = colors[i % colors.length];
			}

			// 曲线说明
			String legend = robinChartModel.getLegend();
			// 曲线形状
			ChartSeries chartSeries = robinChartModel.getChartSeries();

			// 数据源名称
			String dsName = robinChartModel.getDsName();
			// 曲线标识
			String lineName = dsName + "_" + consolFun.toString();

			String rrdPath = robinChartModel.getRrdPath();
			//如果robinChartModel未指定rrdPath,则使用JRobinGraphingParam对象的rrdPath
			if (rrdPath == null || rrdPath.trim().length() == 0){
				rrdPath = defaultRrdPath;
			}
			// 加入该曲线的相关数据
			graphDef
					.datasource(lineName, rrdPath, dsName, consolFun.toString());

			// 根据每行显示几个legend,加入换行符
			if ((i + 1) % legendColumns == 0) {
				legend += "\n";
			}
			// 绘制曲线
			graphingChar(graphDef, chartSeries, lineName, color, legend);
		}

		// 注释
		graphDef.comment(graphingParam.getComment());

		// 图形
		rrdGraph = new RrdGraph(graphDef);

		return rrdGraph;
	}

	/**
	 * 绘制一条曲线到graphDef
	 * 
	 * @param graphDef 定义图形的对象
	 * @param chartSeries 线型
	 * @param dsName 
	 * @param color
	 * @param legend
	 * @throws RrdException
	 */
	private static void graphingChar(RrdGraphDef graphDef,
			ChartSeries chartSeries, String dsName, Color color, String legend)
			throws RrdException {
		if (chartSeries == null) {
			chartSeries = DEFAULT_CHART_SERIES;
		}

		// 根据不同的图形形状类别,调用不同的方法
		if (chartSeries.equals(ChartSeries.LINE)) {
			graphDef.line(dsName, color, legend);
		} else if (chartSeries.equals(ChartSeries.AREA)) {
			graphDef.area(dsName, color, legend);
		} else if (chartSeries.equals(ChartSeries.STACK)) {
			graphDef.stack(dsName, color, legend);
		}
	}

	/**
	 * 按默认宽高,生成图片文件
	 * 
	 * @param rrdGraph 
	 * @param graphFormat
	 * @param graphingPath
	 * @throws RrdException
	 * @throws IOException
	 */
	private static void saveGraph(RrdGraph rrdGraph, GraphFormat graphFormat,
			String graphingPath) throws RrdException, IOException {
		if (graphFormat == null) {
			graphFormat = DEFAULT_GRAPH_FORMAT;
		}

		if (graphFormat.equals(GraphFormat.PNG)) {
			rrdGraph.saveAsPNG(graphingPath);
		} else if (graphFormat.equals(GraphFormat.GIF)) {
			rrdGraph.saveAsGIF(graphingPath);
		} else if (graphFormat.equals(GraphFormat.JPEG)) {
			rrdGraph.saveAsJPEG(graphingPath, 0.5f);
		}
	}

	/**
	 * 按指定宽高生成图片文件
	 * 
	 * @param rrdGraph
	 * @param graphFormat
	 * @param width
	 * @param height
	 * @param quality
	 * @param graphingPath
	 * @throws RrdException
	 * @throws IOException
	 */
	private static void saveGraph(RrdGraph rrdGraph, GraphFormat graphFormat,
			int width, int height, float quality, String graphingPath)
			throws RrdException, IOException {
		if (graphFormat == null) {
			graphFormat = DEFAULT_GRAPH_FORMAT;
		}

		if (graphFormat.equals(GraphFormat.PNG)) {
			rrdGraph.saveAsPNG(graphingPath, width, height);
		} else if (graphFormat.equals(GraphFormat.GIF)) {
			rrdGraph.saveAsGIF(graphingPath, width, height);
		} else if (graphFormat.equals(GraphFormat.JPEG)) {
			if (quality == 0) {
				quality = 0.5f;
			}
			rrdGraph.saveAsJPEG(graphingPath, width, height, quality);
		}
	}

	/**
	 * 按默认宽高,返回图片的字节码
	 * 
	 * @param rrdGraph
	 * @param graphFormat
	 * @return
	 * @throws RrdException
	 * @throws IOException
	 */
	private static byte[] byteGraph(RrdGraph rrdGraph, GraphFormat graphFormat)
			throws RrdException, IOException {
		byte[] bytes = null;

		if (graphFormat == null) {
			graphFormat = DEFAULT_GRAPH_FORMAT;
		}

		if (graphFormat.equals(GraphFormat.PNG)) {
			bytes = rrdGraph.getPNGBytes();
		} else if (graphFormat.equals(GraphFormat.GIF)) {
			bytes = rrdGraph.getGIFBytes();
		} else if (graphFormat.equals(GraphFormat.JPEG)) {
			bytes = rrdGraph.getJPEGBytes(0.5f);
		}
		return bytes;
	}

	/**
	 * 按指定宽高,返回图片的字节码
	 * 
	 * @param rrdGraph
	 * @param graphFormat
	 * @param width
	 * @param height
	 * @param quality
	 * @return
	 * @throws RrdException
	 * @throws IOException
	 */
	private static byte[] byteGraph(RrdGraph rrdGraph, GraphFormat graphFormat,
			int width, int height, float quality) throws RrdException,
			IOException {
		byte[] bytes = null;

		if (graphFormat == null) {
			graphFormat = DEFAULT_GRAPH_FORMAT;
		}

		if (graphFormat.equals(GraphFormat.PNG)) {
			bytes = rrdGraph.getPNGBytes(width, height);
		} else if (graphFormat.equals(GraphFormat.GIF)) {
			bytes = rrdGraph.getGIFBytes(width, height);
		} else if (graphFormat.equals(GraphFormat.JPEG)) {
			if (quality == 0) {
				quality = 0.5f;
			}
			bytes = rrdGraph.getJPEGBytes(width, height, quality);
		}
		return bytes;
	}
分享到:
评论

相关推荐

    RRD与JRobin

    在IT监控领域,RRD(Round Robin Database)和JRobin是两种常见的时序数据库,用于存储和管理时间序列数据,如系统性能指标、网络流量、服务器状态等。这两种技术对于实时监控和分析IT系统的健康状况至关重要。 ...

    jrobin-1.5.9-API文档-中文版.zip

    赠送jar包:jrobin-1.5.9.jar; 赠送原API文档:jrobin-1.5.9-javadoc.jar; 赠送源代码:jrobin-1.5.9-sources.jar; 赠送Maven依赖信息文件:jrobin-1.5.9.pom; 包含翻译后的API文档:jrobin-1.5.9-javadoc-API...

    jrobin-1.5.14.jar和源代码

    《JRobin:深入理解与应用》 在Java世界中,数据持久化是一个不可或缺的部分,而JRobin正是这样一个轻量级的、高效的RPM(Ring-Persistent Metrics)存储库,它被广泛用于记录和分析系统性能指标。JRobin-1.5.14....

    jrobin-1.5.9-API文档-中英对照版.zip

    赠送jar包:jrobin-1.5.9.jar; 赠送原API文档:jrobin-1.5.9-javadoc.jar; 赠送源代码:jrobin-1.5.9-sources.jar; 赠送Maven依赖信息文件:jrobin-1.5.9.pom; 包含翻译后的API文档:jrobin-1.5.9-javadoc-API...

    JRobin 流量报表

    它们都支持 RRDTool(Round Robin Database Tool)的数据格式,使得从 Mrtg 迁移到 JRobin 变得相对简单。 3. **JRobin 工作原理** - **数据收集**:JRobin 通过监听网络、系统或者其他数据源,定期收集流量数据。...

    jrobin学习例子程序

    学习用jrobin绘图的绝佳例子程序 学习用jrobin绘图的绝佳例子程序

    jrobin流量监控代码

    **Jrobin流量监控代码详解** Jrobin是一种开源的、轻量级的时序数据存储库,专门用于性能监控和日志记录。它被设计为Rrdtool(Round Robin Database Tool)的一个替代品,Rrdtool是由Tobi Oetiker开发的用于存储和...

    javaMelody+jrobin jar文件 .rar

    1. **轻量级**:JRobin的设计目标是轻便且高效,它不依赖任何外部数据库,只需一个简单的jar包即可实现数据存储。 2. **高效数据存储**:JRobin采用环形缓冲区机制,能有效地处理大量时间序列数据,避免了因数据量...

    JRobin-开源

    JRobin是RRDTool的100%纯Java替代品,具有几乎完全相同的规格。 如果向RRDTool和JRobin提供相同的数据,则将获得完全相同的结果和图形。 支持所有标准RRDTool操作。

    JavaMelody javamelody-core-1.52.0.jar jrobin-1.5.9.jar

    在本案例中,我们关注的是两个核心的JAR文件:`javamelody-core-1.52.0.jar`和`jrobin-1.5.9.jar`。 `javamelody-core-1.52.0.jar`是JavaMelody的核心组件,包含了实现监控功能的主要类和接口。这个版本的Java...

    javamelody.jar和 jrobin.jar

    监控器需要的jar,需在web.xml中配置 &lt;filter-name&gt;monitoring &lt;filter-class&gt;net.bull.javamelody.MonitoringFilter&lt;/filter-class&gt; &lt;filter-name&gt;monitoring &lt;url-pattern&gt;/* ...可以进入到监控页面

    jrobin-1.5.9.jar中文-英文对照文档.zip

    注:下文中的 *** 代表文件名中的组件名称。 # 包含: 中文-英文对照文档:【***-javadoc-API文档-中文(简体)-英语-对照版.zip】 jar包下载地址:【***.jar下载地址(官方地址+国内镜像地址).txt】 ...

    RRD环形数据库操作.rar

    这种数据库由JRobin库在Java环境中实现,而JRobin是一个轻量级、高效的RRD工具。 RRD数据库的结构由一系列数据源(Data Sources)和时序更新记录(Archives)组成。数据源代表了你要监控的特定指标,如CPU利用率或...

    snmp-tutorial:SNMP教程:Jrobin、SNMP4j

    snmp-tutorialSNMP tutorial :Jrobin、SNMP4jsnmp4j-1x-demoSNMP4j实现同步和异步的GET的示例SNMP4j实现同步和异步的Walk的示例SNMP4j实现Trap的示例SNMP4j实现SET的示例SNMP4j实现GETBLUK的示例robin-demoJRobin ...

    开源 tomcat 性能查看工具

    "jrobin-1.5.9.1.jar"是Java Robin(JRobin)的组件,它是JavaMelody的一个依赖库,用于存储和检索监控数据。JRobin是一个纯Java实现的RMON(Remote Monitoring)兼容的数据存储系统,它能够高效地记录和分析时间...

    监控JAVA应用的好工具javamelody

    这个工具的核心组件包括javamelody.jar和jrobin-1.5.9.1.jar,这两个JAR文件在Java应用的监控中扮演着重要角色。 javamelody.jar是JavaMelody的主要实现库,它提供了全面的监控功能。这个库能够集成到任何基于...

    JavaMelody 监测java或javaEE应用服务器

    另一个`jrobin-1.5.9.1.jar`则是JRobin库,它是JavaMelody用来存储和读取性能数据的持久化组件,提供了类似于RRDTool(Round Robin Database)的功能,以高效的方式存储时间序列数据。 在使用JavaMelody时,通常会...

    javamelody资料包

    2. **jrobin**: JRobin是用于存储性能数据的二进制日志库,它是基于RMON(Remote Monitoring)标准的,能够高效地存储和检索性能历史数据。 3. **msyh.ttc** 和 **msyhbd.ttc**: 这两个文件可能包含的是中文字体,...

    javamelody性能监控jar和war

    4. **集成JavaMelody**: 集成JavaMelody非常简单,只需要在web.xml配置文件中添加一段JavaMelody的过滤器和监听器配置。一旦配置完成,JavaMelody就会在每次请求时自动收集数据,并在后台处理。 5. **监控功能**: ...

    JavaMelody JAVA Web项目服务器性能监控工具

    通过在Java Web应用中简单集成,JavaMelody就能提供包括请求处理时间、SQL查询、内存使用、线程信息、异常跟踪等多种关键性能指标的可视化报告。 首先,JavaMelody的核心功能在于其丰富的监控指标。它能够监控HTTP...

Global site tag (gtag.js) - Google Analytics