(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202211118415.X (22)申请日 2022.09.15 (65)同一申请的已公布的文献号 申请公布号 CN 115205046 A (43)申请公布日 2022.10.18 (73)专利权人 北京锐融天下 科技股份有限公司 地址 100089 北京市海淀区上地 三街9号B 座2层B312 (72)发明人 冯世伟　闵刚　 (74)专利代理 机构 北京超凡宏宇专利代理事务 所(特殊普通 合伙) 11463 专利代理师 彭星 (51)Int.Cl. G06Q 40/04(2012.01) G06Q 20/10(2012.01)G06F 16/27(2019.01) (56)对比文件 CN 110471688 A,2019.1 1.19 US 2009313311 A1,2009.12.17 CN 112231395 A,2021.01.15 CN 111506649 A,2020.08.07 US 2018025 049 A1,2018.01.25 US 201717 7697 A1,2017.0 6.22 CN 107766175 A,2018.0 3.06 审查员 欧晓丹 (54)发明名称 一种数据处理方法、 装置、 电子设备及存储 介质 (57)摘要 本申请提供了一种数据处理方法、 装置、 电 子设备及存储介质， 通过数据库路由器对交易请 求分配到不同的目标数据中心进行处理， 提高了 处理效率； 在目标数据中心处理交易请求之前对 该目标数据中心的数据进行检测， 只有在目标数 据中心里的数据已处于同步状态时， 才对交易请 求进行处理； 在对交易请求进行处理时根据分配 业务锁进行处理， 避免了交易账户的数据不同 步。 权利要求书2页 说明书11页 附图3页 CN 115205046 B 2022.12.09 CN 115205046 B 1.一种数据处理方法， 其特征在于， 应用于数据库路由器， 所述数据库路由器通信连接 有多个数据中心， 不同的数据中心之间具有预设距离的间隔； 所述方法包括： 针对用户发起的交易请求， 根据预设的用户与数据中心 的匹配关系， 为所述交易请求 匹配对应的目标数据中心， 并将所述交易请求发送到所述 目标数据中心； 所述交易请求包 含有目标交易账户； 对各个数据中心进行数据检测， 得到所述目标数据中心关于所述目标交易账户的已存 储业务数据和其他目标数据中心关于所述目标交易账户的历史业务数据， 并将所述已存储 业务数据与所述历史业 务数据进行对比； 若所述已存储业务数据与 所述历史业务数据相同， 根据 所述交易请求发起的业务 时间 和所述目标交易账户， 为各个所述交易请求分配业务锁， 以使所述 目标数据中心根据所述 业务锁依 次对所述交易请求进行处理， 得到所述交易请求对应的当前业务数据； 并在记录 所述当前业务数据之后， 将所述当前业务数据同步到其他数据中心， 进而保持所有的数据 中心的数据处于同步状态。 2.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 监测各个数据中心的工作状态； 若所述目标数据中心处于异常工作状态， 将所述交易请求发送到预设的备用数据中 心； 对各个数据中心进行数据检测， 得到所述备用数据中心关于所述目标交易账户的已存 储业务数据和其他目标数据中心关于所述目标交易账户的历史业务数据， 并将所述已存储 业务数据与所述历史业 务数据进行对比； 若所述已存储业务数据与 所述历史业务数据相同， 根据 所述交易请求发起的业务 时间 和所述目标交易账户， 为各个所述交易请求分配业务锁， 以使所述备用数据中心根据所述 业务锁依 次对所述交易请求进行处理， 得到所述交易请求对应的当前业务数据； 并在记录 所述当前业务数据之后， 将所述当前业务数据同步到其他数据中心， 进而保持所有的数据 中心的数据处于同步状态。 3.根据权利要求2所述的方法， 其特 征在于， 所述方法还 包括： 所述数据库路由器从所述备用数据中心获取所述当前业务数据并进行存储， 以保持与 各个数据中心的数据处于同步状态； 在所述目标数据中心的工作状态再次恢 复正常的时候， 所述数据库路由器根据自身存 储的业务数据对所述目标数据中心进 行数据同步， 以使所述目标数据中心与其他数据中心 保持数据同步。 4.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 若所述已存 储业务数据与所述历史业 务数据不同， 向用户反馈等待信息； 在预设等待时长之后， 再次对各个数据中心进行数据检测， 得到所述目标数据中心关 于所述目标交易账户的已存储业务数据和 其他目标数据中心关于所述目标交易账户的历 史业务数据， 并将所述已存 储业务数据与所述历史业 务数据进行对比； 若所述已存储业务数据与 所述历史业务数据相同， 根据 所述交易请求发起的业务 时间 和所述目标交易账户， 为各个所述交易请求分配业 务锁； 若所述已存 储业务数据与所述历史业 务数据不同， 向用户反馈交易失败信息 。权　利　要　求　书 1/2 页 2 CN 115205046 B 25.根据权利要求1所述的方法， 其特征在于， 所述交易请求包括独立交易请求， 所述独 立交易请求 为与其他交易请求 不存在共同交易账户的请求； 所述 业务锁包括分布式锁； 所述方法通过以下 方式为所述交易请求分配业 务锁： 根据所述独立交易请求发起的业务时间， 为各个所述独立交易请求分配第一分布式 锁。 6.根据权利要求1所述的方法， 其特征在于， 所述交易请求包括关联交易请求， 所述关 联交易请求 为与其他交易请求存在共同交易账户的请求； 所述 业务锁包括联合锁； 所述方法通过以下 方式为所述交易请求分配业 务锁： 为所述关联交易请求分配联合锁； 根据所述关联交易请求包含的各个交易请求发起的业务 时间， 为各个所述交易请求分 配第二分布式锁。 7.根据权利要求6所述的方法， 其特 征在于， 所述方法还 包括： 若所述共同交易账户对应的多个所述关联交易请求匹配到不同的目标数据中心， 根据 所述共同交易账户的账户属 性信息， 对所述关联交易请求的目标数据中心进行调整， 以使 同一所述共同交易账户的所有关联交易请求在同一所述目标 数据中心下进行处 理。 8.一种数据处理装置， 其特征在于， 驻留于数据库路由器， 所述数据库路由器通信连接 有多个数据中心， 不同的数据中心之间具有预设距离的间隔； 所述装置包括： 匹配模块， 用于针对用户发起的交易请求， 根据 预设的用户与数据中心的匹配关系， 为 所述交易请求匹配对应的目标数据中心， 并将所述交易请求发送到所述 目标数据中心； 所 述交易请求包 含有目标交易账户； 检测模块， 用于对各个数据中心进行数据检测， 得到所述目标数据中心关于所述目标 交易账户的已存储业务数据和其他目标数据中心关于所述目标交易账户的历史业务数据， 并将所述已存 储业务数据与所述历史业 务数据进行对比； 分配模块， 用于若所述已存储业务数据与所述历史业务数据相同， 根据所述交易请求 发起的业务时间和所述 目标交易账户， 为各个所述交易请求分配业务锁， 以使所述 目标数 据中心根据所述业务锁依次对所述交易请求进行 处理， 得到所述交易请求对应的当前业务 数据； 并在记录所述当前业务数据之后， 将所述当前业务数据同步到其他数据中心， 进而保 持所有的数据中心的数据处于同步状态。 9.一种电子设备， 其特征在于， 包括： 处理器、 存储器和总线， 所述存储器存储有所述处 理器可执行 的机器可读指令， 当电子设备运行时， 所述处理器与所述存储器之间通过总线 通信， 所述机器可读指令被所述处理器执行时执行如权利要求1至7任一所述的数据处理方 法的步骤。 10.一种计算机可读存储介质， 其特征在于， 该计算机可读存储介质上存储有计算机程 序， 该计算机程序被处 理器运行时执 行如权利要求1至7任一所述的数据处 理方法的步骤。权　利　要　求　书 2/2 页 3 CN 115205046 B 3