`
cleaneyes
  • 浏览: 345327 次
  • 性别: 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;
	}
分享到:
评论

相关推荐

    模具状态监测行业发展趋势:预计到2030年市场规模为5.06亿美元

    模具状态监测市场:6.8%的年复合增长率引领制造业智能化升级 在快速发展的制造业中,模具作为生产过程中的核心部件,其状态直接影响到产品的质量和生产效率。然而,模具的损耗和故障往往难以预测,给企业带来不小的损失。如今,随着模具状态监测技术的兴起,这一切正在发生改变。这项创新技术不仅能够帮助企业提前发现模具的潜在问题,还能显著延长模具的使用寿命,提升生产效率。但你真的了解这个市场的潜力和现状吗?让我们一同揭开模具状态监测市场的神秘面纱。 市场概况: 根据QYR(恒州博智)的统计,2023年全球模具状态监测市场的销售额已经达到了3.2亿美元,预计到2030年,这一数字将攀升至5.06亿美元,年复合增长率高达6.8%。这一显著的增长背后,是制造业对智能化、自动化生产需求的不断提升,以及模具状态监测技术在提高生产效率、降低维护成本方面的显著优势。 技术创新与趋势: 模具状态监测技术主要依赖于传感器、数据分析和处理等技术手段,能够实时采集模具的温度、振动、压力等指标,并通过与预设参数的比对,及时识别模具的异常情况。随着物联网、大数据和人工智能等技术的不断发展,模具状态监测技术将更加智能化,能够提供

    Kubernetes DevOps实践工作坊-从理论到实战操作脚本集(含源码).zip

    Kubernetes DevOps实践工作坊-从理论到实战操作脚本集(含源码).zip [资源说明] 1、该项目是团队成员近期最新开发,代码完整,资料齐全,含设计文档等 2、上传的项目源码经过严格测试,功能完善且能正常运行,请放心下载使用! 3、本项目适合计算机相关专业(人工智能、通信工程、自动化、电子信息、物联网等)的高校学生、教师、科研工作者、行业从业者下载使用,可借鉴学习,也可直接作为毕业设计、课程设计、作业、项目初期立项演示等,也适合小白学习进阶,遇到问题不懂就问,欢迎交流。 4、如果基础还行,可以在此代码基础上进行修改,以实现其他功能,也可直接用于毕设、课设、作业等。 5、不懂配置和运行,可远程教学 欢迎下载,学习使用!

    基于springboot+vue3+uniapp的点餐小程序源代码+数据库+文档说明(高分毕设)

    基于springboot+vue3+uniapp的点餐小程序源代码+数据库+文档说明(高分毕设),个人经导师指导并认可通过的毕业设计项目,评审分98分,项目中的源码都是经过本地编译过可运行的,都经过严格调试,确保可以运行!主要针对计算机相关专业的正在做毕业设计的学生和需要项目实战练习的学习者,资源项目的难度比较适中,内容都是经过助教老师审定过的能够满足学习、使用需求,如果有需要的话可以放心下载使用。 基于springboot+vue3+uniapp的点餐小程序源代码+数据库+文档说明(高分毕设)基于springboot+vue3+uniapp的点餐小程序源代码+数据库+文档说明(高分毕设)基于springboot+vue3+uniapp的点餐小程序源代码+数据库+文档说明(高分毕设)基于springboot+vue3+uniapp的点餐小程序源代码+数据库+文档说明(高分毕设)基于springboot+vue3+uniapp的点餐小程序源代码+数据库+文档说明(高分毕设)基于springboot+vue3+uniapp的点餐小程序源代码+数据库+文档说明(高分毕设)基于springb

    欧姆龙NX1P2系列总线plc程序 自动检测机,plc程序,无触摸屏程序 1.多工位DDR马达转盘控制,多工位同时加工 2.多产品配方功能程序 3.各种实用型自制功能块程序,可重复调用,成熟设备

    欧姆龙NX1P2系列总线plc程序 自动检测机,plc程序,无触摸屏程序 1.多工位DDR马达转盘控制,多工位同时加工。 2.多产品配方功能程序。 3.各种实用型自制功能块程序,可重复调用,成熟设备

    企业微信最全养号、防封、加人机制.pdf

    企业微信最全养号、防封、加人机制.pdf

    LLM 友好的异步爬虫框架

    这是一款用 Python 开发的异步爬虫框架,能够将网站上的数据转化成 Markdown、JSON 等 LLM 友好的输出格式。它完全开源且免费,极大地简化了异步爬虫的编写。相比于付费的 Firecrawl,它具有更快的爬取速度,支持同时抓取多个 URL、页面截图、关键字优化提取(基于 LLM)和复杂的多页面会话管理等功能。

    毕设Python春节电影信息爬取与可视化分析源码+项目说明+全部资料.zip

    毕设Python春节电影信息爬取与可视化分析源码+项目说明+全部资料.zip [资源说明] 1、该项目是团队成员近期最新开发,代码完整,资料齐全,含设计文档等 2、上传的项目源码经过严格测试,功能完善且能正常运行,请放心下载使用! 3、本项目适合计算机相关专业(人工智能、通信工程、自动化、电子信息、物联网等)的高校学生、教师、科研工作者、行业从业者下载使用,可借鉴学习,也可直接作为毕业设计、课程设计、作业、项目初期立项演示等,也适合小白学习进阶,遇到问题不懂就问,欢迎交流。 4、如果基础还行,可以在此代码基础上进行修改,以实现其他功能,也可直接用于毕设、课设、作业等。 5、不懂配置和运行,可远程教学 欢迎下载,学习使用!

    2019厦门国际银行数创金融杯源码+竞赛策略报告文档.zip

    2019厦门国际银行数创金融杯源码+竞赛策略报告文档.zip [资源说明] 1、该项目是团队成员近期最新开发,代码完整,资料齐全,含设计文档等 2、上传的项目源码经过严格测试,功能完善且能正常运行,请放心下载使用! 3、本项目适合计算机相关专业(人工智能、通信工程、自动化、电子信息、物联网等)的高校学生、教师、科研工作者、行业从业者下载使用,可借鉴学习,也可直接作为毕业设计、课程设计、作业、项目初期立项演示等,也适合小白学习进阶,遇到问题不懂就问,欢迎交流。 4、如果基础还行,可以在此代码基础上进行修改,以实现其他功能,也可直接用于毕设、课设、作业等。 5、不懂配置和运行,可远程教学 欢迎下载,学习使用!

    基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业)

    基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业),个人经导师指导并认可通过的毕业设计项目,评审分98分,项目中的源码都是经过本地编译过可运行的,都经过严格调试,确保可以运行!主要针对计算机相关专业的正在做毕业设计的学生和需要项目实战练习的学习者,资源项目的难度比较适中,内容都是经过助教老师审定过的能够满足学习、使用需求,如果有需要的话可以放心下载使用。 基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业)基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业)基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业)基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业)基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业)基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业)基于Android Studio开发的安卓的记事本app项目源码(高分期末大作业)基于Android Studio开

    基于java的小区智能卡管理系统设计与实现.docx

    基于java的小区智能卡管理系统设计与实现.docx

    NLP中文垃圾短信分类系统源码+设计全部资料+文档报告(自然语言处理课设).zip

    NLP中文垃圾短信分类系统源码+设计全部资料+文档报告(自然语言处理课设).zip [资源说明] 1、该项目是团队成员近期最新开发,代码完整,资料齐全,含设计文档等 2、上传的项目源码经过严格测试,功能完善且能正常运行,请放心下载使用! 3、本项目适合计算机相关专业(人工智能、通信工程、自动化、电子信息、物联网等)的高校学生、教师、科研工作者、行业从业者下载使用,可借鉴学习,也可直接作为毕业设计、课程设计、作业、项目初期立项演示等,也适合小白学习进阶,遇到问题不懂就问,欢迎交流。 4、如果基础还行,可以在此代码基础上进行修改,以实现其他功能,也可直接用于毕设、课设、作业等。 5、不懂配置和运行,可远程教学 欢迎下载,学习使用!

    电源滤波器车辆状态估计,扩展卡尔曼滤波EKF,无迹卡尔曼滤波UKF车辆状态估计,扩展卡尔曼滤波EKF,无迹卡尔曼滤波UKF 角阶跃输入+整车7自由度模型+UKF状态估计模型+附送EKF状态估计模型,针

    电源滤波器车辆状态估计,扩展卡尔曼滤波EKF,无迹卡尔曼滤波UKF车辆状态估计,扩展卡尔曼滤波EKF,无迹卡尔曼滤波UKF 角阶跃输入+整车7自由度模型+UKF状态估计模型+附送EKF状态估计模型,针对于轮毂电机分布式驱动车辆,进行车速,质心侧偏角,横摆角速度估计。 模型输入:方向盘转角delta,车辆纵向加速度ax 模型输出:横摆角速度wz,纵向车速vx,质心侧偏角β

Global site tag (gtag.js) - Google Analytics