(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210934596.7 (22)申请日 2022.08.04 (71)申请人 中国平安财产保险股份有限公司 地址 518000 广东省深圳市福田区益田路 5033号平安金融中心12、 13、 38、 39、 40 层 (72)发明人 周国中　 (74)专利代理 机构 深圳市力道知识产权代理事 务所(普通 合伙) 44507 专利代理师 张传义 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01) G06F 16/2458(2019.01) G06F 16/215(2019.01)G06Q 40/04(2012.01) (54)发明名称 数据一致性处理方法、 装置、 服务器及存储 介质 (57)摘要 本申请涉及数据处理， 提供一种数据一致性 处理方法、 装置、 服务器及存储介质， 该方法包 括： 获取执行失败的目标事务的任务数据， 并将 目标事务的任务数据缓存至预设磁盘阵列； 根据 任务数据中的任务配置数据， 从预设降级插件的 降级容器中查找目标降级逻辑； 基于目标降级逻 辑对应的降级函数， 调用预设磁盘阵列中缓存的 任务数据对目标事务进行重试补偿； 在检测到经 过重试补偿的目标事务执行成功后， 删除预设磁 盘阵列中缓存的目标事务的任务数据。 本申请旨 在保证数据一致性的同时， 还能提高系统并发能 力和系统可用性。 权利要求书2页 说明书11页 附图3页 CN 115168384 A 2022.10.11 CN 115168384 A 1.一种数据一 致性处理方法， 其特 征在于， 包括： 获取执行失败的目标事务的任务数据， 并将所述目标事务的任务数据缓存至预设磁盘 阵列； 根据所述任务数据中的任务配置数据， 从预设降级插件的降级容器中查找目标降级逻 辑； 基于所述目标降级逻辑对应的降级函数， 调用所述预设磁盘阵列中缓存的所述任务数 据对所述目标事务进行重试补偿； 在检测到经过重试补偿的所述目标事务执行成功后， 删除所述预设磁盘阵列中缓存的 所述目标事务的任务数据。 2.如权利要求1所述的数据一致性处理方法， 其特征在于， 所述基于所述目标降级逻辑 对应的降级函数， 调用所述预设磁盘阵列中缓存的所述任务数据对所述目标事务进行重试 补偿， 包括： 调用预设的动态编译器对所述目标降级逻辑进行动态编译， 生成所述目标降级逻辑对 应的降级函数； 运行所述降级函数， 以查询所述预设磁 盘阵列中缓存的所述任务数据； 通过缓存的所述任务数据生成所述目标事务的补偿任务， 并定时执 行所述补偿任务。 3.如权利要求2所述的数据一致性处理方法， 其特征在于， 所述通过缓存的所述任务数 据生成所述目标事务的补偿任务， 包括： 根据所述任务数据中的第一任务标识， 确定所述目标事务是立即执行还是调度执行， 以获取第一补偿任务； 根据所述任务数据中的第 二任务标识， 确定所述目标事务是以事务方式执行还是以非 事务方式执 行， 以获取第二补偿任务； 根据所述第一补偿任务和第二补偿任务， 生成所述目标事务的补偿任务。 4.如权利要求3所述的数据一致性处理方法， 其特征在于， 所述根据所述第 一补偿任务 和第二补偿任务， 生成所述目标事务的补偿任务之前， 还 包括： 若所述第一补偿方式为立即执行所述目标事务， 则确定所述目标事务是同步执行还是 异步执行， 以获取第三补偿任务； 若所述第一补偿方式为调度 执行所述目标事务， 则确定调度执行所述任务数据的数据 服务器， 并根据调度执 行所述任务数据的数据服 务器获取第三补偿任务； 根据所述第一补偿任务、 第二补偿任务和所述第三补偿任务， 生成所述目标事务的补 偿任务。 5.如权利要求1 ‑4中任一项所述的数据一致性处理方法， 其特征在于， 所述方法还包 括： 在检测到经 过重试补偿的所述目标事务执 行失败后， 生成所述目标事务的撤销指令； 将所述撤销指令发送至多个数据服务器， 所述撤销指令用于通知所述多个数据服务器 同步撤销所述目标事务。 6.如权利要求5所述的数据一致性处理方法， 其特征在于， 所述在检测到经过重试补偿 的所述目标事务执 行失败后， 还 包括： 基于所述目标事务的任务数据， 生成所述目标事务的预警表达式；权　利　要　求　书 1/2 页 2 CN 115168384 A 2输出所述预警表达式， 并删除所述预设磁盘阵列中缓存的所述目标事务的任务数据； 其中， 所述预警表达式用于提 示用户所述目标事务的数据不 一致。 7.如权利要求1 ‑4中任一项所述的数据一致性处理方法， 其特征在于， 所述获取执行失 败的目标事务的任务数据， 包括： 接收消息中间件返回的事务执 行异常消息； 根据所述事务执行异常消息确定执行失败的分支事务， 并确定包括所述分支事务的目 标事务； 获取所述目标事务中的多个分支事务的任务数据。 8.一种数据一 致性处理装置， 其特 征在于， 所述数据一 致性处理装置包括： 获取模块， 用于获取执行失败的目标事务的任务数据， 并将所述目标事务的任务数据 缓存至预设磁 盘阵列； 查找模块， 用于根据所述任务数据中的任务配置数据， 从预设降级插件的降级容器中 查找目标降级逻辑； 补偿模块， 用于基于所述目标降级逻辑对应的降级函数， 调用所述预设磁盘阵列中缓 存的所述任务数据对所述目标事务进行重试补偿； 删除模块， 用于在检测到经过重试补偿的所述目标事务执行成功后， 删除所述预设磁 盘阵列中缓存的所述目标事务的任务数据。 9.一种服务器， 其特征在于， 所述服务器包括处理器、 存储器、 以及存储在所述存储器 上并可被所述处理器执行 的计算机程序， 其中所述计算机程序被所述处理器执行时， 实现 如权利要求1至7中任一项所述的数据一 致性处理方法的步骤。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质上存储有计算机 程序， 其中所述计算机程序被处理器执行时， 实现如权利要求1至7中任一项所述的数据一 致性处理方法的步骤。权　利　要　求　书 2/2 页 3 CN 115168384 A 3