多账户高速交易方法、装置、存储介质及电子装置

摘要

本申请公开了一种多账户高速交易方法、装置、存储介质及电子装置。该多账户高速交易方法包括：接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；获取所述高频交易事务中每个事务项所涉及的账户余额记录；对所述每个事务项执行一致性规整操作；对一致性规整的事务项所对应的账户余额进行加扣，并记录余额加扣和流水记录。本申请解决了由于交易事务处理响应时间长造成的交易速率无法得到保证的技术问题。

权利要求

1.一种多账户高速交易方法，其特征在于，包括：

接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；

获取所述高频交易事务中每个事务项所涉及的账户余额记录；

对所述每个事务项执行一致性规整操作；对所述每个事务项执行一致性规整操作包括：通过hash算法提取事务项的核心特征值的特征标志，基于特征标志对事务项进行顺序化处理；

在高速交易执行模块中采用账户并行处理的方式，对一致性规整的事务项所对应的账户余额进行加扣，并记录余额加扣和流水记录；

对所述每个事务项执行一致性规整操作之后还包括：

判断一致性规整后的事务项的并行反馈值是否满足预设并行事务率；所述并行反馈值的获取包括：先记录每个高频热点账户的并行特征值，然后基于并行特征值实时生成并行反馈值，最后将并行反馈值存储于高速存储装置中；

如果满足，则对满足预设并行事务率的事务项所对应的账户余额进行余额加扣，并记录余额加扣和流水记录；

如果不满足，则记录余额加扣和流水记录；

根据所述余额加扣记录和流水记录对不满足预设并行事务率的事务项所对应的账户余额进行批量余额同步加扣。

2.根据权利要求1所述的多账户高速交易方法，其特征在于，记录余额加扣和流水记录之后还包括：将账户余额记录、余额加扣和流水记录存到关系型数据库中。

3.根据权利要求2所述的多账户高速交易方法，其特征在于，将账户余额记录、余额加扣和流水记录存到关系型数据库中之后还包括：接收用户对待查询账户的余额查询请求；

响应于余额查询请求，根据账户余额记录和账户加扣记录计算所述待查询账户的账户余额，并返回给用户。

4.一种多账户高速交易装置，其特征在于，包括：

事务接收单元，用于接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；

记录获取单元，用于获取所述高频交易事务中每个事务项所涉及的账户余额记录；

一致性规整单元，用于对所述每个事务项执行一致性规整操作；对所述每个事务项执行一致性规整操作包括：通过hash算法提取事务项的核心特征值的特征标志，基于特征标志对事务项进行顺序化处理；

加扣记录单元，用于在高速交易执行模块中采用并行处理的方式，对一致性规整的事务项所对应的账户余额进行加扣后记录流水，并据其更新账户余额记录；

对所述每个事务项执行一致性规整操作之后还包括：

判断一致性规整后的事务项的并行反馈值是否满足预设并行事务率；

如果满足，则对满足预设并行事务率的事务项所对应的账户余额进行余额加扣，并记录余额加扣和流水记录；

如果不满足，则记录余额加扣和流水记录；

根据所述余额加扣记录和流水记录对不满足预设并行事务率的事务项所对应的账户余额进行批量余额同步加扣。

5.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质中存储有计算机程序，其中，所述计算机程序被设置为运行时执行所述权利要求1至3中任一项所述的多账户高速交易方法。

6.一种电子装置，包括：存储器和处理器，其特征在于，所述存储器中存储有计算机程序，其中，所述处理器被设置为运行所述计算机程序以执行所述权利要求1至3中任一项所述的多账户高速交易方法。

说明书

多账户高速交易方法、装置、存储介质及电子装置

技术领域

[0001] 本申请涉及线上交易领域，具体而言，涉及一种多账户高速交易方法、装置、存储介质及电子装置。

背景技术

[0002] 发明人发现，基于关系型数据库进行多个高频热点账户的同时交易时，采用的是逐个账户进行处理，往往造成交易事务处理响应时间长，交易速率无法得到保证。

