一种额度管理方法及装置

本发明涉及计算技术领域，特别地涉及一种额度管理方法及装置。

随着信息技术的发展，数据成为人们生活工作必不可少的元素，而在人们工作、生 活中产生的数据量也是巨大的，并且数据量增长速度也越来越高。由于数据与人们生产生 活的关系越来越密切，数据交易活动也越来越多，而数据交易活动常常会使用数据交易系 统才能够进行。

分布式高并发数据交易系统是数据交易系统的一种，具有内聚性、透明性、高并发 性等特点。在分布式高并发数据交易系统中，数据需求方付费查询数据提供方的数据资源， 数据需求方的账户通过充值、授信等方式获取一定额度以便进行数据购买操作，数据需求 方的额度管理是数据交易环节中的重要一环。为了数据交易的顺利进行，需要提供一种高 效、灵敏的额度管理机制，以提高分布式高并发数据交易系统的整体数据配送效率。分布式 高并发数据交易系统的数据配送子系统本身是复杂的，是一个分布式高并发高吞吐的系 统。通过现有技术的额度管理方法在这样一个庞大的系统中进行额度管理，存在额度管理 过程过于复杂，计算量过大等问题，因而难以实现高效、灵敏的额度管理。

有鉴于此，本发明提供一种额度控制方法及装置，有助于比较合理地处理数据交 易系统的额度管理的问题，从而有助于保证数据交易的顺利高效地进行。本发明的其他目 的和有益效果将结合具体实施方式加以说明或体现。

为实现上述目的，根据本发明的一个方面，提供了一种额度管理方法。

本发明实施例的额度管理方法，包括：接收用户发送的交易操作的请求；从用户的 账户对应的节点树中，选择满足交易范围条件的目标节点；若所述目标节点的额度能够满 足所述交易操作，执行所述交易操作；若所述目标节点的额度不能够满足所述交易操作，则 向额度控制中心申请相应的额度，申请成功后将申请到的额度增加到目标节点的总额度 中，然后执行所述交易操作。

可选的，所述从用户的账户对应的节点树中，选择满足交易范围条件的目标节点 的步骤包括：在节点树的叶子节点中查满足交易范围条件的节点，若到，则选择为目标 节点；若未到，则进入以下步骤；在子节点中查满足交易范围条件的非叶子节点，若 到，则选择为目标节点；若未到，则进入以下步骤；判断根节点是否满足交易范围条件，若 是，则选择根节点为目标节点。

可选的，所述执行所述交易操作的步骤之后，还包括：在所述目标节点的总额度中 减除为执行所述交易操作所消耗的额度，得到剩余额度；将剩余额度记录到所述目标节点 的配送日志中；在到达设定时间后，根据所述配送日志计算所述账户的结算额度；根据所述 结算额度更新所述账户的额度；将所述账户的更新后的额度发送到所述额度控制中心。

可选的，所述向额度控制中心申请相应的额度的步骤包括：发送额度申请信息到 额度控制中心，从与节点树对应的额度池中申请相应的额度；锁定所述额度池，使得所述额 度控制中心接收到所述用户的其它额度申请信息之后，拒绝响应所述其它额度申请信息； 接收额度申请成功的信息；解除锁定所述额度池，使得所述额度控制中心接收到所述其它 额度申请信息之后，能够响应所述其它额度申请信息。

本发明实施例的另一方面，提供了一种额度管理装置。

本发明实施例的额度管理装置包括：请求接收模块：用于接收用户发送的交易操 作的请求；目标节点选择模块：用于从用户的账户对应的节点树中，选择满足交易范围条件 的目标节点；第一执行模块：用于若所述目标节点的额度能够满足所述交易操作，执行所述 交易操作；第二执行模块：用于若所述目标节点的额度不能够满足所述交易操作，则向额度 控制中心申请相应的额度，申请成功后将申请到的额度增加到目标节点的总额度中，然后 执行所述交易操作。

