1.智能电网异构高并发大数据协同接入系统,其特征在于,采用SGEPON作为通信信道,提出一级电网协同接入SGEPON数据网管系统,对若干个二级电网、多家厂商、数万台SGEPON设备统一管理;第一,针对SGEPON数据网管接入层中存在的异构性问题,提出智能SGEPON设备大数据统一接入模型,包括:一是多源协议的动态扩展接入,包括多源协议动态适配器设计、多源协议适配接口的实现、多源协议动态适配抽象类的实现、多源协议动态适配的类实现,二是电网异构大数据的统一,包括电网SGEPON设备对象解析、智能SGEPON设备数据协同编码,三是异构统一接入数据库设计;首先基于面向对象的接口与类之间关系,设计和实现接入层的多源协议适配器来屏蔽多源协议的异构性,实现多源协议的动态和扩展接入;然后基于SGEPON设备对象、对象属性和对象之间关系,通过UML设计SGEPON设备元数据融合模型,并规定关键数据的编码,为数据处理统一提供模板;最后,一级电网SGEPON数据网管中采用Oracle数据库,并根据SGEPON设备元数据融合模型进行数据库表结构的设计,实现SGEPON设备数据的统一存储和一致化展示;第二,针对SGEPON数据网管接入层中存在的高并发问题,提出智能SGEPON设备数据接入并发控制方法,包括:一是电网并发数据模型,包括接入层整体架构模型、静态数据接入模型、变更数据接入模型、状态数据接入模型、告警数据接入模型,二是并发电网控制方法,包括智能SGEPON并发线程池、优先任务队列控制、电网C3PO数据库连接池控制;解析接入层中各业务模块包含的不同子任务和具体实现流程,将Java线程池、优先任务队列和C3PO数据库连接池融合后引入接入层,实现高并发控制,提高SGEPON设备接入效率。2.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,多源协议动态适配器设计:一级电网SGEPON数据网管的接入层中通过加入多源协议适配器来支持多源协议,多源协议适配器通过提取多源协议相同的特征,并屏蔽差异之处,为SGEPON网元设备数据接入提供统一的多源协议调用;一级电网SGEPON数据网管接入层的多源协议适配器利用Java语言中的抽象类与接口之间的实现关系、类和抽象类之间的继承关系设计,最上层定义统一的父接口Northbound,中间层定义每种多源协议的抽象类,实现父接口,最下层定义各厂商多源协议具体的实现类。3.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,多源协议适配接口的实现:多源协议适配器的最上层定义接口Northbound ,根据多源协议的功能抽象实现,接口Northbound中声明的方法和各种协议抽象出的相同功能逐一对应,接入层按照多源协议机制建立通信时,获取厂商EMS所部署服务器的IP地址和北向接口所绑定的端口,方法connect(StringlP,intport)对应多源协议的通信建立,规定传入参数为字符串类型的IP和整数类型的port,具体按照不同协议的传输层协议,在下层抽象类中实现;方法sendOrder(String order)对应多源协议的发送命令,规定传入参数为字符串类型的order;方法getEquipments( )对应多源协议获取SGEPON设备静态数据,接入层发送查询命令之后,获得响应的静态数据,以字符串集合ArrayList的结果返回;另外,getOLTState( )、getPONState( )、getBoardState( )、getONUState( )方法对应二级电网厂商EMS北向接口返回的OLT、PON端口、Board和ONU的实时状态,且都以字符串集合ArrayList返回;方法listenChange( )对应多源协议的监听推送SGEPON设备变更数据,接入层通过该方法监听厂商EMS北向接口主动推送的设备变更数据,读取报文之后,添加进字符串集合ArrayList返回;方法listenAlarme( )对应于多源协议的监听推送SGEPON设备告警数据,也以字符串集合ArrayList返回;方法close( )对应多源协议的关闭通信,其和方法connect(StringIP,intport)配对使用,接入层在与厂商EMS的北向接口完成数据交互之后,释放占用的IO和端口资源,通过close( )及时关闭通信。4.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,多源协议动态适配抽象类的实现:多源协议适配器的第二层按照不同的协议依次定义抽象类,命名规则为“协议名简称_Northbound”,实现上层的父接口Northbound,各自定义不仅重写并实现Northbound中声明的方法,又保持方法的声明而不实现;接入层作为客户端,而各二级电网EMS为服务端,接入层通过Socket类实现客户端的代码,抽象类TLl_Northbound具体定义为:首先声明Socket类型的sk对象,以及通过sk得到与IO相关的字BufferedWriter类型对象bw和BufferedReader类型对象br,然后在方法connect(StringlP,intport)中,进行sk、bw和br对象的创建和初始化,接入层与厂商EMS的北向接口是否成功建立通信则根据该方法返回的结果判断;TL1_Northbound抽象类中实现各厂商子类中共同拥有的connect(StringIP ,int port)方法,同种逐一实现其它类似方法,因厂商设备差异,造成部分方法的实现不同,保留原声明即可,同种,其它协议SNMP_Northbound、CORBA_Northbound抽象类也按照这种规则具体定义。5.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,多源协议动态适配的类实现:最下层具体到各个厂商每一种协议的实现类,命名规则为“厂商名简称_多源协议名简称_Northbound”,它们继承于上层的协议抽象类,且已通过继承拥有父类中实现的方法,而各厂商存在差异的方法则在此处进行实现;FH_TLl_Northbound类中getEquipments( )方法的具体实现:接入层在发送查询OLT设备静态数据命令后,通过该方法接收响应信息,首先,getEquipments( )方法判断响应的是否是对应的SGEPON设备数据,然后,getEquipments( )方法通过分析response_id中的字段判断响应的信息对应的查询命令,以及是否查询成功,如果查询失败,getEquipments( )方法通过response_block字段得到发生错误的原因,如果成功,通过response_block字段得到响应信息报文个数和每个报文中OLT设备静态数据的记录数,最后,接入层根据具体记录数读取所有OLT设备的静态数据,并添加到字符串集合ArrayList中;同种,一级电网SGEPON数据网管接入层的多源协议适配器,针对其它厂商的各种北向接口协议,也按照这种方式具体实现,部分EMS北向接口没有实现其它协议,将这些类中的方法进行空实现,以备之后扩展。6.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,电网异构大数据的统一:接入层在解析过程中数据转换,屏蔽数据的异构性,提前建立统一的SGEPON网元设备数据模型,为解析过程中的数据转换和数据统一提供模板;1)电网SGEPON设备对象解析SGEPON数据网管对象包括OLT、SHELF、BOARD、PON端口和ONU,设备对象的属性信息包括:设备背景信息、SGEPON静态信息、设备实时状态信息、SGEPON实时告警信息和设备日志信息,设备背景信息包括设备所属厂商和二级电网位置信息,SGEPON静态信息包括设备基本地址定位和软硬件版本信息;设备实时状态信息包括实时管理和运行状态;SGEPON实时告警信息包括当前设备告警信息的产生和恢复;设备日志信息包括历史告警信息和设备变更信息;SGEPON数据网管中明确所管理对象之间的关联关系,SGEPON在网络结构上是点到多点的拓扑结构,再结合省市地理位置信息,构成“省‑市‑OLT‑SHELF‑BOARD‑PON‑ONU”多叉树的拓扑关联关系,其中省为根节点,ONU则为叶子节点;2)智能SGEPON设备数据协同编码SGEPON设备元数据融合模型提供统一转换模型,一级电网SGEPON数据网管在进行网元设备数据接入时,接入层的处理线程根据该模型进行数据解析、过滤和字段属性的提取,将二级电网信息进行编码,通过整型的CITY_CODE唯一标识,将厂商信息也进行编码,通过MAU_CODE唯一标识,通过数据协同编码的方法进行最后的统一,以向数据库的表中存入一致性的数据。7.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,电网并发数据模型:1)接入层整体架构模型一级电网SGEPON数据网管的接入层需要同时实现二级电网SGEPON设备数据的接入,接入层中针对每个厂商设计独立的进程,实现多进程并发,每个进程中则包括多个二级电网的SGEPON设备数据接入任务;基于SGEPON数据网管应用层实现的具体管理,每个二级电网的SGEPON设备数据接入程序实现对应的业务数据接入,具体包括4个:SGEPON网元设备静态数据接入、变更数据接入、状态数据接入、告警数据接入,每个二级电网的接入程序针对每一业务都开启单独的线程,而每一种业务数据的接入程序中又包括通信控制、数据获取、数据处理和数据存储流程;SGEPON数据网管的接入层与各个二级电网EMS的北向接口实现通信,进行SGEPON网元设备的数据接入,按照业务和功能划分,接入层每个二级电网的实现分为4个模块;2)静态数据接入模型静态数据接入采用的pull方式,首先,接入层按照多源协议的通信机制与厂商EMS北向接口的服务端口建立通信连接,若未成功建立通信连接,则尝试重新连接,重连次数上限为3次,如果连续3次建立连接都未成功,则直接结束当前任务,等待下次机会,当成功建立通信连接后,接入层按照多源协议的规定和命令格式发送认证命令,读取并解析返回的认证结果,如果认证失败,则根据返回的错误原因进行修正,重新进行认证;当认证成功后,按照多源协议发送查询命令,查询不同类型的SGEPON设备静态数据,然后进行数据获取、数据处理、数据统一和数据存储,最后,在查询完成后断开连接,释放占用端口等资源;3)变更数据接入模型变更数据接入采用的是push方式,首先,接入层与厂商EMS的北向接口建立通信连接,并认证成功,然后,接入层按照多源协议规则,发送让EMS主动上报变更数据的注册命令,并根据回复信息判断是否注册成功,如果注册失败,则根据回复信息中的错误原因,进行注册命令修正,然后重新注册,当注册成功后,便开始监听EMS推送的SGEPON设备变更数据,接入层一旦监听到有推送过来的变更数据,便读取完整的数据报文,然后进行解析,并通过解析得到的数据判断发生变更的网元设备,以及是发生什么情况的变更,根据变更设备的类型和变更情况,接入层与数据层进行交互,对相应的数据表进行insert、delete、update操作,保证数据的一致性,并且将设备变更信息存入到设备变更表中,以便将数据共享给用电信息采集业务管理系统;接入层与厂商EMS北向接口建立长连接,一直保持监听状态,接入层利用多源协议的心跳包机制,创建子任务,使用同一条通信连接,周期性向北向接口发送心跳命令,与厂商EMS的北向接口保持长连接。8.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,智能SGEPON并发线程池:接入层中不同的业务数据接入方式不同,其所要采用的线程池配置也会不同,首先,接入层程序直接使用并发框架工具类E x e c u t o r s 调用静态方法newScheduledThreadPool(int)创建一个ScheduledExecutorService类型的线程池,该对象命名为execService并设置改线程池的核心线程数为8,其支持任务的延时和周期性执行,然后,针对每个二级电网SGEPON设备实时状态接入创建其单独的任务,每个二级电网的任务中又包括其自己的通信线程、数据处理和存储线程,最后线程池对象execService调用scheduleAtFixedRate(Runnable command ,long initialDelay,longperiod ,Time Unit unit)方法来提交各二级电网的SGEPON设备状态数据接入任务,传入的第一个参数command表示具体的任务,第二个参数initialDelay表示初始化延时,第三个参数period表示任务执行的周期,第四个参数则表示延时和周期的时间单位,execService在提交各二级电网的SGEPON设备状态数据接入任务时,设置延时参数initialDelay都相差60秒,进而使其启动错开,提高运行效率,然后设置周期为period,通过修改配置文件来修改轮询周期。9.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,优先任务队列控制:优先任务队列PriorityBlockingQueue中的所有任务实现Comparable接口,并重写compareTo( )方法,该方法传入同种类型的任务对象,并比较两个任务对象的优先级,进而实现排序,SGEPON数据网管接入层程序中定义一个任务是继承Thread类或实现Runnable接口实现,但它们都没有实现Comparable接口,为实现代码复用,先定义PriorityThread和PriorityRunnable类,Thread类中已声明优先级成员变量,如果不设置,则默认为5,通过继承Thread类和实现Comparable接口,并重写compareTo( )方法即可,PriorityRunnable类则需要被定义为抽象类,同时实现Runnable和Comparable两个接口,但只重写compareTo( )方法,而不重写run( )方法,并通过定义成员变量priority表示任务的优先级,其范围也取值为1到10之间的整;另外,接入层针对每种业务数据的接入和其包括的子任务进行等级评估和设置,告警数据获取、告警数据解析和存储子任务的优先等级设为最高10,而对应的心跳包优先等级设为3,这是因为用户更重视SGEPON设备的告警信息,如果有告警信息时则优先处理,且心跳包是为了保证在通信连接上长时间没有数据传输时,防止连接断开,现在有告警数据在通信连接上传输,则暂时不用发送心跳包,因此发送心跳包的优先等级设置低。10.根据权利要求1所述智能电网异构高并发大数据协同接入系统,其特征在于,电网C3PO数据库连接池控制:接入层中基于C3PO数据库连接池,CPO数据库连接池的配置采用xml文件配置,文件命名为c3p0‑config .xml,放置于项目的类路径之下,配置文件中设置jdbcUrl .driverClass .user、password、acquireIncrement、initialPoolSize、minPoolSize和maxPoolSize参数,jdbcUrl表示数据库连接的url地址,不同数据库url地址表示格式不同,通过initialPoolSize初始化池中的连接数为10,通过minPoolSize设置池中的最小连接数也为10,当池中数据库连接不够时,通过acquireIncrement增加连接数目,即每次增加5个,但池中的最大连接数maxPoolSize为50,当池中连接数目达到最大且都被使用时,则新任务排队等待有连接空闲出来;通过xml配置文件设置C3PO数据库连池的相应参数,并导入所需Jar包之后,通过Java语言编写数据库连接管理工具类JDBCUtils,首先,JDBCUtils通过静态成员变量定义并初始化线程池dataSource对象,还定义与数据库事务相关的专有连接,其绑定在对应线程之上,防止在多线程环境中出现数据安全问题,然后,JDBCUtils定义静态方法getConnection( )用于获取数据库连接,通过定义静态方法getDataSource( )获取数据库连接池,通过定义releaseConnection(Connectionconnection)方法释放连接,只是将使用完成之后的连接放回数据库连接池中,而真实的数据库物理连接并没有关闭,另外三个静态方法beginTransaction( )、commitTransaction( )和rollbackTransaction( )则与数据库中的事务相关,依次对应开启事务、提交事务和回滚事务,通过在程序中调用相应的事务方法,保证数据库事务处理的原子性、一致性、隔离性和持久性。