CN110765091A 对账方法和系统 （上海陆家嘴国际金融资产交易市场股份有限公司）

分布式数据库服务器将接收到的增量业务数据理服务器轮询分布式存储节点并通过调用预先封装的数据处理层从分布式存储节点中获取增付系统服务器将增量支付数据发送至分布式消处理窗口内分布式消息队列服务器接收的目标2业务系统服务器实时扫描业务系统数据库的第一日志文所述分布式数据库服务器将接收到的所述增量业务数据存储至分布式数据库的分布数据处理服务器轮询所述分布式存储节点并通过调用预先封装的数据处理层从所述支付系统服务器实时扫描支付系统数据库的第二对账系统服务器监听当前流处理窗口内所述分布式消息队列服务器接收的目标增量业务数据及目标增量支付数据，当成功监听到目标增量业务数据及目标增量支付数据时，所述数据处理服务器获取预先创建的主键信息表存储节点中抽取并且成功发送至分布式消息队列的所述数据处理服务器将所述主键信息表中的主键与所述分布式存储节点中的目标数所述数据处理服务器从所述分布式存储节点中抽取与所述第一目标主键对应的增量所述数据处理服务器获取发送成功的增量业务数据对应所述对账系统服务器获取目标业务数据表对应的唯一键配置信息所述对账系统服务器将所述目标增量业务数据中所述目标字段对应的字段值与对账3所述数据处理服务器根据所述可执行代码文件更新所述预先封对账系统服务器将获取的所述目标增量业务数据及目标增量支付数据分别保存在内对账系统服务器将两个临时数据表进行关联操作，对关联成对账系统服务器在所述对账数据库中对对账失败的目标增量业务数据及目标增量支对账系统服务器按照预设时间间隔扫描所述对账数据对账系统服务器对对账数据库中数据的对账状态进业务系统服务器用于实时扫描业务系统数据库的第一日志所述分布式数据库服务器用于将接收到的所述增量业务数据存储至分布式数据库的数据处理服务器用于轮询所述分布式存储节点并通过调用预先封装的数据处理层从支付系统服务器用于实时扫描支付系统数据库的第对账系统服务器用于监听当前流处理窗口内所述分布式消息队列服务器接收的目标所述数据处理服务器还用于获取预先创建的主键信4所述对账系统服务器还用于获取目标业务数据表对应的5[0003]传统技术中，通常都是通过T+1的方式批处理对业务系统及支付系统的数据进行[0007]所述分布式数据库服务器将接收到的所述增量业务数据存储至分布式数据库的[0008]数据处理服务器轮询所述分布式存储节点并通过调用预先封装的数据处理层从[0010]对账系统服务器监听当前流处理窗口内所述分布式消息队列服务器接收的目标布式存储节点中抽取并且成功发送至分布式消息队列[0013]所述数据处理服务器将所述主键信息表中的主键与所述分布式存储节点中的目[0014]所述数据处理服务器从所述分布式存储节点中抽取与所述第一目标主键对应的6[0018]所述对账系统服务器将所述目标增量业务数据中所述目标字段对应的字段值与[0026]对账系统服务器将获取的所述目标增量业务数据及目标增量支付数据分别保存[0028]在其中一个实施例中，所述按照当前对账类型对应的预设对账逻辑执行对账操[0029]对账系统服务器在所述对账数据库中对对账失败的目标增量业务数据及目标增对应的目标增量业务数据及目标增量支付数据再7[0035]所述分布式数据库服务器用于将接收到的所述增量业务数据存储至分布式数据[0036]数据处理服务器用于轮询所述分布式存储节点并通过调用预先封装的数据处理[0038]对账系统服务器用于监听当前流处理窗口内所述分布式消息队列服务器接收的数据时，从所述分布式消息队列服务器中获取所述目标增量业务数据及目标增量支付数[0039]在其中一个实施例中，所述数据处理服务器还用于获取预先所述主键信息表用于存储从分布式存储节点中抽取并且成功发送至分布式消息队列的增送至所述分布式消息队列服务器中；获取发送成功的增量业务数据对应的第二目标主键，8有业务系统数据库，业务系统数据库用于存储各涉及金钱交易的业务场景下的业务数据，[0055]步骤204，分布式数据库服务器将接收到的增量业务数据存储至分布式数据库的[0057]具体地，分布式数据库服务器在接收到业务系统服务器发送的9[0058]步骤206，数据处理服务器轮询分布式存储节点并通过调用预先封装的数据处理分布式数据库中的数据进行处理的程序逻辑。在一个实施例中，数据处理逻辑包括ETL对账,因此需要对支付系统数据库中的增量支付数据进行过滤，具体可以通过以下方式进行过滤：首先将增量支付数据发送至一个消息中间件进行缓存(该消息中间件例如可以是[0065]步骤210，对账系统服务器监听当前流处理窗口内分布式消息队列服务器接收的量业务数据及目标增量支付数据，当成功监听到目标增量业务数据及目标增量支付数据通过流处理地方式从分布式消息队列服务器中获取数据进行对账，从而实现了对账实时[0075]其中，分布式存储节点中的目标数据表指的是用于存储增量业务数据的目标数据表的主键指的是目标数据表中的主关键字(primarykey)，主关键字由目标数据[0081]步骤206D，数据处理服务器获取发送成功的增量业务数据对的主键是不相同的，但是最终得到的增量业务数据中会包含分布式数据库对应的主键字功的数据在分布式数据库中对应的主键回写至主键信息表中，主键信息表得以不断地更[0085]在一个实施例中，上述步骤210中从分布式消息队列服务器中获取目标增量业务一键配置信息指的是事先配置的用于对目标业务数据表中的数据记录进行唯一性约束的数据库中的数据记录不重复，可以将比对一致的字段值对应的目标增量业务数据过滤掉，目标增量业务数据记录与第二临时数据表的任意一条目标增量支付数据记录中的订单编器通过在对账数据库中对对账失败的目标增量业务数据及目标增量支付数据设置预设状[0109]业务系统服务器502用于实时扫描业务系统数据库的第一日志文件，对第一日志[0110]分布式数据库服务器504用于将接收到的增量业务数据存储至分布式数据库的分[0111]数据处理服务器506用于轮询分布式存储节点并通过调用预先封装的数据处理层[0112]支付系统服务器510用于实时扫描支付系统数据库的第二日志文件，对第二日志[0113]对账系统服务器512用于监听当前流处理窗口内分布式消息队列服务器接收的目表用于存储从分布式存储节点中抽取并且成功发送至分布式消息队列的增量业务数据的取发送成功的增量业务数据对应的第二目标主键，将第二目标主键回写至主键信息表中，包括非易失性和/或易失性存储器。非易失性存储器可包括只读存储器(ROM)、可编程ROM型SDR