[0003] 针对相关技术中交易事务处理响应时间长造成的交易速率无法得到保证的问题，目前尚未提出有效的解决方案。

发明内容

[0004] 本申请的主要目的在于提供一种多账户高速交易方法、装置、存储介质及电子装置，以解决交易事务处理响应时间长造成的交易速率无法得到保证的问题。

[0005] 为了实现上述目的，根据本申请的一个方面，提供了一种多账户高速交易方法。

[0006] 根据本申请的多账户高速交易方法包括：接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；获取所述高频交易事务中每个事务项所涉及的账户余额记
录；对所述每个事务项执行一致性规整操作；对一致性规整的事务项所对应的账户余额进
行加扣，并记录余额加扣和流水记录。

[0007] 进一步的，对所述每个事务项执行一致性规整操作之后还包括：判断一致性规整后的事务项的并行反馈值是否满足预设并行事务率；如果满足，则对满足预设并行事务率
的事务项所对应的账户余额进行余额加扣，并记录余额加扣和流水记录。

[0008] 进一步的，判断一致性规整后的事务项的并行反馈值是否满足预设并行事务率之后还包括：如果不满足，则记录余额加扣和流水记录；根据所述余额加扣记录和流水记录对
不满足预设并行事务率的事务项所对应的账户余额进行批量余额同步加扣。

[0009] 进一步的，所述并行反馈值的获取包括：先记录每个高频热点账户的并行特征值，然后基于并行特征值实时生成并行反馈值，最后将并行反馈值存储于高速存储装置中。

[0010] 进一步的，对所述每个事务项执行一致性规整操作包括：通过hash算法提取事务项的核心特征值的特征标志，基于特征标志对事务项进行顺序化处理。

[0011] 进一步的，记录余额加扣和流水记录之后还包括：将账户余额记录、余额加扣和流水记录存到关系型数据库中。

[0012] 进一步的，将账户余额记录、余额加扣和流水记录存到关系型数据库中之后还包括：接收用户对待查询账户的余额查询请求；响应于余额查询请求，根据账户余额记录和账
户加扣记录计算所述待查询账户的账户余额，并返回给用户。

[0013] 为了实现上述目的，根据本申请的另一方面，提供了一种多账户高速交易装置。

[0014] 根据本申请的多账户高速交易装置包括：事务接收单元，用于接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；记录获取单元，用于获取所述高频交易
事务中每个事务项所涉及的账户余额记录；一致性规整单元，用于对所述每个事务项执行
一致性规整操作；加扣记录单元，用于对一致性规整的事务项所对应的账户余额进行加扣
后记录流水，并据其更新账户余额记录。

[0015] 为了实现上述目的，根据本申请的另一方面，提供了一种计算机可读存储介质。

[0016] 根据本申请的计算机可读存储介质，所述计算机可读存储介质中存储有计算机程序，其中，所述计算机程序被设置为运行时执行所述的多账户高速交易方法。

[0017] 为了实现上述目的，根据本申请的另一方面，提供了一种电子装置。

[0018] 根据本申请的电子装置，包括：存储器和处理器，所述存储器中存储有计算机程序，其中，所述处理器被设置为运行所述计算机程序以执行所述的多账户高速交易方法。

[0019] 在本申请实施例中，采用多账户高速交易的方式，通过接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；获取所述高频交易事务中每个事务项所涉及的
账户余额记录；对所述每个事务项执行一致性规整操作；对一致性规整的事务项所对应的
账户余额进行加扣，并记录余额加扣和流水记录；达到了大大缩减交易事务处理响应时间
的目的，从而实现了有效提升交易速率的技术效果，进而解决了由于交易事务处理响应时
间长造成的交易速率无法得到保证的技术问题。

附图说明

[0020] 构成本申请的一部分的附图用来提供对本申请的进一步理解，使得本申请的其它特征、目的和优点变得更明显。本申请的示意性实施例附图及其说明用于解释本申请，并不
构成对本申请的不当限定。在附图中：

