用于金融领域的负载均衡与缓存中心系统及风控系统

摘要

本发明公开了一种用于金融领域的负载均衡与缓存中心系统及风控系统，通过负载均衡实现金融风控系统中的业务并发处理，通过数据缓存中心保证金融风控系统中的风控业务请求的数据正确性与完整性。其技术方案为：负载均衡系统用于通过动态维护金融风控系统的低时效服务组模块中的每个服务单元的状态，实现风控业务请求的均匀分发；缓存中心系统用于通过实现用户会话粒度的分业务数据缓存，保证业务请求数据的正确性与完整性。

说明书

技术领域

本发明涉及金融领域的风控系统实现，具体一种用于金融领域的负载均衡与缓存中心系统、以及应用该负载均衡与缓存中心系统的金融风控系统。

背景技术

金融风控系统支持众多逻辑复杂的业务功能，系统需要处理单个或多个业务人员发起的各类复杂业务请求，且部分业务的计算量极大。风控业务团队会使用同一套风控系统来处理业务请求。当多任务同时发起时，容易出现明显的卡顿或等待现象，并发性的业务处理需求急需实现。如何对多服务并发处理进行设计以及实现计算任务在多服务之间的负载均衡，是业界亟待解决的问题之一。

风控系统的主体功能可以按照时效性分为两类：一类是高时效业务，此类业务处理时延低，程序能够在极短时间内完成计算；另一类是低时效业务，这类业务的计算复杂度高，单个业务请求需要消耗较长的处理时间。由于低失效业务的存在，会造成风控计算任务阻塞时间过长。

此外，单次业务操作可能涉及多个业务对象，受限于通讯协议，业务人员需要分批向服务端提交数据；另一方面，风控的部分业务需要支持业务人员使用自定义的参数模板进行计算，即单个业务请求需要与其对应的参数信息实现严格绑定。因此，如何保证风控业务请求的数据正确性与完整性也是业界亟待解决的问题之一。

发明内容

以下给出一个或多个方面的简要概述以提供对这些方面的基本理解。此概述不是所有构想到的方面的详尽综览，并且既非旨在指认出所有方面的关键性或决定性要素亦非试图界定任何或所有方面的范围。其唯一的目的是要以简化形式给出一个或多个方面的一些概念以为稍后给出的更加详细的描述之序。

本发明的目的在于解决上述问题，提供了一种用于金融领域的负载均衡与缓存中心系统及风控系统，通过负载均衡实现金融风控系统中的业务并发处理，通过数据缓存中心保证金融风控系统中的风控业务请求的数据正确性与完整性。

本发明的技术方案为：本发明揭示了一种用于金融领域的负载均衡与缓存中心系统，系统包括负载均衡系统、缓存中心系统，其中：

负载均衡系统，用于通过动态维护金融风控系统的低时效服务组模块中的每个服务单元的状态，并实现风控业务请求的均匀分发；

缓存中心系统，用于通过实现用户会话粒度的分业务数据缓存，保证业务请求数据的正确性与完整性。

根据本发明的用于金融领域的负载均衡与缓存中心系统的一实施例，负载均衡系统包括服务实时状态维护单元和服务挑选单元，其中：

服务实时状态维护单元，用于初始化并动态维护低时效服务组模块中每一个服务单元的实时状态；

服务挑选单元，用于从低时效服务组模块中挑选一个状态为空闲的服务单元。

根据本发明的用于金融领域的负载均衡与缓存中心系统的一实施例，服务实时状态维护单元进一步配置为当负载均衡系统收到一笔低时效业务请求时，其中一个状态为空闲的服务单元会被选中负责该笔低时效业务请求的业务处理，同时该服务单元会被置为繁忙状态；且通过服务单元和负载均衡系统之间的服务状态报告，实现服务单元状态的重置机制。

根据本发明的用于金融领域的负载均衡与缓存中心系统的一实施例，服务挑选单元基于顺序查找算法选取空闲单元：顺序遍历所有的服务单元，当找到第一个空闲的服务单元时停止查找，并指定该服务单元负责处理本次低时效业务请求，若不存在任何一个空闲的服务单元，则返回错误，在完成挑选之后，再由服务实时状态维护单元更新该服务单元的状态。

根据本发明的用于金融领域的负载均衡与缓存中心系统的一实施例，缓存中心系统包括多个会话单元，实现不同会话的隔离以防止后台数据错乱，每一会话单元中缓存多个业务参数数据和请求数据，以同时处理来自同一业务操作端的不同请求。

