(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210447065.5 (22)申请日 2022.04.26 (65)同一申请的已公布的文献号 申请公布号 CN 114896258 A (43)申请公布日 2022.08.12 (73)专利权人 北京科杰科技有限公司 地址 100020 北京市朝阳区阜通 东大街1号 院3号楼3层2单 元120307 (72)发明人 郭亚齐　于洋　高经郡　 (74)专利代理 机构 北京维正专利代理有限公司 11508 专利代理师 卓凡 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01)G06F 9/54(2006.01) (56)对比文件 CN 1098152 91 A,2019.0 5.28 CN 109063027 A,2018.12.21 CN 113760566 A,2021.12.07 CN 114116144 A,2022.03.01 EP 1197856 A2,2002.04.17 审查员 张琳琳 (54)发明名称 事务数据 的同步方法、 装置、 计算机设备及 存储介质 (57)摘要 本申请公开了一种事务数据的同步方法、 装 置、 计算机设备及存储介质， 其中， 该事务数据的 同步方法包括： 采用事务记录筛选器确定消息的 消息类型； 若消息类型为事务数据， 则给消息建 立事务账本， 并采用Raft共识机制将 事务账本与 所有节点的全网账本进行同步； 当事务账本对应 的账本状态处于待消费状态时， 检查事务账本的 幂等性获取检查结果； 若检查结果为不满足幂等 性， 则执行事务账本中的事务， 并获取事务执行 结果； 采用补偿机制校验事务执行结果， 获取校 验结果。 该方法可有效地提高大数据实时同步系 统中事务数据的及时同步保持事务数据的一致 性， 保证数据不重复不丢失， 简化数据配置 单元， 有效实现 分布式系统配件的插拔扩 展。 权利要求书2页 说明书9页 附图5页 CN 114896258 B 2022.12.16 CN 114896258 B 1.一种事务数据的同步方法， 其特 征在于， 包括： 获取消息， 并采用事务记录 筛选器确定所述消息的消息类型； 若所述消息类型为事务数据， 则给所述消息建立事务账本以及事务ID， 并采用Raft共 识机制将所述事务 ID对应的所述事务账本与所有节点的全网账本进行同步； 当所述事务账本对应的账本状态处于待消费状态时， 检查所述事务账本的幂等性， 获 取检查结果； 若所述检查结果为不满足幂等性， 则执行所述事务账本中的事务， 并获取事务执行结 果； 采用补偿机制校验所述事务执行结果， 获取校验结果， 基于所述校验结果更新所述事 务账本对应的账本状态。 2.根据权利要求1所述的事务数据的同步方法， 其特征在于， 所述全 网账本包括一个主 节点和至少一个与所述主节点保持同步的从节点； 在所述采用Raft共识机制将所述事务ID对应的所述事务账本与全网账本进行同步之 后， 还包括： 若所述主节点发生故障， 则从任一所述从节点中选举出新的主节点。 3.根据权利要求1所述的事务数据的同步方法， 其特征在于， 所述执行所述事务账本中 的事务， 包括： 将所述事务账本 中的事务发送给消息 中间件， 以使所述消息 中间件将所述事务账本中 的事务插 入消息队列后发送给消息消费者， 用于执 行所述事务账本中的事务。 4.根据权利要求1所述的事务数据的同步方法， 其特征在于， 所述校验结果包括完成执 行和未完成执 行； 所述采用 补偿机制校验所述事务执行结果， 获取校验结果， 基于所述校验结果更新所 述事务账本对应的账本状态， 包括： 校验所述事务执 行结果对应的所有子事务； 若所有子事务均完成， 则所述校验结果为完成执行， 将所述账本状态更新为事务完成 执行； 若所有子事务未完全完成， 则所述校验结果 为未完成执 行并提取异常数据； 采用补偿机制补偿所述异常数据， 若在预设补偿次数后获取的所述校验结果仍为未完 成， 则进行 数据回滚， 并将所述账本状态更新 为事务未完成执 行。 5.根据权利要求1所述的事务数据的同步方法， 其特征在于， 在所述采用事务记录筛选 器确定所述消息的消息类型之后， 还 包括： 若所述消息类型为非事务数据， 则给 所述消息建立非事务账本以及非事务 ID。 6.根据权利要求1所述的事务数据的同步方法， 其特征在于， 在所述获取消息之前， 还 包括： 将按集群式部署所有节点， 采用RPC协议 ‑Dubbo架构支持所有所述节点之间的远程调 用。 7.根据权利要求1所述的事务数据的同步方法， 其特 征在于， 所述获取消息包括： 获取通过消息分发机制分发的消息， 所述消息分发机制包括： 配置节点标记顺序、 服务 器内存监控、 随机分发机制或者指定分发机制中的任一种。权　利　要　求　书 1/2 页 2 CN 114896258 B 28.一种事务数据的同步装置， 其特 征在于， 包括： 确定消息类型模块， 用于获取消息， 并采用事务记录 筛选器确定所述消息的消息类型； 建立事务账本模块， 用于若所述消息类型为事务数据， 则给所述消息建立事务账本以 及事务ID， 并采用R aft共识机制将所述事务ID对应的所述事务账本与所有节 点的全网账本 进行同步； 检查事务幂等性模块， 用于当消息消费者消费所述事务账本对应的消息时， 检查所述 事务账本的幂等 性， 获取检查结果； 获取事务执行结果模块， 用于若所述检查结果为不满足幂等性， 则执行所述事务账本 中的事务， 并获取事务执 行结果； 校验事务执行结果模块， 用于采用补偿机制校验所述事务执行结果， 获取校验结果， 基 于所述校验结果更新所述事务账本对应的账本状态。 9.一种计算机设备， 包括存储器、 处理器以及存储在所述存储器中并可在所述处理器 上运行的计算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现如权利要求 1至 7任一项所述事务数据的同步方法。 10.一种计算机可读存储介质， 所述计算机可读存储介质存储有计算机程序， 其特征在 于， 所述计算机程序被处理器执行时实现如权利要求1至7任一项所述事务数据的同步方 法。权　利　要　求　书 2/2 页 3 CN 114896258 B 3