[0021] 图1是根据本申请实施例的多账户高速交易方法的流程示意图；

[0022] 图2是根据本申请实施例的多账户高速交易装置的结构示意图；

[0023] 图3是根据本申请要选实施例的多账户高速交易装置的结构示意图。

具体实施方式

[0024] 为了使本技术领域的人员更好地理解本申请方案，下面将结合本申请实施例中的附图，对本申请实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是
本申请一部分的实施例，而不是全部的实施例。基于本申请中的实施例，本领域普通技术人
员在没有做出创造性劳动前提下所获得的所有其他实施例，都应当属于本申请保护的范
围。

[0025] 需要说明的是，本申请的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用
的数据在适当情况下可以互换，以便这里描述的本申请的实施例。此外，术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或单元的
过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元，而是可包括没有清
楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。

[0026] 在本申请中，术语“上”、“下”、“左”、“右”、“前”、“后”、“顶”、“底”、“内”、“外”、“中”、“竖直”、“水平”、“横向”、“纵向”等指示的方位或位置关系为基于附图所示的方位或位置关系。这些术语主要是为了更好地描述本发明及其实施例，并非用于限定所指示的装置、元件或组成部分必须具有特定方位，或以特定方位进行构造和操作。

[0027] 并且，上述部分术语除了可以用于表示方位或位置关系以外，还可能用于表示其他含义，例如术语“上”在某些情况下也可能用于表示某种依附关系或连接关系。对于本领
域普通技术人员而言，可以根据具体情况理解这些术语在本发明中的具体含义。

[0028] 此外，术语“安装”、“设置”、“设有”、“连接”、“相连”、“套接”应做广义理解。例如，可以是固定连接，可拆卸连接，或整体式构造；可以是机械连接，或电连接；可以是直接相连，或者是通过中间媒介间接相连，又或者是两个装置、元件或组成部分之间内部的连通。
对于本领域普通技术人员而言，可以根据具体情况理解上述术语在本发明中的具体含义。

[0029] 需要说明的是，在不冲突的情况下，本申请中的实施例及实施例中的特征可以相互组合。下面将参考附图并结合实施例来详细说明本申请。

[0030] 根据本发明实施例，提供了一种多账户高速交易方法，如图1所示，该方法包括如下的步骤S101至步骤S104：

[0031] 步骤S101、接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；

[0032] 高频热点账户为单位时间内可能产生多次交易的账户；也就导致在短时间内会出现多次加扣余额的情况。如此，当多个高频热点账户在同一个交易中时，每个账户均有可能
加扣余额，只能使用队列逐个进行账户余额的加扣，但是这必然造成整个交易事务处理响
应时间很长，交易速率得不到保证。为了解决这个问题，本实施例中，先将同一个交易中的
所有高频热点账户定义为一个高频交易事务，其中每个事务项对应一个账户交易事务，为
后续的并行处理该高频交易事务中的所有事务项提供了保障。

[0033] 本实施例中，采用高速交易执行模块接收多个高频热点账户在进行同一个交易时所定义的高频交易事务。

[0034] 步骤S102、获取所述高频交易事务中每个事务项所涉及的账户余额记录；

[0035] 加扣余额时，根据交易双方或多方应当支出的金额可以推算出每个账户应当加扣的余额；但是并不知道账户上本身有多少余额，不利于后续对账户查询的实时响应。为此，
需要先从高频交易事务中每个事务项中提取出对应的账户余额记录，保证后续的余额加扣
的顺利进行。

[0036] 本实施例中，在高速交易执行模块中同时进行每个事务项所涉及的账户余额记录的获取。

[0037] 步骤S103、对所述每个事务项执行一致性规整操作；

[0038] 通过一致性规整操作，能够使得高频交易事务内所有事务项执行时全局一致性规整，为后续的加扣的并行处理提供保障。

[0039] 本实施例中，在高速交易执行模块中对所述每个事务项执行一致性规整操作。

