(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210799014.9 (22)申请日 2022.07.08 (71)申请人 武汉达梦数据库股份有限公司 地址 430000 湖北省武汉市东湖新 技术开 发区高新大道999号未来科技大厦C3 栋16-19层 (72)发明人 彭青松　余院兰　孙峰　刘启春　 (74)专利代理 机构 深圳市六加知识产权代理有 限公司 4 4372 专利代理师 向彬 (51)Int.Cl. G06F 16/2457(2019.01) G06F 16/25(2019.01) G06F 16/27(2019.01) G06F 16/28(2019.01) (54)发明名称 一种共享存储集群数据库的数据 同步方法 及设备 (57)摘要 本发明涉及一种共享存储集群数据库的数 据同步方法及设备。 其方法部分主要包括： 源端 数据库同步系统针对共享存储集群的每个实例 对应初始化一个日志读取线程； 日志读取线程将 读取到的日志送入日志排序线程的待排序队列， 日志排序线程通过预先设置的日志依赖关系来 排序日志， 并将日志按顺序添加到日志分析线程 的待分析队列； 日志分析线程 从待分析队列中按 顺序抽取日志进行分析处理， 处理完成后加入到 日志投递线程的待投递消息队列， 日志投递线程 将待投递的消息发送到目的端进行入库。 本发明 可以保证事务同步的次序正确， 且能高效排序日 志， 从而提升整体数据同步 性能。 权利要求书2页 说明书8页 附图5页 CN 115168434 A 2022.10.11 CN 115168434 A 1.一种共享存 储集群数据库的数据同步方法， 其特 征在于， 包括： 源端数据库同步系统针对 共享存储集群的每 个实例对应初始化 一个日志读取线程； 日志读取线程将读取到的日志送入日志排序线程的待排序队列， 日志排序线程通过预 先设置的日志 依赖关系来 排序日志， 并将日志按顺序添加到日志分析线程的待分析队列； 日志分析线程从待分析队列中按顺序抽取 日志进行分析处理， 处理完成后加入到日志 投递线程的待投递消息队列， 日志投递线程将待投递的消息发送到目的端 进行入库。 2.根据权利要求1所述的共享存储集群数据库的数据同步方法， 其特征在于， 所述日志 读取线程将读取到的日志送入日志 排序线程的待排序队列， 日志排序线程通过预先设置的 日志依赖关系来 排序日志， 并将日志按顺序添加到日志分析线程的待分析队列具体包括： 日志读取线程从对应实例节点上读取 日志， 将读取到的日志加入到日志排序线程的日 志待排序队列中， 并设置当前节点 LSN； 日志排序线程按顺序遍历待排序队列中的日志， 根据遍历到的日志获取其日志依赖关 系， 所述日志 依赖关系包括该日志 依赖的节点 号以及依赖节点的最大LSN所 形成的数组； 比对日志的当前节点LSN与依赖节点的最大LSN大小， 若所有依赖节点的最大LSN均大 于当前节点 LSN， 则将该日志添加到日志分析线程的待分析队列。 3.根据权利要求2所述的共享存储集群数据库的数据同步方法， 其特征在于， 在根据遍 历到的日志获取其日志依赖关系时， 若该日志不存在日志依赖关系， 则直接将该日志添加 到日志分析线程的待分析队列。 4.根据权利要求2所述的共享存储集群数据库的数据同步方法， 其特征在于， 在比对日 志的当前节点LSN与依赖节点的最大LSN大小 时， 若存在一个依赖节点的最大LSN小于当前 节点LSN， 则将该依赖节点的当前日志添加到日志分析线程的待分析队列。 5.根据权利要求2所述的共享存储集群数据库的数据同步方法， 其特征在于， 在比对日 志的当前节点LSN与依赖节点的最大LSN大小 时， 若存在多个依赖节点的最大LSN小于当前 节点LSN， 则选取其中最小LSN的依赖节点的当前日志加入到日志分析线程的待分析队列。 6.根据权利要求2所述的共享存储集群数据库的数据同步方法， 其特征在于， 所述日志 读取线程从对应实例节点上读取日志时， 若没有读到日志， 则循环继续读取， 直至读取到日 志。 7.根据权利要求2所述的共享存储集群数据库的数据同步方法， 其特征在于， 日志排序 线程按顺序遍历待排序队列中的日志 时， 还获取对应的日志基础信息， 所述日志基础信息 包括当前日志的节 点号、 当前日志的最小LSN和最大LSN、 前一个日志的最大LSN中的一种或 多种。 8.根据权利要求1 ‑7任一所述的共享存储集群数据库的数据同步方法， 其特征在于， 所 述方法还 包括： 在源端数据库及目的端数据库均部署同步系统； 其中， 源端数据库同步系统从源端共 享存储集群数据库读取日志， 目的端 数据库同步系统负责把源端发过来的同步操作应用到 目的端数据库。 9.根据权利要求1 ‑7任一所述的共享存储集群数据库的数据同步方法， 其特征在于， 所 述方法还 包括： 目的端数据库同步系统接收到源端数据库同步系统 的日志投递线程所投递的消息后，权　利　要　求　书 1/2 页 2 CN 115168434 A 2解包该消息， 然后通过目的端数据库的接口进行入库。 10.一种共享存 储集群数据库的数据同步设备， 其特 征在于： 包括至少一个处理器和存储器， 所述至少一个处理器和存储器之间通过数据总线连 接， 所述存储器存储能被所述至少一个处理器执行 的指令， 所述指令在被所述处理器执行 后， 用于完成权利要求1 ‑9中任一项所述的共享存 储集群数据库的数据同步方法。权　利　要　求　书 2/2 页 3 CN 115168434 A 3