可选的，所述目标节点选择模块包括：叶子节点查单元：用于在节点树的叶子节 点中查满足交易范围条件的节点，若到，则选择为目标节点；若未到，则进入以下步 骤；非叶子节点查单元：用于在子节点中查满足交易范围条件的非叶子节点，若到， 则选择为目标节点；若未到，则进入以下步骤；根节点查单元：用于判断根节点是否满 足交易范围条件，若是，则选择根节点为目标节点。

可选的，所述装置还包括：剩余额度计算模块：用于在所述目标节点的总额度中减 除为执行所述交易操作所消耗的额度，得到剩余额度；剩余额度记录模块：用于将剩余额度 记录到所述目标节点的配送日志中；结算额度计算模块：用于在到达设定时间后，根据所述 配送日志计算所述账户的结算额度；余额更新模块：用于根据所述结算额度更新所述账户 的额度；余额发送模块：用于将所述账户的更新后的额度发送到所述额度控制中心。

可选的，第二执行模块包括：额度申请信息发送单元：用于发送额度申请信息到额 度控制中心，从与节点树对应的额度池中申请相应的额度；锁定单元：用于锁定所述额度 池，使得所述额度控制中心接收到所述用户的其它额度申请信息之后，拒绝响应所述其它 额度申请信息；反馈信息接收单元：接收额度申请成功的信息；解锁单元：解除锁定所述额 度池，使得所述额度控制中心接收到所述其它额度申请信息之后，能够响应所述其它额度 申请信息。

根据本发明的又一方面，提供了一种电子设备，包括：一个或多个处理器；存储装 置，用于存储一个或多个程序，当所述一个或多个程序被所述一个或多个处理器执行，使得 所述一个或多个处理器实现如本发明任意实施例所述的方法。

根据本发明的又一方面，提供了一种计算机可读介质，其上存储有计算机程序，所 述程序被处理器执行时实现如本发明任意实施例所述的方法。

根据本发明的技术方案，当用户希望执行数据的交易操作时，可通过数据需求方 前置机发送交易操作的请求，在接收到该用户发送的交易操作的请求之后，首先从符合本 次交易范围条件的节点中选择目标节点，当目标节点具有额度时，直接执行交易操作，并扣 除对应的目标节点的额度；当目标节点不具有额度时，申请额度，然后执行交易操作，并在 完成交易操作后扣除对应的目标节点的额度。当具有多个交易操作的请求时，这些不同的 交易操作可在多个节点上分别执行，节点之间的额度申请、花费可以独立进行，从而在高并 发数据交易系统中，能够减少额度管理的复杂度，避免对同一个额度数据进行大量重复读 写操作的情况，减少重复计算，降低系统额外开销。同时，还能够避免同一时间多个进程竞 争同一个额度数据的情况，当海量用户短时间内对某些数据请求数据交易时，频繁访问和 更新的情况减少，降低系统负载，缩短响应时间，提高数据交易的执行速度和效率。高并发 状态下，当前一个进程的写数据库操作未完成时后续进程发生读取数据库操作，后续进程 读取的状态与前面进程读取的状态相同就会发生实际额度不够也能进行交易，即真实花费 会超过额度。本发明实施例减少一个节点上高并发的情况，同时在申请额度成功之后才进 行交易操作，避免真实花费超过额度的问题，又由于节点树上的节点均可在对应的交易范 围内负担交易操作花费的额度，因此减少同一节点上的高并发情况并没有影响数据交易系 统的响应速度。

附图用于更好地理解本发明，不构成对本发明的不当限定。其中：

图1是根据本发明实施方式的额度管理方法的主要步骤的示意图；

图2是根据本发明实施方式的涉及的处理组件示意图；

图3是根据本发明实施方式的一种节点树结构示意图；

图4是根据本发明实施方式的节点树与额度控制中心信息发送示意图；

图5是根据本发明实施方式的一种额度管理装置的主要模块示意图。

