大数据应用系统的消息驱动架构

doi:10.11959/j.issn.2096-0271.2016040

大数据 ›› 2016, Vol. 2 ›› Issue (4): 36-48.doi: 10.11959/j.issn.2096-0271.2016040

大数据应用系统的消息驱动架构

贵芳¹,李廉¹,杨静¹,武永卫²

¹ 合肥工业大学计算机与信息学院，安徽合肥 230009
² 清华大学计算机科学与技术系，北京 100084

出版日期:2016-07-20 发布日期:2017-04-27
基金资助:
国家自然科学基金资助项目;国家自然科学基金资助项目;国家自然科学基金资助项目;广东省佛山市创新团队基金资助项目

A message driven framework for big data application system

Fang GUI¹,Lian LI¹,Jing YANG¹,Yongwei WU²

¹ School of Computer and Information,Hefei University of Technology,Hefei 230009,China
² Department of Computer Science and Technology,Tsinghua University,Beijing 100084,China

Online:2016-07-20 Published:2017-04-27
Supported by:
The National Natural Science Foundation of China;The National Natural Science Foundation of China;The National Natural Science Foundation of China;The Innovation Teams Foundation of Foshan,Guangdong

摘要/Abstract

摘要：

基于消息驱动框架的软件开发成为大数据应用系统的重要模式之一。基于面向实体、消息驱动的开发架构，设计并实现了该架构中的消息管理模块。定义了消息基本格式，制定了消息管理规范，并且具体实现了其功能，通过一个案例显示了该架构的优点。

关键词: 大数据应用系统, 消息驱动架构, 消息管理模块, 多用户, 动态演化编程

Abstract:

Software development based on message driven framework has become an important pattern for big data application system.The message management module which is an important part of whole framework was designed and implemented.The basic format of message and the standard of message management was defined,its function was realized,and the advantages through a case were shown.

Key words: big data application system, message driven framework, module of message management, dynamic and self developing programming

贵芳, 李廉, 杨静, 武永卫. 大数据应用系统的消息驱动架构[J]. 大数据, 2016, 2(4): 36-48.

Fang GUI, Lian LI, Jing YANG, Yongwei WU. A message driven framework for big data application system[J]. Big Data Research, 2016, 2(4): 36-48.

图/表 9

表1

图1

表2

图2

图3

图4

表3

图5

图6

参考文献 22

