一种传输数据的方法及装置的制造方法

xiaoxiao2021-2-28  197

一种传输数据的方法及装置的制造方法
【技术领域】
[0001 ]本发明涉及计算机技术领域,特别涉及一种传输数据的方法及装置。
【背景技术】
[0002]随着计算机技术的快速发展,数据库的应用也越来越多,数据库之间的数据传输也越来越频繁。
[0003]现有技术中,业务生成数据库生成业务数据,业务消费数据库保存消费数据。业务生成数据库将生成的业务数据传输给业务消费数据库,业务消费数据库生成消费数据,向外部提供消费数据。当外部请求的消费数据在业务消费数据库中没有时,需要等到业务生成数据库将相关的数据发送给业务消费数据库,再由业务消费数据库返回对应的消费数据。
[0004]通过上述描述可见,现有技术中的数据传输方式,由于数据库之间数据传输相对较慢,因此,在被请求的数据没有保存在业务消费数据库中时,请求方需要等待较长的时间才能获得需要的数据。在现有的数据传输方法中,一般通过一个实体表来接收外部发来的业务数据并向外部返回消费数据,当实体表与外部进行消费数据的交互时,会降低业务数据的处理效率,进而会降低消费数据的处理效率。总之,现有技术中数据处理的效率较低。

【发明内容】