以下结合附图对本发明的示范性实施例做出说明，其中包括本发明实施例的各种 细节以助于理解，应当将它们认为仅仅是示范性的。因此，本领域普通技术人员应当认识 到，可以对这里描述的实施例做出各种改变和修改，而不会背离本发明的范围和精神。同 样，为了清楚和简明，以下的描述中省略了对公知功能和结构的描述。

在本发明实施方式中，采用分层控制的方式，对账户的额度进行准确地控制，同时 不增加整个系统的复杂度。以下结合附图进行详细说明。图1是根据本发明实施方式的额度 管理方法的主要步骤的示意图。

步骤101：接收用户发送的交易操作的请求。

上述用户为数据需求方，通过数据交易系统发送数据的交易操作请求，请求通过 账户的额度获取某些特定的数据。例如，数据需求方需要广告数据，生成关于广告数据的交 易操作的请求。

步骤102：从用户的账户对应的节点树中，选择满足交易范围条件的目标节点。

对于同一用户而言，可能存在一个主账户和多个子账户，将这些所有的主账户和 子账户中，可进行数据交易的账户，划分为节点，生成与用户对应的一个节点树。在初始情 况下，用户首先申请主账户，然后根据交易范围申请子账户。按照可进行交易范围申请账 户，包括主账户和子账户，每一账户为一个节点。业务账户可继续按缩小产品范围，生成子 业务账户，即子节点，这样就形成了一个以交易范围划分的节点树。每个用户一般对应一颗 节点树。在本发明具体实施例中，一个用户一般情况下会具有一个主账户，因此，一个用户 对应一个节点树，主账户对应节点树的根节点，子账户对应节点树的孩子节点。在用户对应 的节点树中，每个节点对应一定的交易范围，可以在该节点对应的交易范围内进行数据交 易，例如，某一节点能够与某个或某些特定的数据提供方进行数据交易等。而用上述交易操 作的请求，与某一个特定的交易范围对应，例如，需要某一特定的数据提供方提供的数据， 在相应交易操作的请求之前，需要查与本次交易操作的请求的交易范围对应的节点。一 个节点树中，可能存在至少一个满足交易范围条件的节点，从这些满足交易范围条件的节 点中，选择一个作为目标节点，该目标节点为本次交易操作提供需要的额度。

上述目标节点可以是孩子节点或根节点。

当节点树中不存在满足交易范围条件的节点时，返回交易失败的相关信息，然后 可提示用户注册新的子账户，为用户生成新的子账户，然后相应地在节点树中建立能够满 足交易范围条件的新的孩子节点。

步骤103：若所述目标节点的额度能够满足所述交易操作，执行所述交易操作。

用户通过对账户进行充值操作、接受另一账户赠送操作、授信操作等，获得一定的 额度，若选择的目标节点的额度能够满足本次交易操作的请求，则直接执行交易操作，执行 交易操作所消耗的额度，从目标节点的额度中扣除。

步骤104：若所述目标节点的额度不能够满足所述交易操作，则通过额度控制中心 申请相应的额度，申请成功后将申请到的额度增加到目标节点的总额度中，然后执行所述 交易操作。

选择目标节点之后，交易操作所需要的额度直接从目标节点的额度中扣除，实用 完成之后再针对该目标节点进行新的额度的申请，从而用户的主账户和子账户额度互不影 响，让额度控制更为简单。

节点树的节点所申请的额度，只有在该节点作为某个交易操作的请求的目标节点 时才能够使用，用完以后再予以申请，从而能够避免账户实际花费超过账户的额度的情况。

上述通过额度控制中心申请相应的额度的步骤中，申请的额度与交易操作相适 应，可通过预估等方式确定。

上述执行交易操作的步骤，具体包括执行交易操作所必须的所有步骤，比如，发送 与执行交易操作对应的数据请求到数据提供方，接收数据提供方提供的数据反馈信息，将 数据反馈信息发送给设定的接收模块等。