[1]	高志刚 . 自然资源系统的演化及其动力机制[J]. 资源开发与市场, 2002,18(6): 14-17. GAO Z G . Evolution and its driving mechanism of natural resources system[J]. Resource Development ＆ Market, 2002,18(6): 14-17.
[2]	洪学海, 范灵俊, 洪筱楠 ,等. 智慧城市建设中政府大数据开放与市场化利用[J]. 大数据, 2016,2(3): 17-26. HONG X H , FAN L J , HONG X N ,et al. Government big data opening and market utilization for smart city construction[J]. Big Data Research, 2016,2(3): 17-26.
[3]	郑磊, 高丰 . 中国开放政府数据平台研究：框架、现状与建议[J]. 电子政务, 2015(7): 8-16. ZHENG L , GAO F . Study on the Chinese government data platform:framework,status and suggestions[J]. E-Government, 2015(7): 8-16.
[4]	马朝辉, 聂瑞华, 谭昊翔 ,等. 大数据治理的数据模式与安全[J]. 大数据, 2016,2(3): 83-95. MA C H , NIE R H , TAN H X ,et al. Research on data schema and security in data governance[J]. Big Data Research, 2016,2(3): 83-95.
[5]	MASKIT D , TAYLOR S . A messagedriven programming system for fine-grain multicomputers[J]. Software:Practice and Experience, 1994,24(10): 953-980.
[6]	邵长磊, 吾际舟 . 计算机编程语言的演变[J]. 农业网络信息, 2009(11): 112-115. SHAO C L , WU J Z . Evolution of computer programming languages[J]. Agriculture Network Information, 2009(11): 112-115.
[7]	SAMMET J E . Programming languages:history and future[J]. Communications of the ACM, 1972,15(7): 601-610.
[8]	朱树人, 贺株莉 . 面向对象与面向过程的程序设计方法比较[J]. 长沙电力学院学报, 1998,13(2): 161-167. ZHU S R , HE Z L . Compare the programming method of the object-oriented and the process-oriented[J]. Journal of Changsha University of Electric Power, 1998,13(2): 161-167.
[9]	张丽霞 . 面向过程的编程与面向对象的编程[J]. 赤峰学院学报, 2006,22(5): 41-46. ZHANG L X . Programming about process-oriented and object-oriented[J]. Journal of Chifeng College, 2006,22(5): 41-46.
[10]	BAINOMUGISHA E , CARRETON A L , CUTSEM T ,et al. A survey on reactive programming[J]. ACM Computing Surveys (CSUR), 2013,45(4): 115-123.
[11]	KANTOROWITZ E , TADMOR S . Toward specification-oriented frameworks[C]// The Israeli Workshop on Programming Languages＆ Development Environments,July 1,2002. Hefa,Israel.[S.l.:s.n.], 2002:4.
[12]	DE PAOLI F , TISATO F . On the complementary nature of event-driven and time-driven models[J]. Control Engineering Practice, 1996,4(6): 847-854.
[13]	HE C , HE K . A role-based approach to design pattern modeling and implementation[J]. Journal of Software, 2006,17(4): 658-669.
[14]	ZHANG T , ZHANG Y , YU X F ,et al. MDF based design patterns modeling and model transformation[J]. Journal of Software, 2008,19(9): 2203-2217.
[15]	PENCZEK F , HERHUT S , SCHOLZ S B ,et al. Message driven programming with s-net:methodology and performance[C]// The 39th International Conference on Parallel Processing Workshops (ICPPW),September 13-16,2010, San Diego,CA,USA. New Jersey： IEEE Press, 2010: 405-412.
[16]	PHILLIPS J C , STONE J E , SCHULTEN K . Adapting a message-driven parallel application to GPU-accelerated clusters[C]// International Conference for High Performance Computing,Networking,Storage and Analysis,November 15-21,2008, Austin,TX,USA. New Jersey： IEEE Press, 2008: 1-9.
[17]	肖美华, 余立金 . SOCKET通信程序模型抽取及可靠性验证[J]. 计算机科学, 2012,39(11): 102-105. XIAO M H , YU L J . Model extraction and reliability verification on socket communication program[J]. Computer Science, 2012,39(11): 102-105.
[18]	刘邦桂, 李正凡 . 用Java实现流式Socket通信[J]. 华东交通大学学报, 2007,24(5): 110-112. LIU B G , LI Z F . Implementation of socket stream communication in Java[J]. Journal of East China Jiaotong University, 2007,24(5): 110-112.
[19]	于海, 樊晓桠 . 基于FPGA异步FIFO的研究与实现[J]. 微电子学与计算机, 2007,24(3): 210-213. YU H , FAN X Y . Research and implementation of asynchronous FIFO based on FPGA[J]. Microelectronics ＆Computer, 2007,24(3): 210-213.
[20]	夏家莉, 陈辉 . 一种动态优先级实时任务调度算法[J]. 计算机学报, 2012,35(12): 2685-2695. XIA J L , CHEN H . A real-time tasks scheduling algorithm based on dynamic priority[J]. Chinese Journal of Computers, 2012,35(12): 2685-2695.
[21]	李建中, 张东东 . 滑动窗口规模的动态调整算法[J]. 软件学报, 2004,15(12): 1800-1814. LI J Z , ZHANG D D . Algorithms for dynamically adjusting the sizes of sliding windows[J]. Journal of Software, 2004,15(12): 1800-1814.
[22]	KALé L V , BHANDARKAR M A . Structured dagger:a coordination language for message-driven programming[C]// The Second International Euro-Par Conference,August 26-29,1996, Lyon,France. Berlin： Springer Berlin Heidelberg, 1996: 646-653.

年份	语言	年份	语言
1957-1959年	Fortran、USP、COBOL	1991年	Python
1970年	Pascal	1993年	Ruby
1972年	C	1995年	Java
1983年	C++	1995年	PHP
1983年	Objective-C	1995年	JavaScript

	字段		类型	说明
head		name	符号串	消息名称，长度不超过128 byte
		from	URL+timedid	发送方地址和发送时间
		to	X +P	发送形式与接收方URL地址
		type	发送类型	主动发送或被动发送
		life	字符+时间类型	消息的生存时间
		time	时间类型	消息的发送时间
		priority	整数类型	优先级
body		text	文本类型	消息内容，长度限制为1 024 byte

行星	质量/kg	位置/m	速度/(m·s^-1)
金星	4.867 6×10²⁴	(0,1.07×10¹¹)	(-35 000,0)
地球	5.98×10²⁴	(1.496×10¹¹,0)	(0,29 783)
火星	6.418×10²³	(-2.496×10¹¹,0)	(0,-24 000)

大数据应用系统的消息驱动架构

A message driven framework for big data application system

在线阅读

PDF下载

可视化

摘要/Abstract

引用本文

使用本文

图/表 9

参考文献 22

相关文章 0

Metrics

推荐阅读 0