根据本发明的用于金融领域的负载均衡与缓存中心系统的一实施例，缓存中心系统进一步配置为：当收到一笔低时效业务请求时，缓存中心系统开始缓存该笔低时效业务请求相关的包括业务参数数据和请求数据在内的业务数据，当缓存中心系统收到一结束标志后获知该笔完整的业务数据缓存完成，在完成数据打包并发送给金融风控系统中空闲的服务单元后，缓存中心系统清空该笔缓存的业务数据，若当前金融风控系统中不存在空闲的服务单元，则该笔缓存数据同样也会被清空。

根据本发明的用于金融领域的负载均衡与缓存中心系统的一实施例，缓存中心系统还配置异常处理机制，当系统出现异常时自动清除缓存中的异常数据。

本发明还揭示了一种金融风控系统，包括核心服务模块、低时效服务组模块、数据排队机模块、风控前置模块、以及外部的风控业务操作端模块，其中：

核心服务模块，用于处理风控业务中的高时效业务；

低时效服务组模块，用于处理风控业务中的低时效业务；

数据排队机模块，用于连接金融风控系统服务端的所有数据源并将所有数据汇总定序，将定序后的结果发布至核心服务模块；

风控前置模块，用于收集风控业务操作端模块的业务请求，并将该业务请求数据发送至数据排队机模块，另一方面将核心服务模块与低时效服务组模块的处理结果发送给风控业务操作端模块；

风控业务操作端模块，是风控业务人员实现风控各类业务请求的发起方，同时负责接收风控前置模块发送的应答数据与推送数据并将进行展示；

其中，核心服务模块包括高时效业务处理单元、如权利要求1至7中任一项所述的负载均衡与缓存中心系统，高时效业务处理单元用于处理风控业务操作端模块发起的高时效业务请求并将处理结果发布至风控前置模块，另一方面自动根据后台数据变化，执行包括资金预警检查、异常交易判定的逻辑，并将产生的数据推送给风控前置模块；

其中，低时效服务组模块包括多个服务单元来并发处理多个风控业务请求。

根据本发明的金融风控系统的一实施例，低时效服务组模块的每一服务单元包括：

压力试算单元，配置为由业务人员灵活调整保证金率、价格类型在内的试算参数，从而对投资者进行试算；

会员预结算单元，配置为基于预估结算价，提前对会员进行结算；

停板试算单元，配置为模拟当交易所出现连续停板的极端行情下，评估投资者的抗风险能力；

权益反向试算单元，配置为评估投资者抗风险能力，验证投资者当前可用资金可以承受的行情波动幅度。

本发明对比现有技术有如下的有益效果：本发明的系统在风控业务分类的基础上，针对低时效业务设计并实现一套可灵活横向扩展的服务端架构。通过多服务单元间的负载均衡机制和数据缓存中心，在保证风控业务请求的数据正确性和完整性的前提下，实现风控多任务的并发处理，从而满足了业务人员并发执行风控业务的需求。

附图说明

在结合以下附图阅读本公开的实施例的详细描述之后，能够更好地理解本发明的上述特征和优点。在附图中，各组件不一定是按比例绘制，并且具有类似的相关特性或特征的组件可能具有相同或相近的附图标记。

图1示出了本发明的金融风控系统的一实施例的架构示意图。

图2示出了本发明的用于金融领域的负载均衡与缓存中心系统的一实施例的原理图。

具体实施方式

以下结合附图和具体实施例对本发明作详细描述。注意，以下结合附图和具体实施例描述的诸方面仅是示例性的，而不应被理解为对本发明的保护范围进行任何限制。

图1示出了本发明的金融风控系统的一实施例的架构。如图1所示，本实施例的金融风控系统包括：核心服务模块、低时效服务组模块、数据排队机模块、风控前置模块、以及外部的风控业务操作端模块。

核心服务模块与低时效服务组模块建立单向数据传输，所传输的数据包括：各类低时效业务的请求数据以及与请求数据绑定的参数信息。

风控业务操作端模块与风控前置模块建立双向数据传输，从操作端到前置方向所传输的数据包括：业务请求数据与参数信息；从前置到操作端方向所传输的数据包括各类业务应答数据与后台主动推送的业务数据。

风控前置模块与数据排队机模块、数据排队机模块与核心服务模块分别建立单向数据传输。其中，前者传输的数据为风控前置模块从风控业务操作端模块收集到的数据；后者再将该数据以及从其它模块(图中未列出)汇总到数据排队机模块的数据，统一发送给核心服务模块。

核心服务模块以及低时效服务组模块中的每个服务单元，分别与风控前置模块建立单向数据传输。核心服务模块向风控前置模块发送请求应答数据与推送类数据。低时效服务组模块只向风控前置模块发送业务应答数据。

