(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210401171.X (22)申请日 2022.04.18 (65)同一申请的已公布的文献号 申请公布号 CN 114510539 A (43)申请公布日 2022.05.17 (73)专利权人 北京易鲸捷信息技 术有限公司 地址 100089 北京市海淀区知春路128号 4 层401-7 (72)发明人 刘博　范振勇　李东卫　何振兴　 莫荻　武新　 (74)专利代理 机构 四川言己律师事务所 51349 专利代理师 罗韬 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/23(2019.01)G06F 9/46(2006.01) (56)对比文件 CN 113193947 A,2021.07.3 0 CN 113193947 A,2021.07.3 0 CN 112764888 A,2021.0 5.07 CN 109977171 A,2019.07.0 5 CN 114079660 A,2022.02.22 US 2012/ 0102006 A1,2012.04.26 审查员 王妍 (54)发明名称 分布式数据库一致性检查点的生成及应用 方法 (57)摘要 本发明公开了一种分布式数据库一致性检 查点的生 成及应用方法， 属及一种分布式数据库 一致性检查方法， 方法包括以数据库中的主键为 关键字， 对数据库中的数据进行分片， 得到多个 数据分片； 每个数据分片通过其维护的事务写 标 记队列， 辅助生成数据分片的一致性时间戳； 当 事务提交完成， 数据成功写入后， 由数据分片将 所述逻辑指令传输至处理器； 由汇聚器生成全局 时间戳作为整个 分布式数据库的一致性检查点。 通过采用时钟机制生成全局时间戳作为整个分 布式数据库的一致性检查点， 避免了在全局事务 管理器中的网络收发瓶颈， 解决在主备模式下数 据同步带来的性能消耗问题， 更利于提升分布式 数据库的性能。 权利要求书2页 说明书6页 附图5页 CN 114510539 B 2022.06.24 CN 114510539 B 1.一种分布式数据库一 致性检查点的生成方法， 其特 征在于所述的方法包括： 以分布式数据库中的主键为关键字， 对分布式数据库中的存储单元进行分片， 得到多 个数据分片； 每个数据分片通过其维护的事务写标记队列， 辅助生成数据分片的一致性时间戳， 所 述事务写标记队列的列表中包 含事务ID、 事务时间戳与引用计数； 当事务提交完成， 数据成功写入后， 针对每个数据分片生成逻辑指令， 由数据分片将所 述逻辑指令传输 至处理器； 由所述处理器基于当前逻辑指令生成事件， 将事件发送至事务写标记队列， 然后所述 事件发送至事务写标记队列通过消费逻辑指令的事件向前推动数据分片的一致性时间戳， 得到新时间戳后， 将其传输 至汇聚器； 由汇聚器将多个所述新时间戳进行去重与排序处理后， 生成全局时间戳， 以所述全局 时间戳作为整个分布式数据库的一 致性检查点； 所述事务写标记队列包括消费逻辑指令与重计算时间戳； 所述消费逻辑指令为在事务中发生数据更新时， 在有序的事务列表中找到对应的元 素， 并更新 其引用计数， 使当前 数据分片的一 致性时间戳向前推进； 所述重计算 时间戳为在事务写标记队列的列表中取出时间戳最小的元素， 与当前一致 性时间戳进行比较， 如经比较有向前推进， 则更新所述 一致性时间戳。 2.根据权利要求1所述的分布式数据库一致性检查点的生成方法， 其特征在于： 系统实 时检测每个数据分片 中的数据量， 当一个数据分片 中的数量过大时， 将其分裂成两个新的 分片； 当两个在范围上相邻的两个数据分片数据量过少时， 将两个数据分片合并为一个数 据分片； 所述数据分片中数据量的大小通过 预设的阈值确定 。 3.根据权利要求1所述的分布式数据库一致性检查点的生成方法， 其特征在于： 所述消 费逻辑指令在事务的引用计数变为0时， 从列表中删除对应的事务。 4.根据权利要求1或3所述的分布式数据库一致性检查点的生成方法， 其特征在于： 在 所述重计算时间戳的操作中， 还 采用自然时间戳推进所述 一致性时间戳。 5.根据权利要求1所述的分布式数据库一致性检查点的生成方法， 其特征在于： 所述处 理器在启动后首先等待数据分片注册， 数据分片向处理器输出注册请求， 数据分片在处理 器完成注 册后， 由处 理器处理数据分片传输的逻辑指令 。 6.一种分布式数据库一 致性检查点的应用方法， 其特 征在于所述的方法包括： 将权利要求1至5任意一项所获得的一致性检查点， 连同序列号， 通过多数派一致性协 议一并传输 至各个数据库节点； 所述数据库节点在接收到一致性检查点与序列号后， 在暂存队列中判断序列号是否大 于前一次接 收到的一致性检查点的序列号， 如判断结果为否， 将当前一致性检查点与序列 号暂存至 接收队列中； 如判断结果 为是， 则保存本次的一 致性检查点并清空暂存队列。 7.根据权利要求6所述的分布式数据库一致性检查点的应用方法， 其特征在于所述保 存本次的一致性检查点为： 在判断序列号大于前一次接 收到的一致性检查点的序列号后， 继续判断暂存队列中一致性检查点的数据分片数量与当前数据库节点上的分片数量是否 一致；权　利　要　求　书 1/2 页 2 CN 114510539 B 2如判断结果 为是， 则将当前的一 致性检查点保存至当前 数据库节点上； 如判断结果为否， 则继续判断是否因当前数据库节点的数据分片未初始化导致的分片 数量是否一 致； 如判断结果 为是， 则将当前的一 致性检查点保存至当前 数据库节点上； 如判断结果为否， 则继续判断是否因当前数据库节点上的数据分片在等待GC清理， 或 者在一致性检查点传输的过程中发生分裂， 导 致的分片数量是否一 致； 如判断结果 为是， 则将当前的一 致性检查点保存至当前 数据库节点上； 如判断结果 为否， 则放弃保存本次的一 致性检查点。权　利　要　求　书 2/2 页 3 CN 114510539 B 3