[0040] 优选的，对所述每个事务项执行一致性规整操作包括：

[0041] 通过hash算法提取事务项的核心特征值的特征标志，基于特征标志对事务项进行顺序化处理。

[0042] 把每个事务项的加扣性质，交易性质，涉及余额账户的全局唯一标志，账户性质等核心特征值通过hash算法提取特征标志，基于特征标志，对事务项进行顺序化处理，从而达
到事务内所有事务项执行时的全局一致性规整的目的。

[0043] 步骤S104、对一致性规整的事务项所对应的账户余额进行加扣，并记录余额加扣和流水记录。

[0044] 可以是对一致性规整后的事务项直接进行账户余额加扣，具体地，在高速交易执行模块中采用并行处理的方式给每个事务项所对应的每个账户余额进行加扣，并且计记录
余额加扣和流水记录。加扣时，每个账户余额分别同时进行，得到的余额加扣和流水记录与
先前获取的账户余额记录相对应，为后续存储提供关联基础。

[0045] 采用高速交易执行模块实现了账户扣余额和记录的并行处理，替代了逐个账户进行处理，大大降低了交易事务处理响应时间，也就有效提升了交易速率。

[0046] 从以上的描述中，可以看出，本发明实现了如下技术效果：

[0047] 在本申请实施例中，采用多账户高速交易的方式，通过接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；获取所述高频交易事务中每个事务项所涉及的
账户余额记录；对所述每个事务项执行一致性规整操作；对一致性规整的事务项所对应的
账户余额进行加扣，并记录余额加扣和流水记录；达到了大大缩减交易事务处理响应时间
的目的，从而实现了有效提升交易速率的技术效果，进而解决了由于交易事务处理响应时
间长造成的交易速率无法得到保证的技术问题。

[0048] 根据本发明实施例，优选的，对所述每个事务项执行一致性规整操作之后还包括：

[0049] 判断一致性规整后的事务项的并行反馈值是否满足预设并行事务率；

[0050] 如果满足，则对满足预设并行事务率的事务项所对应的账户余额进行余额加扣，并记录余额加扣和流水记录；

[0051] 如果不满足，则记录余额加扣和流水记录，并根据所述余额加扣记录和流水记录对不满足预设并行事务率的事务项所对应的账户余额进行批量余额同步加扣。

[0052] 判断致性规整后的事务项的并行反馈值是否低于或等于预设并行事务率，如果满足，表明这些事务项符合高速交易执行模块的并行处理条件，则直接在高速交易执行模块
上，对满足预设并行事务率的事务项所对应的账户余额进行余额加扣，并记录余额加扣和
流水记录。如果超出预设并行事务率，表明这些事务项不符合高速交易执行模块的并行处
理条件，则记录余额加扣和流水记录，并通过高速余额同步处理定时器，根据所述余额加扣
记录和流水记录对不满足预设并行事务率的事务项所对应的账户余额进行批量余额同步
加扣。

[0053] 本实施例中，每个定时器装置基于定时周期（根据需求和实际条件周期可以为毫秒级周期，也可以是秒级周期等）进行高速运转，对超出并行事务率的账户的余额，基于账
户余额记录和自身的加扣记录进行批量余额同步。

[0054] 实现了周期内能进行的事务率不受数据库事务控制影响，通过判断分别并行处理符合和不符合事务率的项目，有效加快了处理速度。

[0055] 优选的，所述并行反馈值的获取包括：先记录每个高频热点账户的并行特征值，然后基于并行特征值实时生成并行反馈值，最后将并行反馈值存储于高速存储装置中。采用
并行事务控制反馈模块进行监控，能够基于监测到的并行特征值生成并行反馈值，从而保
证判断流程的正常进行。

[0056] 根据本发明实施例，优选的，记录余额加扣和流水记录之后还包括：

[0057] 将账户余额记录、余额加扣和流水记录存到关系型数据库中。

[0058] 接收用户对待查询账户的余额查询请求；