核心服务模块所处理的核心业务是风控业务中计算任务较小的高时效业务，包括预警、通知提醒、强平处理、撤单处理、行权推荐等。

低时效服务组模块所处理的低时效业务是指风控业务中计算资源消耗较大的业务，包括压力试算、预结算、停板试算等。

数据排队机模块连接金融风控系统服务端的所有数据源(包括风控前置模块与其它模块)，将所有数据汇总并定序，并将定序后的结果发布至核心服务模块。

风控前置模块实现的功能为：一方面，收集风控业务操作端模块的业务请求，并将该业务请求数据发送至数据排队机模块；另一方面，将核心服务模块与低时效服务组模块的处理结果(包括应答数据与推送数据)发送给风控业务操作端模块。

风控业务操作端模块是风控业务人员日常使用的终端，风控各类业务请求的发起方。同时，也负责接收风控前置模块发送的应答数据与推送数据，并将数据进行展示。此外，风控业务操作端模块还具备管理风控系统参数的功能。

进一步的，核心服务模块包括高时效业务处理单元、负载均衡与缓存中心系统。

高时效业务处理单元的功能为：一方面，处理风控业务操作端模块发起的高时效业务请求(包括强平处理、撤单处理、行权推荐等)，并将处理结果发布至风控前置模块；另一方面，该单元自动根据后台数据变化，执行资金预警检查、异常交易判定等逻辑，并将产生的数据推送给风控前置模块。

进一步的，低时效服务组模块包括可灵活横向扩展的N个服务单元来并发处理多个风控业务请求，每一服务单元中包括压力试算单元、会员预结算单元、停板试算单元和权益反向试算单元。

压力试算单元的功能为：支持业务人员灵活调整保证金率、价格类型等试算参数，从而对投资者进行试算。

会员预结算单元的功能为：基于系统的预估结算价，提前对会员进行结算。可辅助会员每日从交易所执行出金操作，实现资金利用的最大化。

停板试算单元的功能为：模拟当交易所出现连续停板的极端行情下，评估投资者的抗风险能力。

权益反向试算单元的功能为：评估投资者抗风险能力的另一种手段，验证投资这当前可用资金可以承受的行情波动幅度。

负载均衡与缓存中心系统的具体实现如图2所示的实施例，本实施例的用于金融领域的负载均衡与缓存中心系统包括缓存中心系统和负载均衡系统两部分。

负载均衡系统的功能为：通过动态维护低时效服务组模块中的每个服务单元1～N的状态，并实现特定的挑选算法(例如下文中提到的顺序查找算法)，实现风控业务请求的均匀分发。

负载均衡系统包括服务实时状态维护单元和服务挑选单元。

服务实时状态维护单元，负责初始化并动态维护低时效服务组模块中每一个服务单元的实时状态。每个服务单元可能处于“空闲”或“繁忙”两种状态且每个服务单元都被初始化为“空闲状态”。当负载均衡系统收到一笔低时效业务请求时，其中一个状态为“空闲”的服务单元会被选中负责该笔请求的业务处理。此时，该服务单元会被置为“繁忙”状态。为了能源源不断地处理后续请求任务，本发明通过服务单元和负载均衡系统之间的服务状态报告，实现了服务单元状态的重置机制。当服务单元完成一笔特定的业务请求，并将业务应答发布至风控前置模块之后，服务单元会向负载均衡系统发送服务状态报告。负载均衡系统根据服务状态报告中包含的服务单元序号信息，重置该服务单元的状态为“空闲”。

服务挑选单元，负责从低时效服务组模块中挑选一个状态为“空闲”的服务单元。为简化算法实现，本发明使用了朴素的顺序查找算法选取空闲单元。即顺序遍历所有的服务单元，当找到第一个空闲的服务单元时，停止查找，并指定该服务单元负责处理本次业务请求。若不存在任何一个空闲的服务单元，则返回错误。在完成挑选之后，再由服务实时状态维护单元更新该服务单元的状态。

缓存中心系统的功能为：通过实现用户会话粒度的分业务数据缓存，保证业务请求数据的正确性与完整性。

缓存中心系统进一步包括N个会话单元，这是为了保证系统可以同时处理来自不同操作员的业务请求。通过实现多个会话单元，实现不同会话的彻底隔离，可防止后台数据发生错乱，保证业务请求的数据准确性。同时，每一会话单元中可缓存N个业务参数数据和请求数据，这是为了让系统可以同时处理来自同一业务操作端的不同请求。

通过这种方式，系统具备了多会话以及单会话多业务共两个维度的并发处理能力。

