基于WebService的用电数据分组交互接口方法转让专利

申请号 : CN201510181075.9

文献号 : CN104821958B

文献日 :

基本信息:

PDF:

法律信息:

相似专利:

发明人 : 陶晓峰王军李捷吴少雄王有祥孙刚张洁

申请人 : 国家电网公司国电南瑞科技股份有限公司国网浙江省电力公司

摘要 :

本发明公开了一种基于WebService的用电数据分组交互接口方法,包括以下步骤,用电采集系统提供的WebService的数据接口服务,进行分组和生成优先级,并随机分配唯一的交互数据任务ID号,将分配的任务ID号返回给目标端;数据接口服务按需要交互的数据量进行分组及任务的优先级进行排序,并对每组任务生成子任务ID号;按顺序进行子任务对应的数据准备完成后,数据接口服务把对应子任务ID号返回给目标端,目标端根据子任务ID号快速获得准备好的数据,本发明的方法解决了WebService实时交互中根据请求的数据量及具体数据信息按优先级策略进行分组排序,并按顺序响应,实现分组异步交互,具有良好的应用前景。

权利要求 :

1.一种基于WebService的用电数据分组交互接口方法,其特征在于:包括以下步骤,步骤(1),通过用电采集系统提供的WebService的数据接口服务,接收目标端发起的用电数据交互任务,数据接口服务根据接收的用电数据交互任务的前台请求的类别或者后台请求的类别、业务查询需求设置任务等级,并随机分配唯一的用电数据交互任务ID号,并将分配的任务的用电数据交互任务ID号返回给目标端;

步骤(2),对任务等级最高的任务进行分析,通过用电采集系统对WebService的数据按设定的字节数进行分包,控制网络交互的次数和流量;同时根据前台或者后台的请求、业务查询需求的数据量大小,设置业务交互的优先级,并按需要交互的数据量根据Nagle分组策略算法进行分组,生成若干个子分包数据和对应的子任务ID号,用电采集系统按照短作业优先和最高响应比作业算法对子任务划分,等级高的子任务优先进行数据准备,进入消息队列准备数据交互;

步骤(3),当等级最高的子任务对应的数据准备完成后,WebService的数据接口服务把对应子任务ID号返回给目标端,目标端根据子任务ID号快速获得准备好的数据;

步骤(4)WebService的数据接口服务继续后续等级最高的子任务的数据准备,返回步骤(3),直到目标端获取所有分组子任务准备好的数据,执行步骤(5);

步骤(5),返回步骤(2),对后续等级最高的任务进行分析;

其中,步骤(1),数据接口服务根据接收的用电数据交互任务的前台请求的类别或者后台请求的类别、业务查询需求设置任务等级,前台请求包括:实时终端设备注册及取消注册;业务查询需求包括:对终端电能表信息、抄表数据、事件数据的后台查询;后台请求包括:定时任务扫描终端设备注册情况进行注册;任务等级根据业务重要程度及要求响应时效的角度由高到低分别为前台请求、业务查询、后台请求。

2.根据权利要求1所述的基于WebService的用电数据分组交互接口方法,其特征在于:

步骤(1)所述的任务ID号,用于描述任务信息体的唯一标识,通过任务ID号对任务信息体进行维护,任务ID号是不重复的。

3.根据权利要求1所述的基于WebService的用电数据分组交互接口方法,其特征在于:

步骤(2)所述的子任务ID号,用于描述子任务信息体的唯一标识,通过子任务ID号对子任务信息体进行维护,子任务ID号是不重复的,并从属于对应的任务ID号。

说明书 :

基于WebService的用电数据分组交互接口方法

技术领域

[0001] 本发明涉及用电采集系统技术领域,具体涉及一种基于WebService的用电数据分组交互接口方法。

背景技术

[0002] 由于WebService具有跨平台、分布式、松耦合等技术特点,在系统间数据交互中得到越来越广泛应用。目前,大部分异构系统间的信息交互方式都采用WebService+中间库的方式,但是,由于中间库存在垃圾数据没有及时清理,频率访问和统计造成数据库性能下降及更新操作造成锁表等问题,所以在用电采集系统与其它业务系统数据交互没有采用WebService+中间库的方式,只是直接采用Webservice方式进行数据交互,但是Webservice在网络中传输的是XML文件为基础的消息请求和响应,首先如果不采用中间库进行大量数据交互的存储载体,一次性大批量的数据传输会使网络成为瓶颈,容易造成数据丢包的问题;其次在进行数据准备时,也需要占用很多包括时间、性能等的服务端资源,迫切需求通过算法引入和程序优化提升用电采集系统与外部系统数据交互功能。
[0003] 根据上述介绍,以上现有技术方案的缺点为:在取消中间库的情况下,采用WebService方式传输数据量不能太大,请求大批量数据时对服务端性能有影响,请求端无法有效地监测到数据传输过程,同时业务需求造成批量查询及与外部系统交互的数据量非常大,抑制Webservice方式进行数据交互。

发明内容