本发明实施例中，目标节点在进行交易时，若额度不够，那么该节点向额度控制中 心申请额度，一般根据交易操作的业务量和价格进行预估额度进行申请。当用户账户发生 多个交易操作时，这些交易操作分别在各自对应的目标节点上获取交易所需要的额度，并 且由于目标节点可不通过根节点向额度中心申请额度，因此当多个交易操作的请求同时发 出时，相互之间不会出现竞争同一个额度数据的情况，避免出现随着响应时间的正常而导 致越来越多的其它交易操作的请求也不能够及时得到响应的问题，有效地避免了系统的拥 堵。在高并发的数据交易系统中，本发明实施例根据交易操作的请求所对应的范围选择目 标节点执行交易操作，减少海量用户短时间内对某些数据进行频繁访问和更新的情况，缩 短响应时间，提高响应速度，避免反应慢时用户多次发生同一交易操作的请求而产生雪崩 效应进一步导致数据交易系统瘫痪。

在本发明一些实施例中，所述从用户的账户对应的节点树中，选择满足交易范围 条件的目标节点的步骤包括：

在节点树的叶子节点中查满足交易范围条件的节点，若到，则选择为目标节 点；若未到，则进入以下步骤；

在子节点中查满足交易范围条件的非叶子节点，若到，则选择为目标节点；若 未到，则进入以下步骤；

判断根节点是否满足交易范围条件，若是，则选择根节点为目标节点。

上述交易范围，与交易操作的请求相对应，可记载于交易操作的请求之中。本发明 实施例中，根据交易范围最小匹配原则选择交易节点，也就是叶子节点具有交易优先权。从 而尽量将所有交易操作都分配到各个不同的节点上，避免交易范围大的节点承担过多的交 易操作任务，进一步避免拥堵，提高处理效率。

在本发明一些实施例中，所述执行所述交易操作的步骤之后，还包括：

在所述目标节点的总额度中减除为执行所述交易操作所消耗的额度，得到剩余额 度；

将剩余额度记录到所述目标节点的配送日志中；

在到达设定时间后，根据所述配送日志计算所述账户的结算额度；

根据所述结算额度更新所述账户的额度；

将所述账户的更新后的额度发送到所述额度控制中心。

在本发明实施例中，每个节点在进行交易操作之前，可通过现金充值、平台赠送、 平台授信等方式获取一定额度，用于交易操作，在执行交易操作后，会逐渐消耗额度。所有 节点分别计算为执行相应的交易操作所消耗的额度，然后将各个节点计算的额度发送进行 到额度控制中心进行汇总，额度统计和真实账户结算是分开进行的，账户结算根据真实的 配送量生成配送日志，在配送日志中记载数据需求方的账户的交易操作请求的次数，然后 根据配送日志计算账户的结算额度，将用户所有账户的花费进行汇总得出用户所有子账 户、主账户的总花销，在额度控制中心中，该用户的剩余额度为初始额度减去总花销。这种 方法计算总额度，可避免重复计算，保证额度计算的正确性。

在本发明一些实施例中，所述通过额度控制中心申请相应的额度的步骤包括：

发送额度申请信息到额度控制中心，从与节点树对应的额度池中申请相应的额 度；

锁定所述额度池，使得所述额度控制中心接收到所述用户的其它额度申请信息之 后，拒绝响应所述其它额度申请信息；

接收额度申请成功的信息；

解除锁定所述额度池，使得所述额度控制中心接收到所述其它额度申请信息之 后，能够响应所述其它额度申请信息。

现有技术中，在高并发场景下，多个进程发出的多个请求同时通过负载均衡分配 至内网多台服务器，在某个请求成功写入数据库之前，其他请求的查询结果可能还是写入 之前的状态，这就会造成系统误判。

