(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 20221024285 0.7 (22)申请日 2022.03.11 (71)申请人 北京沃东天骏信息技 术有限公司 地址 100176 北京市经济技 术开发区科创 十一街18号院2号楼4层A402室 申请人 北京京东世纪贸易有限公司 (72)发明人 陈鑫　 (74)专利代理 机构 北京同立钧成知识产权代理 有限公司 1 1205 专利代理师 贺财俊　黄健 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 数据一致性校验方法、 装置、 设备及存储介 质 (57)摘要 本申请提供一种数据一致性校验方法、 装 置、 设备及存储介质， 该方法包括： 通过从第一数 据监听队列获取第一业务系统的第一数据变更 消息； 根据第一数据变更消息生成数据校验任 务， 并将数据校验任务加入延时消息队列； 数据 校验任务用于校验第一业务系统与第一业务系 统关联的第二业务系统的数据一致性； 在延时消 息队列中的数据校验任务到期时， 获取数据校验 任务对应的第一业务系统和第二业务系统中的 关联数据， 对关联数据进行数据一致性校验。 通 过设置数据监听队列、 延时消息队列， 确保系统 数据校验任务有序进行。 通过对延时消息队列中 数据校验任务的执行时间的控制， 优化系统数据 一致性校验的处理能力， 提高数据一致性校验的 准确率。 权利要求书2页 说明书11页 附图3页 CN 114610735 A 2022.06.10 CN 114610735 A 1.一种数据一 致性校验方法， 其特 征在于， 包括： 从第一数据监听队列获取第一 业务系统的第一数据变更消息； 根据所述第 一数据变更消息生成数据校验任务， 并将所述数据校验任务加入延时消息 队列； 所述数据校验任务用于校验所述第一业务系统与所述第一业务系统关联的第二业务 系统的数据一 致性； 在所述延时消息队列中的所述数据校验任务到期时， 获取所述数据校验任务对应的所 述第一业务系统和所述第二业务系统中的关联数据， 对所述关联数据进行数据一致性校 验。 2.根据权利要求1所述的方法， 其特征在于， 所述根据所述第 一数据变更消息生成数据 校验任务， 并将所述数据校验 任务加入延时消息队列， 包括： 通过解析所述第 一数据变更消息， 获取所述第 一业务系统 的变更数据以及所述第 一业 务系统的变更 数据对应的第一标识数据； 将所述第一标识数据作为所述数据校验任务的标识， 将所述第 一标识数据加入所述延 时消息队列。 3.根据权利要求1所述的方法， 其特征在于， 所述在所述延时消息队列中的所述数据校 验任务到期时， 获取所述数据校验任务对应的所述第一业务系统和所述第二业务系统中的 关联数据， 包括： 在所述延时消息队列中的所述数据校验任务到期时， 根据所述第一标识数据， 从缓存 中获取所述数据校验 任务对应的所述第一 业务系统和所述第二 业务系统中的关联 数据。 4.根据权利要求1 ‑3任一项所述的方法， 其特征在于， 所述关联数据包括所述第 一业务 系统的变更数据， 以及与所述变更数据对应的所述第二业务系统的目标数据； 对所述关联 数据进行 数据一致性校验， 包括： 若所述变更数据与所述目标数据不一致， 根据所述变更数据修正所述目标数据， 和/ 或， 将所述数据校验 任务的相关数据推送至运营终端。 5.根据权利要求4所述的方法， 其特征在于， 若所述变更数据与所述目标数据不一致， 根据所述变更 数据修正所述目标 数据之后， 所述方法还 包括： 根据所述变更 数据更新与所述第二 业务系统关联的其 他业务系统的关联 数据。 6.根据权利要求2所述的方法， 其特 征在于， 所述方法还 包括： 将所述第一 业务系统的变更 数据以及所述第一标识数据保存至缓存中。 7.根据权利要求1 ‑3任一项所述的方法， 其特 征在于， 所述方法还 包括： 从第二数据监听队列获取 所述第二 业务系统的第二数据变更消息； 通过解析所述第 二数据变更消息， 获取所述第 二业务系统 的变更数据以及所述第 二业 务系统的变更 数据对应的第二标识数据； 将所述第二 业务系统的变更 数据以及所述第二标识数据保存至缓存中。 8.根据权利要求3所述的方法， 其特 征在于， 所述方法还 包括： 若所述缓存不包括所述第 一标识数据对应的所述第 二业务系统的目标数据， 根据 所述 第一标识数据从所述第二 业务系统的数据库中获取 所述目标 数据。 9.一种数据一 致性校验装置， 其特 征在于， 包括： 获取模块， 用于从第一数据监听队列获取第一 业务系统的第一数据变更消息；权　利　要　求　书 1/2 页 2 CN 114610735 A 2处理模块， 用于根据所述第一数据变更消息生成数据校验任务， 并将所述数据校验任 务加入延时消息队列； 所述数据校验任务用于校验所述第一业务系统与所述第一业务系统 关联的第二 业务系统的数据一 致性； 所述获取模块， 还用于在所述延时消息队列中的所述数据校验任务到期时， 获取所述 数据校验 任务对应的所述第一 业务系统和所述第二 业务系统中的关联 数据； 所述处理模块， 用于对所述关联 数据进行 数据一致性校验。 10.一种电子设备， 其特征在于， 包括： 存储器， 处理器以及计算机程序； 其中， 所述计算 机程序存储在所述存储器中， 并被配置为由所述处理器执行以实现如权利要求1 ‑8中任一 项所述的方法。 11.一种计算机可读存储介质， 其特征在于， 其上存储有计算机程序， 所述计算机程序 被处理器执行以实现如权利要求1 ‑8中任一项所述的方法。 12.一种计算机程序产品， 其特征在于， 包括计算机程序， 所述计算机程序被处理器执 行时实现权利要求1 ‑8中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 114610735 A 3