[0059] 响应于余额查询请求，根据账户余额记录和账户加扣记录计算所述待查询账户的账户余额，并返回给用户。

[0060] 由于采用了以上的高速交易执行模块、并行事务控制反馈模块和定时器的配合，实现了事务处理提速，基于此，也能够根据处理得到的账户余额记录、余额加扣和流水记录
快速存到关系型数据库中，当有实时获取高频热点账户余额的查询请求时，高频热点账户
余额查询模块就可以快速做出响应，从而有效保证了查询余额的实时性和准确性。

[0061] 需要说明的是，在附图的流程图示出的步骤可以在诸如一组计算机可执行指令的计算机系统中执行，并且，虽然在流程图中示出了逻辑顺序，但是在某些情况下，可以以不
同于此处的顺序执行所示出或描述的步骤。

[0062] 根据本发明实施例，还提供了一种用于实施上述多账户高速交易方法的转子，如图2、图3所示，该装置包括：

[0063] 事务接收单元10，用于接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；

[0064] 高频热点账户为单位时间内可能产生多次交易的账户；也就导致在短时间内会出现多次加扣余额的情况。如此，当多个高频热点账户在同一个交易中时，每个账户均有可能
加扣余额，只能使用队列逐个进行账户余额的加扣，但是这必然造成整个交易事务处理响
应时间很长，交易速率得不到保证。为了解决这个问题，本实施例中，先将同一个交易中的
所有高频热点账户定义为一个高频交易事务，其中每个事务项对应一个账户交易事务，为
后续的并行处理该高频交易事务中的所有事务项提供了保障。

[0065] 本实施例中，采用高速交易执行模块接收多个高频热点账户在进行同一个交易时所定义的高频交易事务。

[0066] 记录获取单元20，用于获取所述高频交易事务中每个事务项所涉及的账户余额记录；

[0067] 加扣余额时，根据交易双方或多方应当支出的金额可以推算出每个账户应当加扣的余额；但是并不知道账户上本身有多少余额，不利于后续对账户查询的实时响应。为此，
需要先从高频交易事务中每个事务项中提取出对应的账户余额记录，保证后续的余额加扣
的顺利进行。

[0068] 本实施例中，在高速交易执行模块中同时进行每个事务项所涉及的账户余额记录的获取。

[0069] 一致性规整单元30，用于对所述每个事务项执行一致性规整操作；

[0070] 通过一致性规整操作，能够使得高频交易事务内所有事务项执行时全局一致性规整，为后续的加扣的并行处理提供保障。

[0071] 本实施例中，在高速交易执行模块中对所述每个事务项执行一致性规整操作。

[0072] 优选的，对所述每个事务项执行一致性规整操作包括：

[0073] 通过hash算法提取事务项的核心特征值的特征标志，基于特征标志对事务项进行顺序化处理。

[0074] 把每个事务项的加扣性质，交易性质，涉及余额账户的全局唯一标志，账户性质等核心特征值通过hash算法提取特征标志，基于特征标志，对事务项进行顺序化处理，从而达
到事务内所有事务项执行时的全局一致性规整的目的。

[0075] 加扣记录单元40，用于对一致性规整的事务项所对应的账户余额进行加扣后记录流水，并据其更新账户余额记录。

[0076] 可以是对一致性规整后的事务项直接进行账户余额加扣，具体地，在高速交易执行模块中采用并行处理的方式给每个事务项所对应的每个账户余额进行加扣，并且计记录
余额加扣和流水记录。加扣时，每个账户余额分别同时进行，得到的余额加扣和流水记录与
先前获取的账户余额记录相对应，为后续存储提供关联基础。

[0077] 采用高速交易执行模块实现了账户扣余额和记录的并行处理，替代了逐个账户进行处理，大大降低了交易事务处理响应时间，也就有效提升了交易速率。

[0078] 从以上的描述中，可以看出，本发明实现了如下技术效果：