本发明实施例中，在执行交易操作时，扣除目标节点的额度，本发明实施例引入锁 定机制，同一用户的账户共享额度池，即同一节点树的节点共享额度池。一次只处理一个额 度申请信息，在处理一条额度申请信息时，排出其它额度申请信息，多个子账户同时申请额 度时由于引入锁定机制不会发生多进程同时竞争同一个额度数据的情况。

本发明涉及的处理组件主要包括DMP(Data Management Platform，数据管理平 台)、DLS(Data Linkage Service，数据交易中心向会员提供数据交易服务的门户)、DMIX (数据配送系统)、DAS(Data Analysis System，数据分析系统)、Redis集、CAP产品(China Audience Profile，中国观众画像库)、CRP产品(Credit Risk Profile，信用风险画像库)、 额度控制中心。

DMP：指交易过程中用于数据流通的供方或需方业务系统；在本系统中，需方DMP发 出查询请求，经过DMIX路由到数据提供方的DMP，供方DMP在接收到请求后返回查询结果。

DLS：通过数据交易中心向会员提供数据交易服务的门户，数据提供方和数据需求 方会员可实现数据交易的商品挂牌、需求发布、数据订购、交易管理、信息查询、清结算等交 易操作，可执行结算和额度文件推送的操作。

DMIX：主要用于接收数据需求方DMP的查询请求，对数据提供方DMP进行路由，具有 实时额度计算、控制，生产配送日志等功能。

DAS：专注于操作DMIX产生的配送日志，对其进行分析，汇总出配送量供DLS进行清 算、结算。

Redis集：引入的第三内存数据库集，在节点树中，每个节点对应一个Redis缓 存，多个节点的Redis缓存形成Redis集。Redis是一个键值存储系统，支持某些结构的数 据的存储，例如Value(值)结构。Redis集提供便捷、快速的数据缓存服务，在系统中用以 实现进程通信，缓存数据。在处理交易操作的请求时，目标节点首先在自己的Redis缓存中 查询额度，如果额度不足，则向额度控制中心请求额度。

CAP产品：是面向市场营销行业的标准化数据产品。其主要的用户体为广告主、 4A广告代理公司、DSP数据投放企业等，为其提供广告投放前的用户画像、投放中的数据补 全和投放后的数据校验等多种服务。

CRP产品：产品可以为金融机构提供个人及企业的信用风险数据探查服务，帮助金 融机构完成风险控制。

额度控制中心：额度控制中心是所有用户账户及其子账户的额度管理和控制中 心。额度控制中心提供的服务包括：负责受理账户额度申请，通过计算重新分配和调度节点 额度；额度调配，计算用户的真实花费用于费用清算，得出账户剩余额度；处理其他额度调 整额相关业务等。

图2是根据本发明实施例提供的额度管理方法涉及的处理组件示意图，包括Reids 缓存201、目标节点202、额度控制中心203、DLS204、DAS205、DMIX206、数据提供方前置机 207。

在接收到用户的交易操作的请求后，匹配交易节点，选择选择满足本次请求的交 易范围条件的目标节点202。在确定目标节点202之后，目标节点在自己的Redis缓存201中 查询额度，如果额度不足，则向额度控制中心203请求额度。目标节点202成功获取额度后， 执行交易操作，向数据提供方前置机207发起与交易操作的请求对应的数据请求。期间由 DMIX206负责两者数据配送。完成数据配送的同时，目标节点扣减相应的额度，记录在其 Redis缓存201中。然后，关于本次交易操作的记录会记载在配送日志中，由节点发送到 DAS205。DAS205实时分析统计账户配送量，并统计出所有账户的配送信息的xml文件，在每 日固定时间(如凌晨5点)推送给DLS204。

在本发明一些实施例中，节点树可采用如图3所示的结构。包括一个根节点301、至 少一个非叶子孩子节点302、至少一个叶子节点303。一般情况下，根节点301对应用户的主 账户，交易范围最大。其余节点对应用户的子账户随着层数的增加，节点对应的子账户的交 易范围缩小。

