Page 98 - 基于光伏技术的新能源发电研究

基于光伏技术的新能源发电研究
Research on New Energy Power Generation Based on Photovoltaic Technology

给数据存储消息队列，同时为了保证页面告警信息展示的实时性，告警程序还将
处理结果发送给数据推送消息队列，供 WebSocket 实时推送给客户端页面。
三是方阵汇聚计算程序根据测点计算规则对数据进行实时计算，得出方阵级

别的指标值。计算结果一方面写入 Redis 缓存中，供后续模块使用；另一方面将
推送给下一级的电站汇聚计算程序，同时也要发送给数据存储 / 推送消息队列。
四是电站汇聚计算程序对电站级指标进行汇聚计算。在一个计算周期开始时，
会首先判断一个电站下所有方阵是否已经处理完成，只有在方阵级计算完成之后，

才开始根据测点计算规则进行电站级指标的计算。计算结果处理和方阵汇聚计算
程序类似，需要发送给 Redis、下一级的集团汇聚计算程序和数据存储 / 推送消
息队列。
五是集团汇聚计算程序的流程和电站汇聚计算程序类似，也是等待所有电站

计算完当前周期的数据后，再进行计算。计算结果处理和其他汇聚计算程序相同。
第三，数据存储流程。数据存储的主要流程为：Strom 中的持久化程序订阅
数据存储消息队列，获取数据存储报文后，首先进行反序列化操作，然后将所有
的实时、小时、日、月的计算结果数据存储到 NoSQL 数据库 HBase 中，并将告警、

年计算结果数据存储到关系型数据库中。
（3）数据展现层
数据展现层基于 JavaEE 技术体系，采用 MVC 应用框架构建，由界面控制
器组件、界面操作组件、JSP 页面组件和服务代理单元组成。在一些分析图表、

实时应用展现时，采用 ECharts、HTML5 等技术实现，并通过 WebSocket 订阅数
据推送消息队列的报文，保持客户端页面数据实时刷新。
4. 系统实施与应用
（1）系统实施

在系统实施过程中，需要根据接入的电站容量，为云端系统购买或租用相
应的计算资源、存储资源和网络资源，在其中部署数据接入服务集群、Storm 实
时计算集群、Kafka 消息队列集群、Redis 缓存服务集群、分布式架构调度监控
服务集群、关系数据库集群、HBase 数据库集群、Web 应用集群，搭建起云端系

统。以接入容量 100MW 为例，数据点位约为 10 万个，为了保证计算的实时性，
Storm 实时计算集群的每个节点需要具有较高的计算性能（16 核 CPU、64G 内存）；
同时，HBase 数据库集群中的每个节点每年需扩容约 500GB 的存储空间；而数

90