(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210277883.5 (22)申请日 2022.03.21 (71)申请人 康键信息技 术 （深圳） 有限公司 地址 518000 广东省深圳市前海深港合作 区前湾一路1号A栋201室 （入驻深圳市 前海商务秘书 有限公司） (72)发明人 黄子超　 (74)专利代理 机构 北京辰权知识产权代理有限 公司 11619 专利代理师 付婧 (51)Int.Cl. G06F 11/30(2006.01) G06F 11/34(2006.01) G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 一种分布式事务 一致性实现方法及装置 (57)摘要 本发明公开了一种分布式事务一致性实现 方法及装置， 应用于分布式事务系统， 所述分布 式事务系统包括协调节点和数据节 点集群， 所述 协调节点用于将事务分布到参与事务的数据节 点执行， 方法包括： 在执行事务过程中， 所述协调 节点记录命令发送日志， 每个数据节 点记录事务 提交日志； 当所述协调节点和/或某数据节点故 障并恢复后， 所述协调节点获取每个数据节点记 录的事务提交日志， 并利用本地存储的命令发送 日志与获取的事务提交日志判定数据是否一致， 当判定不一致时， 同步数据节点的数据， 以解决 在协调节 点发送提交命令 之后， 协调节点和数据 节点均故障又恢复后出现的数据不 一致问题。 权利要求书2页 说明书7页 附图3页 CN 114579406 A 2022.06.03 CN 114579406 A 1.一种分布式事务一致性实现方法， 其特征在于， 应用于分布式事务系统， 所述分布式 事务系统包括协调节 点和数据 节点集群， 所述协调节点用于将事务分布到参与事务的数据 节点执行， 所述方法包括： 在执行事务过程中， 所述协调节点记录命令发送日志， 每个数据节点记录事务提交日 志； 当所述协调节点和/或某数据节点故障并恢复后， 所述协调节点获取每个数据节点记 录的事务提交日志， 并利用本地存储的命令发送日志与获取的事务提交日志判定数据是否 一致， 当判定不 一致时， 通过重新发送命令方式使各个数据节点的数据保持一 致。 2.根据权利要求1所述的方法， 其特 征在于， 所述协调节点记录命令发送日志， 包括： 所述协调节点向各个参与事务的所述数据节点发送事务提交命令之后， 利用事务标识 和各个参与事务的数据节点的节点标识生成所述命令发送日志。 3.根据权利要求1所述的方法， 其特征在于， 所述每个数据节点记录事务提交日志， 包 括： 所述数据节点收到所述协调节点发送的事务提交命令后， 执行本地事务提交操作， 并 利用事务标识、 本数据节点的节点标识和提交成功标识生成所述事务 提交日志。 4.根据权利要求3所述的方法， 其特征在于， 所述数据节点执行本地事务提交操作， 包 括： 所述数据节点将本地事务执 行结果提交至数据库中， 以更新所述数据库中的数据。 5.根据权利要求1所述的方法， 其特征在于， 所述利用本地存储的命令发送日志与获取 的事务提交日志判定数据是否一 致， 包括： 获取日志时间与当前系统时间最接近的命令发送日志中包含的事务标识和各个参与 事务的数据节点的节点标识； 针对每个节点标识， 从获取的事务提交日志中， 查找同时包含所述事务标识和所述节 点标识的事务 提交日志； 若存在某一节点标识查找失败的情况， 则确定数据不 一致； 若针对每 个节点标识均查找成功， 则确定数据一 致。 6.根据权利要求5所述的方法， 其特征在于， 所述通过重新发送命令方式使各个数据节 点的数据保持一 致， 包括： 向查找失败的节点标识对应的数据节点重新发送事务提交命令， 以使所述数据节点的 数据与其 他数据节点保持一 致性。 7.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 所述协调节点每隔预设时间周期清除一次本地记录的命令发送日志； 每个所述数据节点每隔预设时间周期清除一次本地记录的事务 提交日志。 8.一种分布式事务一致性实现装置， 其特征在于， 应用于分布式事务系统， 所述分布式 事务系统包括协调节 点和数据 节点集群， 所述协调节点用于将事务分布到参与事务的数据 节点执行； 所述装置包括协调节点上的第 一记录模块和一致性模块， 以及每个数据节点上的第 二 记录模块； 所述第一记录模块， 用于在执 行事务过程中， 记录命令发送日志；权　利　要　求　书 1/2 页 2 CN 114579406 A 2所述第二记录模块， 用于在执 行事务过程中， 记录事务 提交日志； 所述一致性模块， 用于当所述协调节点和/或某数据节点故障并恢复后， 获取每个数据 节点记录的事务提交日志， 并利用本地存储的命令发送日志与获取的事务提交日志判定数 据是否一 致， 当判定不 一致时， 通过重新发送命令方式使各个数据节点的数据保持一 致。 9.根据权利要求8所述的装置， 其特征在于， 所述一致性模块， 具体用于在利用本地存 储的命令发送日志与获取的事务提交日志判定数据是否一致过程中， 获取日志时间与当前 系统时间最接近的命令发送日志中包含的事务标识和各个参与事务的数据节点的节点标 识； 针对每个节点标识， 从获取的事务提交日志中， 查找同时包含所述事务标识和所述节 点 标识的事务提交日志； 若存在某一节 点标识查找失败的情况， 则确定数据不一致； 若针对每 个节点标识均查找成功， 则确定数据一 致。 10.根据权利要求9所述的装置， 其特征在于， 所述一致性模块， 具体用于在通过重新发 送命令方式使 各个数据节点的数据保持一致过程中， 向查找失败的节点标识对应的数据 节 点重新发送事务 提交命令， 以使所述数据节点的数据与其 他数据节点保持一 致性。权　利　要　求　书 2/2 页 3 CN 114579406 A 3