当收到一笔具体的低时效业务请求时，缓存中心系统便开始缓存该笔请求相关的业务参数数据和请求数据。系统通过一个特殊的结束标志来代表请求发送完毕。当缓存中心收到该标志后，代表一笔完整的业务数据(即业务参数数据+请求数据)缓存完成。在完成数据打包，并发送给特定的服务单元之后，缓存中心将清空该笔缓存数据。若当前不存在空闲的服务单元，该笔缓存数据同样也会被清空。

此外，缓存中心系统还配置异常处理机制，当系统出现异常时自动清除缓存中的异常数据，保证业务数据的一致性和完整性。例如当某个业务人员的操作端与后台的连接异常断开时，缓存中心系统自动清空该会话单元中所有业务类型的缓存数据。

尽管为使解释简单化将上述方法图示并描述为一系列动作，但是应理解并领会，这些方法不受动作的次序所限，因为根据一个或多个实施例，一些动作可按不同次序发生和/或与来自本文中图示和描述或本文中未图示和描述但本领域技术人员可以理解的其他动作并发地发生。

本领域技术人员将进一步领会，结合本文中所公开的实施例来描述的各种解说性逻辑板块、模块、电路、和算法步骤可实现为电子硬件、计算机软件、或这两者的组合。为清楚地解说硬件与软件的这一可互换性，各种解说性组件、框、模块、电路、和步骤在上面是以其功能性的形式作一般化描述的。此类功能性是被实现为硬件还是软件取决于具体应用和施加于整体系统的设计约束。技术人员对于每种特定应用可用不同的方式来实现所描述的功能性，但这样的实现决策不应被解读成导致脱离了本发明的范围。

结合本文所公开的实施例描述的各种解说性逻辑板块、模块、和电路可用通用处理器、数字信号处理器(DSP)、专用集成电路(ASIC)、现场可编程门阵列(FPGA)或其它可编程逻辑器件、分立的门或晶体管逻辑、分立的硬件组件、或其设计成执行本文所描述功能的任何组合来实现或执行。通用处理器可以是微处理器，但在替换方案中，该处理器可以是任何常规的处理器、控制器、微控制器、或状态机。处理器还可以被实现为计算设备的组合，例如DSP与微处理器的组合、多个微处理器、与DSP核心协作的一个或多个微处理器、或任何其他此类配置。

结合本文中公开的实施例描述的方法或算法的步骤可直接在硬件中、在由处理器执行的软件模块中、或在这两者的组合中体现。软件模块可驻留在RAM存储器、闪存、ROM存储器、EPROM存储器、EEPROM存储器、寄存器、硬盘、可移动盘、CD-ROM、或本领域中所知的任何其他形式的存储介质中。示例性存储介质耦合到处理器以使得该处理器能从/向该存储介质读取和写入信息。在替换方案中，存储介质可以被整合到处理器。处理器和存储介质可驻留在ASIC中。ASIC可驻留在用户终端中。在替换方案中，处理器和存储介质可作为分立组件驻留在用户终端中。

在一个或多个示例性实施例中，所描述的功能可在硬件、软件、固件或其任何组合中实现。如果在软件中实现为计算机程序产品，则各功能可以作为一条或更多条指令或代码存储在计算机可读介质上或藉其进行传送。计算机可读介质包括计算机存储介质和通信介质两者，其包括促成计算机程序从一地向另一地转移的任何介质。存储介质可以是能被计算机访问的任何可用介质。作为示例而非限定，这样的计算机可读介质可包括RAM、ROM、EEPROM、CD-ROM或其它光盘存储、磁盘存储或其它磁存储设备、或能被用来携带或存储指令或数据结构形式的合意程序代码且能被计算机访问的任何其它介质。任何连接也被正当地称为计算机可读介质。例如，如果软件是使用同轴电缆、光纤电缆、双绞线、数字订户线(DSL)、或诸如红外、无线电、以及微波之类的无线技术从web网站、服务器、或其它远程源传送而来，则该同轴电缆、光纤电缆、双绞线、DSL、或诸如红外、无线电、以及微波之类的无线技术就被包括在介质的定义之中。如本文中所使用的盘(disk)和碟(disc)包括压缩碟(CD)、激光碟、光碟、数字多用碟(DVD)、软盘和蓝光碟，其中盘(disk)往往以磁的方式再现数据，而碟(disc)用激光以光学方式再现数据。上述的组合也应被包括在计算机可读介质的范围内。

提供对本公开的先前描述是为使得本领域任何技术人员皆能够制作或使用本公开。对本公开的各种修改对本领域技术人员来说都将是显而易见的，且本文中所定义的普适原理可被应用到其他变体而不会脱离本公开的精神或范围。由此，本公开并非旨在被限定于本文中所描述的示例和设计，而是应被授予与本文中所公开的原理和新颖性特征相一致的最广范围。