图4为本发明一种实施例中节点树与额度控制中心信息传递关系示意图。多个用 户的节点树401通过负载均衡402向额度控制中心集403发送额度申请信息，每个节点树 401在额度控制中心集403中都设置有对应的额度控制中心4031，同一个节点树401上的 任意节点都能通过负载均衡402向对应的额度控制中心4031发送额度申请信息，并通过负 载均衡402接收额度申请通过或者不通过的信息。

同时，本发明还提供一种额度管理装置，组成模块图如图5所示，本实施例的额度 管理装置500包括：请求接收模块、目标节点选择模块、第一执行模块、第二执行模块。

请求接收模块：用于接收用户发送的交易操作的请求；

目标节点选择模块：用于从用户的账户对应的节点树中，选择满足交易范围条件 的目标节点；

第一执行模块：用于若所述目标节点的额度能够满足所述交易操作的请求，执行 所述交易操作；

第二执行模块：用于若所述目标节点的额度不能够满足所述交易操作，则向额度 控制中心申请相应的额度，申请成功后将申请到的额度增加到目标节点的总额度中，然后 执行所述交易操作。

在本发明一些实施例中，所述目标节点选择模块包括：

叶子节点查单元：用于在节点树的叶子节点中查满足交易范围条件的节点， 若到，则选择为目标节点；若未到，则进入以下步骤；

非叶子节点查单元：用于在子节点中查满足交易范围条件的非叶子节点，若 到，则选择为目标节点；若未到，则进入以下步骤；

根节点查单元：用于判断根节点是否满足交易范围条件，若是，则选择根节点为 目标节点。

在本发明一些实施例中，所述装置还包括：

剩余额度计算模块：用于在所述目标节点的总额度中减除为执行所述交易操作所 消耗的额度，得到剩余额度；

剩余额度记录模块：用于将剩余额度记录到所述目标节点的配送日志中；

结算额度计算模块：用于在到达设定时间后，根据所述配送日志计算所述账户的 结算额度；

余额更新模块：用于根据所述结算额度更新所述账户的额度；

余额发送模块：用于将所述账户的更新后的额度发送到所述额度控制中心。

在本发明一些实施例中，所述第二执行模块包括：

额度申请信息发送单元：用于发送额度申请信息到额度控制中心，从与节点树对 应的额度池中申请相应的额度；

锁定单元：用于锁定所述额度池，使得所述额度控制中心接收到所述用户的其它 额度申请信息之后，拒绝响应所述其它额度申请信息；

反馈信息接收单元：接收额度申请成功的信息；

解锁单元：解除锁定所述额度池，使得所述额度控制中心接收到所述其它额度申 请信息之后，能够响应所述其它额度申请信息。

DLS根据配送单及产品价格生成结算单，并根据结算单更新账户额度账户和资金 账户，最后把最新的额度推给额度控制中心，这样额度控制中心也有了每个账户最新的额 度。系统以此形成闭环，并循环下去。

作为另一方面，本发明实施方式提供一种电子设备，该电子设备包含一个或多个 处理器；以及存储装置，用于存储一个或多个程序，当上述一个或多个程序被上述一个或多 个处理器执行，使得上述一个或多个处理器实现本发明实施例所述的方法，例如按照图1所 执行的方法。作为再一方面，本发明实施方式还提供了一种计算机可读介质，该计算机可读 介质可以是上述实施例中描述的设备中所包含的；也可以是单独存在，而未装配入该设备 中。上述计算机可读介质承载有一个或者多个程序，当上述一个或者多个程序被一个该设 备执行时，使得该设备能够执行本发明实施例所述的方法，例如按照图1所执行的方法。

上述具体实施方式，并不构成对本发明保护范围的限制。本领域技术人员应该明 白的是，取决于设计要求和其他因素，可以发生各种各样的修改、组合、子组合和替代。任何 在本发明的精神和原则之内所作的修改、等同替换和改进等，均应包含在本发明保护范围 之内。