数据收集程序一般建筑(C++ ACE达到)

数据收集程序一般功能

经socket数据的接收的另一侧。端方能够访问智能电表采集器,你可曾与计算机之间的通信的通信协议(你良好的一致性是谁client,谁是服务端,即数据流)

为收集程序要求

可扩展:协议到来的时候,你能够不修改其它代码,仅仅创建相应的解码器和通信类就可以。

可配置:能够通过文件或者数据库来载入对方和自己的配置信息。

模块化程度高:採集程序依照模块功能划分为例如以下的几个主要模块(配置载入模块、两级消息队列、消费线程、解码器管理器、两级解码器、通信模块)

採集程序的一般架构

数据收集程序一般建筑(C++ ACE达到)

此结构历经JSPTPD多个项目成型,在软件院朱磊总的设计下由多人(zhulei,.zhuyongjin,chenfan,,yuanweiwei,chenlinkong,zhuzhongzhi,lvzhiqianq)实现,各个模块均由DLL封装,出现故障easy定位。满足採集程序的一般要求。

关键接口和系统架构

以下是关键路径上的主要接口明细

数据收集程序一般建筑(C++ ACE达到)

上面的接口展示了具体设计中各个模块之间的关系和纽带。能够看出因为功能模块划分的清晰,能够方便的扩展和測试。

眼下难度较大和待完好的部分主要有:

(1)ConfigLoader。由于当成千上万的採集器和电表在线的时候,结构化的配置库将是系统不可或缺的信息支撑。当前的ConfigLoader类接口还比較简单,另外ConfigLoader尽管扩展easy,但在扩展的同一时候仍要提供一个清晰易用的接口还是须要细致斟酌的。或许须要多个项目打磨才会比較完好。

(2)使用Acceptor-Connector加Proactor模式实现自己主动异步处理大并发,这个正在进行,期待期待。

平台能力

依照半个小时採集一次的频率算。上面的结构仅仅要部署一到两个拷贝,应足以应付收购一个二线城市城市的智能电表数据。

版权声明:本文博主原创文章。博客,未经同意,不得转载。





本文转自mfrbuaa博客园博客,原文链接:http://www.cnblogs.com/mfrbuaa/p/4759252.html,如需转载请自行联系原作者


上一篇:创建 Pool & VIP - 每天5分钟玩转 OpenStack(122)


下一篇:使用EMR-Flume同步Kafka数据到HDFS