[0079] 在本申请实施例中，采用多账户高速交易的方式，通过接收多个高频热点账户在进行同一个交易时所定义的高频交易事务；获取所述高频交易事务中每个事务项所涉及的
账户余额记录；对所述每个事务项执行一致性规整操作；对一致性规整的事务项所对应的
账户余额进行加扣，并记录余额加扣和流水记录；达到了大大缩减交易事务处理响应时间
的目的，从而实现了有效提升交易速率的技术效果，进而解决了由于交易事务处理响应时
间长造成的交易速率无法得到保证的技术问题。

[0080] 根据本发明实施例，优选的，对所述每个事务项执行一致性规整操作之后还包括：

[0081] 判断一致性规整后的事务项的并行反馈值是否满足预设并行事务率；

[0082] 如果满足，则对满足预设并行事务率的事务项所对应的账户余额进行余额加扣，并记录余额加扣和流水记录；

[0083] 如果不满足，则记录余额加扣和流水记录，并根据所述余额加扣记录和流水记录对不满足预设并行事务率的事务项所对应的账户余额进行批量余额同步加扣。

[0084] 判断致性规整后的事务项的并行反馈值是否低于或等于预设并行事务率，如果满足，表明这些事务项符合高速交易执行模块的并行处理条件，则直接在高速交易执行模块
上，对满足预设并行事务率的事务项所对应的账户余额进行余额加扣，并记录余额加扣和
流水记录。如果超出预设并行事务率，表明这些事务项不符合高速交易执行模块的并行处
理条件，则记录余额加扣和流水记录，并通过高速余额同步处理定时器，根据所述余额加扣
记录和流水记录对不满足预设并行事务率的事务项所对应的账户余额进行批量余额同步
加扣。

[0085] 本实施例中，每个定时器装置基于定时周期（根据需求和实际条件周期可以为毫秒级周期，也可以是秒级周期等）进行高速运转，对超出并行事务率的账户的余额，基于账
户余额记录和自身的加扣记录进行批量余额同步。

[0086] 实现了周期内能进行的事务率不受数据库事务控制影响，通过判断分别并行处理符合和不符合事务率的项目，有效加快了处理速度。

[0087] 优选的，所述并行反馈值的获取包括：先记录每个高频热点账户的并行特征值，然后基于并行特征值实时生成并行反馈值，最后将并行反馈值存储于高速存储装置中。采用
并行事务控制反馈模块进行监控，能够基于监测到的并行特征值生成并行反馈值，从而保
证判断流程的正常进行。

[0088] 根据本发明实施例，优选的，记录余额加扣和流水记录之后还包括：

[0089] 将账户余额记录、余额加扣和流水记录存到关系型数据库中。

[0090] 接收用户对待查询账户的余额查询请求；

[0091] 响应于余额查询请求，根据账户余额记录和账户加扣记录计算所述待查询账户的账户余额，并返回给用户。

[0092] 由于采用了以上的高速交易执行模块、并行事务控制反馈模块和定时器的配合，实现了事务处理提速，基于此，也能够根据处理得到的账户余额记录、余额加扣和流水记录
快速存到关系型数据库中，当有实时获取高频热点账户余额的查询请求时，高频热点账户
余额查询模块就可以快速做出响应，从而有效保证了查询余额的实时性和准确性。

[0093] 显然，本领域的技术人员应该明白，上述的本发明的各模块或各步骤可以用通用的计算装置来实现，它们可以集中在单个的计算装置上，或者分布在多个计算装置所组成
的网络上，可选地，它们可以用计算装置可执行的程序代码来实现，从而，可以将它们存储
在存储装置中由计算装置来执行，或者将它们分别制作成各个集成电路模块，或者将它们
中的多个模块或步骤制作成单个集成电路模块来实现。这样，本发明不限制于任何特定的
硬件和软件结合。

[0094] 以上所述仅为本申请的优选实施例而已，并不用于限制本申请，对于本领域的技术人员来说，本申请可以有各种更改和变化。凡在本申请的精神和原则之内，所作的任何修
改、等同替换、改进等，均应包含在本申请的保护范围之内。