[0005]有鉴于此,本发明提供了一种传输数据的方法及装置,能够提高数据处理的效率。
[0006]—方面,本发明提供了一种传输数据的方法,包括:预先在目标数据库中设置第一实体表和第二实体表;实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中;将所述第一实体表中的业务数据,实时更新到所述第二实体表中;还包括:
[0007]S1:接收对消费数据的请求;
[0008]S2:根据所述请求,获取所述第二实体表中对应的业务数据;
[0009]S3:根据所述请求对应的业务数据,生成被请求的消费数据;
[0010]S4:返回被请求的消费数据。
[0011]进一步地,所述实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中,包括:通过联合体将所述第一实体表与外部进行对接,实时接收外部通过联合体发来的业务数据,并将所述业务数据保存到所述第一实体表中。
[0012]进一步地,所述将所述第一实体表中的业务数据,实时更新到所述第二实体表中,包括:
[0013]调用高速服务,通过所述高速服务,将所述第一实体表中的业务数据,实时更新到所述第二实体表中。
[0014]进一步地,所述S3中,根据所述请求对应的业务数据,生成被请求的消费数据,包括:
[0015]根据所述请求对应的业务数据和当前的消费数据,生成被请求的消费数据。
[0016]进一步地,在所述S1之后,在所述S2之前,还包括:
[0017]根据所述请求,判断所述请求对应的业务数据是否在所述第二实体表中,如果是,则执行步骤S2,否则,执行步骤A1;
[0018]A1:根据所述请求,向所述第一实体表中获取对应的业务数据,执行步骤S3。
[0019]进一步地,所述外部包括:源数据库;
[0020]所述源数据库和所述目标数据库均为读写分离的数据库。
[0021 ]另一方面,本发明提供了一种传输数据的装置,包括:
[0022]设置单元,用于在目标数据库中设置第一实体表和第二实体表;
[0023]数据接收单元,用于实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中;
[0024]更新单元,用于将所述第一实体表中的业务数据,实时更新到所述第二实体表中;
[0025]请求接收单元,用于接收对消费数据的请求;
[0026]第一获取单元,用于根据所述请求,获取所述第二实体表中对应的业务数据;
[0027]生成单元,用于根据所述请求对应的业务数据,生成被请求的消费数据;
[0028]返回单元,用于返回被请求的消费数据。
[0029]进一步地,所述数据接收单元,用于通过联合体将所述第一实体表与外部进行对接,实时接收外部通过联合体发来的业务数据,并将所述业务数据保存到所述第一实体表中。
[0030]进一步地,所述更新单元,用于调用高速服务,通过所述高速服务,将所述第一实体表中的业务数据,实时更新到所述第二实体表中。
[0031]进一步地,所述生成单元,用于根据所述请求对应的业务数据和当前的消费数据,生成被请求的消费数据。
[0032]进一步地,该装置还包括:
[0033]判断单元,用于根据所述请求,判断所述请求对应的业务数据是否在所述第二实体表中,当判断结果为是时,通知所述第一获取单元,当判断结果为否时,通知第二获取单元;
[0034]所述第二获取单元,用于根据所述请求,向所述第一实体表中获取对应的业务数据,通知所述生成单元。
[0035]进一步地,所述外部包括:源数据库;
[0036]所述源数据库和所述目标数据库均为读写分离的数据库。
[0037]本发明实施例提供了一种传输数据的方法及装置,在目标数据库中设置两个实体表,通过第一实体表实时保存外部发来的业务数据,将第一实体表中的业务数据实时更新到第二实体表中,当接收到对消费数据的请求时,从第二实体表中获取对应的业务数据响应该请求,接收业务数据和响应请求的数据是不同的实体表,使得在响应请求时,不会影响业务数据的接收,进而提高了业务数据的接收效率,响应请求也不会因为接收业务数据而受到影响,进而提高了请求的响应效率,总之,本发明实施例提供的一种传输数据的方法,提高了数据处理的效率。
【附图说明】
[0038]为了更清楚地说明本发明实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。
[0039]图1是本发明一实施例提供的一种传输数据的方法的流程图;
[0040]图2是本发明一实施例提供的另一种传输数据的方法的流程图;
[0041]图3是本发明一实施例提供的一种传输数据的装置的示意图;
[0042]图4是本发明一实施例提供的另一种传输数据的装置的示意图。
【具体实施方式】
[0043]为使本发明实施例的目的、技术方案和优点更加清楚,下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例是本发明一部分实施例,而不是全部的实施例,基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动的前提下所获得的所有其他实施例,都属于本发明保护的范围。
[0044]如图1所示,本发明实施例提供了一种传输数据的方法,该方法可以包括以下步骤:
[0045]步骤101:预先在目标数据库中设置第一实体表和第二实体表;
[0046]步骤102:实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中;
[0047]步骤103:将所述第一实体表中的业务数据,实时更新到所述第二实体表中;
[0048]步骤104:接收对消费数据的请求;
[0049]步骤105:根据所述请求,获取所述第二实体表中对应的业务数据;
[0050]步骤106:根据所述请求对应的业务数据,生成被请求的消费数据;
[0051]步骤107:返回被请求的消费数据。
[0052]本发明实施例提供了一种传输数据的方法,在目标数据库中设置两个实体表,通过第一实体表实时保存外部发来的业务数据,将第一实体表中的业务数据实时更新到第二实体表中,当接收到对消费数据的请求时,从第二实体表中获取对应的业务数据响应该请求,接收业务数据和响应请求的数据是不同的实体表,使得在响应请求时,不会影响业务数据的接收,进而提高了业务数据的接收效率,响应请求也不会因为接收业务数据而受到影响,进而提高了请求的响应效率,总之,本发明实施例提供的一种传输数据的方法,提高了数据处理的效率。
[0053]为了提高数据传输的速度,在一种可能的实现方式中,所述实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中,包括:通过联合体将所述第一实体表与外部进行对接,实时接收外部通过联合体发来的业务数据,并将所述业务数据保存到所述第一实体表中。
[0054]在该实现方式中,将目标数据库通过联合体与外部的数据库进行对接,能够加快数据传输的速度,提高数据处理的效率。
[0055]在一种可能的实现方式中,所述将所述第一实体表中的业务数据,实时更新到所述第二实体表中,包括:
[0056]调用高速服务,通过所述高速服务,将所述第一实体表中的业务数据,实时更新到所述第二实体表中。
[0057]在该实现方式中,在第一实体表和第二实体表之间通过高速服务进行数据交互,加快了数据传输的速度
[0058]在一种可能的实现方式中,所述步骤106中,根据所述请求对应的业务数据,生成被请求的消费数据,包括:根据所述请求对应的业务数据和当前的消费数据,生成被请求的消费数据。
[0059]在一种可能的实现方式中,在步骤104之后,在步骤105之前,还包括:
[0060]根据所述请求,判断所述请求对应的业务数据是否在所述第二实体表中,如果是,则执行步骤105,否则,执行步骤A1;
[0061]A1:根据所述请求,向所述第一实体表中获取对应的业务数据,执行步骤106。
[0062]在一种可能的实现方式中,所述外部包括:源数据库;
[0063]所述源数据库和所述目标数据库均为读写分离的数据库。
[0064]为使本发明的目的、技术方案和优点更加清楚,下面结合附图及具体实施例对本发明作进一步地详细描述。
[0065]在该实施例中,目标数据库是业务消费数据库,外部为业务生产数据库。业务生产数据库将业务数据传输给业务消费数据库,业务消费数据库向外部提供消费数据。
[0066]如图2所示,本发明实施例提供了一种传输数据的方法,该方法可以包括以下步骤:
[0067]步骤201:预先在目标数据库中设置第一实体表和第二实体表。
[ 0068]这两个实体表可以是相同的实体表,这样第一实体表和第二实体表进行数据交互时更加方便。
[0069]步骤202:通过联合体将第一实体表与业务生产数据库进行对接,实时接收外部通过联合体发来的业务数据,并将业务数据保存到第一实体表中。
[0070]通过联合体将业务生产数据库与业务消费数据库进行对接,只是对接第一实体表,方便业务数据的传输。
[0071]步骤203:调用高速服务,通过高速服务,将第一实体表中的业务数据,实时更新到第二实体表中。
[0072]在第一实体表与第二实体表之间通过高速服务进行数据交互,提高了数据传输的速度。可以通过将第一实体表中的数据复制到第二实体表中实现。
[0073]步骤204:接收对消费数据的请求。
[0074]步骤205:根据请求,获取第二实体表中对应的业务数据。
[0075]步骤206:根据请求对应的业务数据,生成被请求的消费数据。
[0076]步骤207:返回被请求的消费数据。
[0077]本发明实施例提供的方法,可以有效降低业务消费对业务生产的影响,可实现读写分离跨数据库之间数据的高效率交互,更好的满足客户对业务数据同时生产和消费的高可靠性和高效率要求。
[0078]如图3、图4所示,本发明实施例提供了一种传输数据的装置。装置实施例可以通过软件实现,也可以通过硬件或者软硬件结合的方式实现。从硬件层面而言,如图3所示,为本发明实施例提供的一种传输数据的装置所在设备的一种硬件结构图,除了图3所示的处理器、内存、网络接口、以及非易失性存储器之外,实施例中装置所在的设备通常还可以包括其他硬件,如负责处理报文的转发芯片等等。以软件实现为例,如图4所示,作为一个逻辑意义上的装置,是通过其所在设备的CPU将非易失性存储器中对应的计算机程序指令读取到内存中运行形成的。本实施例提供的一种传输数据的装置,包括:
[0079]设置单元401,用于在目标数据库中设置第一实体表和第二实体表;
[0080]数据接收单元402,用于实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中;
[0081 ]更新单元403,用于将所述第一实体表中的业务数据,实时更新到所述第二实体表中;
[0082]请求接收单元404,用于接收对消费数据的请求;
[0083]第一获取单元405,用于根据所述请求,获取所述第二实体表中对应的业务数据;
[0084]生成单元406,用于根据所述请求对应的业务数据,生成被请求的消费数据;
[0085]返回单元407,用于返回被请求的消费数据。
[0086]在一种可能的实现方式中,所述数据接收单元402,用于通过联合体将所述第一实体表与外部进行对接,实时接收外部通过联合体发来的业务数据,并将所述业务数据保存到所述第一实体表中。
[0087]在一种可能的实现方式中,所述更新单元403,用于调用高速服务,通过所述高速服务,将所述第一实体表中的业务数据,实时更新到所述第二实体表中。
[0088]在一种可能的实现方式中,所述生成单元406,用于根据所述请求对应的业务数据和当前的消费数据,生成被请求的消费数据。
[0089]在一种可能的实现方式中,该装置还包括:判断单元,用于根据所述请求,判断所述请求对应的业务数据是否在所述第二实体表中,当判断结果为是时,通知所述第一获取单元,当判断结果为否时,通知第二获取单元;
[0090]所述第二获取单元,用于根据所述请求,向所述第一实体表中获取对应的业务数据,通知所述生成单元。
[0091 ]在一种可能的实现方式中,所述外部包括:源数据库;所述源数据库和所述目标数据库均为读写分离的数据库。
[0092]上述装置内的各单元之间的信息交互、执行过程等内容,由于与本发明方法实施例基于同一构思,具体内容可参见本发明方法实施例中的叙述,此处不再赘述。
[0093]本发明实施例提供的一种传输数据的方法及装置,具有如下有益效果:
[0094]1、本发明实施例提供了一种传输数据的方法及装置,在目标数据库中设置两个实体表,通过第一实体表实时保存外部发来的业务数据,将第一实体表中的业务数据实时更新到第二实体表中,当接收到对消费数据的请求时,从第二实体表中获取对应的业务数据响应该请求,接收业务数据和响应请求的数据是不同的实体表,使得在响应请求时,不会影响业务数据的接收,进而提高了业务数据的接收效率,响应请求也不会因为接收业务数据而受到影响,进而提高了请求的响应效率,总之,本发明实施例提供的一种传输数据的方法,提高了数据处理的效率。
[0095]2、本发明实施例提供的一种传输数据的方法及装置,可以有效降低业务消费对业务生产的影响,可实现读写分离跨数据库之间数据的高效率交互,更好的满足客户对业务数据同时生产和消费的高可靠性和高效率要求。
[0096]需要说明的是,在本文中,诸如第一和第二之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来,而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下,由语句“包括一个〃〃〃〃〃〃”限定的要素,并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同因素。
[0097]本领域普通技术人员可以理解:实现上述方法实施例的全部或部分步骤可以通过程序指令相关的硬件来完成,前述的程序可以存储在计算机可读取的存储介质中,该程序在执行时,执行包括上述方法实施例的步骤;而前述的存储介质包括:ROM、RAM、磁碟或者光盘等各种可以存储程序代码的介质中。
[0098]最后需要说明的是:以上所述仅为本发明的较佳实施例,仅用于说明本发明的技术方案,并非用于限定本发明的保护范围。凡在本发明的精神和原则之内所做的任何修改、等同替换、改进等,均包含在本发明的保护范围内。
【主权项】
1.一种传输数据的方法,其特征在于,包括:预先在目标数据库中设置第一实体表和第二实体表;实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中;将所述第一实体表中的业务数据,实时更新到所述第二实体表中;还包括: S1:接收对消费数据的请求; 52:根据所述请求,获取所述第二实体表中对应的业务数据; 53:根据所述请求对应的业务数据,生成被请求的消费数据; S4:返回被请求的消费数据。2.根据权利要求1所述的方法,其特征在于,所述实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中,包括:通过联合体将所述第一实体表与外部进行对接,实时接收外部通过联合体发来的业务数据,并将所述业务数据保存到所述第一实体表中。3.根据权利要求1所述的方法,其特征在于,所述将所述第一实体表中的业务数据,实时更新到所述第二实体表中,包括: 调用高速服务,通过所述高速服务,将所述第一实体表中的业务数据,实时更新到所述第二实体表中。4.根据权利要求1所述的方法,其特征在于,所述S3中,根据所述请求对应的业务数据,生成被请求的消费数据,包括: 根据所述请求对应的业务数据和当前的消费数据,生成被请求的消费数据。5.根据权利要求1-4中任一所述的方法,其特征在于,在所述S1之后,在所述S2之前,还包括: 根据所述请求,判断所述请求对应的业务数据是否在所述第二实体表中,如果是,则执行步骤S2,否则,执行步骤A1; A1:根据所述请求,向所述第一实体表中获取对应的业务数据,执行步骤S3; 和/或, 所述外部包括:源数据库; 所述源数据库和所述目标数据库均为读写分离的数据库。6.一种传输数据的装置,其特征在于,包括: 设置单元,用于在目标数据库中设置第一实体表和第二实体表; 数据接收单元,用于实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中; 更新单元,用于将所述第一实体表中的业务数据,实时更新到所述第二实体表中; 请求接收单元,用于接收对消费数据的请求; 第一获取单元,用于根据所述请求,获取所述第二实体表中对应的业务数据; 生成单元,用于根据所述请求对应的业务数据,生成被请求的消费数据; 返回单元,用于返回被请求的消费数据。7.根据权利要求6所述的装置,其特征在于,所述数据接收单元,用于通过联合体将所述第一实体表与外部进行对接,实时接收外部通过联合体发来的业务数据,并将所述业务数据保存到所述第一实体表中。8.根据权利要求6所述的装置,其特征在于,所述更新单元,用于调用高速服务,通过所述高速服务,将所述第一实体表中的业务数据,实时更新到所述第二实体表中。9.根据权利要求6所述的装置,其特征在于,所述生成单元,用于根据所述请求对应的业务数据和当前的消费数据,生成被请求的消费数据。10.根据权利要求6-9中任一所述的装置,其特征在于,还包括: 判断单元,用于根据所述请求,判断所述请求对应的业务数据是否在所述第二实体表中,当判断结果为是时,通知所述第一获取单元,当判断结果为否时,通知第二获取单元;所述第二获取单元,用于根据所述请求,向所述第一实体表中获取对应的业务数据,通知所述生成单元; 和/或, 所述外部包括:源数据库; 所述源数据库和所述目标数据库均为读写分离的数据库。
【专利摘要】本发明提供了一种传输数据的方法及装置,该方法包括:预先在目标数据库中设置第一实体表和第二实体表;实时接收外部发来的业务数据,并将所述业务数据保存到所述第一实体表中;将所述第一实体表中的业务数据,实时更新到所述第二实体表中;接收对消费数据的请求;根据所述请求,获取所述第二实体表中对应的业务数据;根据所述请求对应的业务数据,生成被请求的消费数据;返回被请求的消费数据。本发明提供了一种传输数据的方法及装置,能够提高数据处理的效率。
【IPC分类】G06F17/30
【公开号】CN105488157
【申请号】CN201510853100
【发明人】闫中玉, 阎磊
【申请人】浪潮软件股份有限公司
【公开日】2016年4月13日
【申请日】2015年11月27日

最新回复(0)