[0004] 本发明所解决的技术问题是在取消中间库的情况下,采用WebService方式传输数据的问题。本发明的基于WebService的用电数据分组交互接口方法,在用电采集系统内基于Nagle分组策略算法和短作业优先、最高响应比作业算法与外部系统通过WebService实现系统间大批量数据的高效异步交互,很好的解决通过WebService方式传输大数据量的问题,具有良好应用前景。
[0005] 为了达到上述目的,本发明所采用的技术方案是:
[0006] 一种基于WebService的用电数据分组交互接口方法,其特征在于:包括以下步骤,[0007] 步骤(1),通过用电采集系统提供的WebService的数据接口服务,接收目标端发起的用电数据交互任务,数据接口服务根据接收的用电数据交互任务的前台或者后台请求类别、业务查询需求设置任务等级,并随机分配唯一的用电数据交互任务ID号,并将分配的任务的用电数据交互任务ID号返回给目标端;
[0008] 步骤(2),对任务等级最高的任务进行分析,通过用电采集系统对WebService的数据按设定的字节数进行分包,控制网络交互的次数和流量;同时根据前台或者后台的请求、业务查询需求的数据量大小,设置业务交互的优先级,并按需要交互的数据量根据Nagle分组策略算法进行分组,生成若干个子分包数据和对应的子任务ID号,用电采集系统按照短作业优先和最高响应比作业算法对子任务划分,等级高的子任务优先进行数据准备,进入消息队列准备数据交互;
[0009] 步骤(3),当等级最高的子任务对应的数据准备完成后,WebService的数据接口服务把对应子任务ID号返回给目标端,目标端根据子任务ID号快速获得准备好的数据;
[0010] 步骤(4)WebService的数据接口服务继续后续等级最高的子任务的数据准备,返回步骤(3),直到目标端获取所有分组子任务准备好的数据,执行步骤(5);
[0011] 步骤(5),返回步骤(2),对后续等级最高的任务进行分析。
[0012] 前述的基于WebService的用电数据分组交互接口方法,其特征在于:步骤(1),数据接口服务根据接收的用电数据交互任务的前台或者后台请求类别、业务查询需求设置任务等级,前台请求包括:实时终端设备注册及取消注册;业务查询需求包括:对终端电能表信息、抄表数据、事件数据的后台查询;后台请求包括:定时任务扫描终端设备注册情况进行注册;任务优先等级根据业务重要程度及要求响应时效的角度由高到低分别为前台请求、业务查询、后台请求。
[0013] 前述的基于WebService的用电数据分组交互接口方法,其特征在于:步骤(1)所述的任务ID号,用于描述任务信息体的唯一标识,通过任务ID号对任务信息体进行维护,任务ID号是不重复的。
[0014] 前述的基于WebService的用电数据分组交互接口方法,其特征在于:步骤(2)所述的子任务ID号,用于描述子任务信息体的唯一标识,通过子任务ID号对子任务信息体进行维护,子任务ID号是不重复的,并从属于对应的任务ID号。
[0015] 本发明的有益效果是:本发明的基于WebService的用电数据分组交互接口方法,在用电采集系统内基于Nagle分组策略算法和短作业优先、最高响应比作业算法与外部系统通过WebService实现系统间大批量数据的高效异步交互,实现分组异步交互,很好的解决通过WebService方式传输大数据量的问题,具有良好应用前景。

附图说明

[0016] 图1是本发明的基于WebService的用电数据分组交互接口方法的流程图图。

具体实施方式

[0017] 下面将结合说明书附图,对本发明作进一步的说明。
[0018] 本发明的基于WebService的用电数据分组交互接口方法,在用电采集系统内基于Nagle分组策略算法和短作业优先、最高响应比作业算法与外部系统通过WebService实现系统间大批量数据的高效异步交互,实现分组异步交互,很好的解决通过WebService方式传输大数据量的问题,如图1所示,具体包括以下步骤,
[0019] 步骤(1),通过用电采集系统提供的WebService的数据接口服务,接收目标端发起的用电数据交互任务,数据接口服务根据接收的用电数据交互任务的前台或者后台请求类别、业务查询需求设置任务等级,并随机分配唯一的用电数据交互任务ID号,并将分配的任务的用电数据交互任务ID号返回给目标端,任务ID号,用于描述任务信息体的唯一标识,通过任务ID号对任务信息体进行维护,任务ID号是不重复的;
[0020] 所述的数据接口服务根据接收的用电数据交互任务的前台或者后台请求类别、业务查询需求设置任务等级,前台请求包括:实时终端设备注册及取消注册;业务查询需求包括:对终端电能表信息、抄表数据、事件数据的后台查询;后台请求包括:定时任务扫描终端设备注册情况进行注册;任务优先等级根据业务重要程度及要求响应时效的角度由高到低分别为前台请求、业务查询、后台请求;
[0021] 步骤(2),对任务等级最高的任务进行分析,通过用电采集系统对WebService的数据按设定的字节数进行分包,控制网络交互的次数和流量;同时根据前台或者后台的请求、业务查询需求的数据量大小,设置业务交互的优先级,并按需要交互的数据量根据Nagle分组策略算法进行分组,生成若干个子分包数据和对应的子任务ID号,用电采集系统按照短作业优先和最高响应比作业算法对子任务划分,等级高的子任务优先进行数据准备,进入消息队列准备数据交互,子任务ID号,用于描述子任务信息体的唯一标识,通过子任务ID号对子任务信息体进行维护,子任务ID号是不重复的,并从属于对应的任务ID号;
[0022] 步骤(3),当等级最高的子任务对应的数据准备完成后,WebService的数据接口服务把对应子任务ID号返回给目标端,目标端根据子任务ID号快速获得准备好的数据,即获得对应XML文件中的数据;
[0023] 步骤(4)WebService的数据接口服务继续后续等级最高的子任务的数据准备,返回步骤(3),直到目标端获取所有分组子任务准备好的数据,执行步骤(5);
[0024] 步骤(5),返回步骤(2),对后续等级最高的任务进行分析。
[0025] 以上显示和描述了本发明的基本原理和主要特征和本发明的优点。本行业的技术人员应该了解,本发明不受上述实施例的限制,上述实施例和说明书中描述的只是说明本发明的原理,在不脱离本发明精神和范围的前提下,本发明还会有各种变化和改进,这些变化和改进都落入要求保护的本发明范围内。本发明要求保护范围由所附的权利要求书及其等效物界定。