1.一种用于电力系统的前置机,其特征在于,包括:依次连接的通信网关模块、通信前置模块、业务前置处理模块、数据总线模块和入库模块;所述通信网关模块,用于连接采集终端,并采集所述采集终端和所述前置机之间发送的报文数据;所述通信前置模块,用于根据预置分发策略分发所述报文数据,具体用于,根据获取到的所述业务前置处理模块中各节点的运行状况,选择对应的基于终端逻辑地址取模算法的分发规则,以分发所述报文数据;其中,所述采集终端的地址按下行Topic的数量取模,得到若干组地址域区间,下行Topic与地址域区间之间存在映射关系;所述通信前置模块还用于,通过与所述业务前置处理模块中各节点定时心跳握手,获取所述前置处理模块中各节点的所述运行状况;还用于将与通信模块中各节点连接的采集终端的地址,发送至与该节点握手的通信前置处理模块中的节点;其中,所述运行状况包括:节点新增、节点故障及故障节点恢复;所述分发规则包括:节点新增规则、节点故障规则和故障节点恢复规则;所述业务前置处理模块,用于对所述报文数据进行组帧和/或解析;所述入库模块,用于通过所述数据总线模块获取所述报文数据,并将所述报文数据进行存储。
2.根据权利要求1所述的用于电力系统的前置机,其特征在于,所述数据总线模块具体为:分布式Kafka消息队列。
3.根据权利要求1所述的用于电力系统的前置机,其特征在于,所述入库模块包括:商用数据库Oracle、缓存数据库Redis、分布式数据库HBase和数据仓库Hive。
4.根据权利要求1所述的用于电力系统的前置机,其特征在于,还包括用于对所述报文数据进行分析的分析模块。
5.根据权利要求4所述的用于电力系统的前置机,其特征在于,所述分析模块具体包括,实时计算子模块和离线计算子模块;所述实时计算子模块和所述数据总线模块连接,用于对传输中的报文数据进行计算;所述离线计算子模块和所述入库模块连接,用于对存储后的报文数据进行计算。
6.根据权利要求5所述的用于电力系统的前置机,其特征在于,所述实时计算子模块具体为:Storm计算框架;所述离线计算子模块具体为:Spark计算框架。
7.一种用于电力系统的采集系统,其特征在于,包括:通信服务器集群和如权利要求1至6中任一项所述的用于电力系统的前置机。