(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211087419.6 (22)申请日 2022.09.07 (71)申请人 上海浪潮云计算 服务有限公司 地址 200072 上海市 静安区江场三路238号 411室 (72)发明人 颜亮　刘刚　江燕　王阳　赵山　 (74)专利代理 机构 济南信达专利事务所有限公 司 37100 专利代理师 李世喆　姜鹏 (51)Int.Cl. H04L 67/1095(2022.01) H04L 67/568(2022.01) G06F 16/27(2019.01) (54)发明名称 数据的同步系统和方法 (57)摘要 本发明实施例提供了数据的同步系统和方 法， 该系统的同步任务管理模块用于接收数据提 供侧的租户提交的数据同步任务； 在当前同步任 务管理模块为本区域的同步任务管理模块时， 确 定租户对应的目标数据同步实例， 并基于该目标 数据同步实例下发数据同步任务； 数据同步模块 用于在接收到当前同步任务管理模块下发的数 据同步任务后， 建立源端地址和目标端地址的通 信连接； 从数据提供侧的源数据库中获取待同步 数据， 并将该待同步数据写入中继缓存后向目标 端地址发送， 以由数据同步侧执行数据同步任 务。 本方案通过在源端地址和目标端地址建立通 信连接， 将待同步数据写入中继缓存后发送， 实 现数据同步的同时保证了数据的完整性和安全 性。 权利要求书2页 说明书9页 附图1页 CN 115484274 A 2022.12.16 CN 115484274 A 1.数据的同步系统， 其特 征在于， 包括： 至少一个同步任务管理模块和数据同步模块； 所述至少一个同步任务管理模块中的当前同步任务管理模块， 用于接收数据提供侧的 租户提交的数据同步任务； 当所述当前同步任务管理模块为本区域的同步任务管理模块 时， 确定所述租户对应的目标数据同步实例， 并基于该目标数据同步实例下发所述数据同 步任务； 其中， 所述数据同步任务中包括： 数据提供侧的源端地址和数据同步侧的目标端地 址； 所述数据同步模块， 用于在接收到所述当前同步任务管理模块下发的数据同步任务 后， 建立所述源端地址和所述 目标端地址的通信连接； 从数据提供侧的源数据库中获取待 同步数据， 并将该待同步数据写入中继缓存后向所述 目标端地址发送， 以由所述数据同步 侧执行数据同步任务。 2.根据权利要求1所述的系统， 其特 征在于， 所述当前同步任务管理模块， 进一步用于当所述当前同步任务管理模块不是本区域的 同步任务管理模块时， 将所述数据同步任务分发至其他区域， 以由对应该数据同步任务的 目标区域完成该同步任务。 3.根据权利要求1所述的系统， 其特 征在于， 所述当前同步任务管理模块， 用于根据所述数据同步任务， 查看所述租户的数据同步 实例资源池的空闲实例列 表中是否有空闲实例； 若所述数据同步 实例资源池中具有空闲实 例， 则查看该 空闲实例的规格是否满足预设要求； 若 所述空闲实例的规格满足预设要求， 则 将该空闲实例确定为 目标数据同步实例； 若所述数据同步实例资源池中不具有空闲实例， 或所述数据同步 实例资源池中的空闲实例的规格不满足预设要求， 则根据所述数据同步任 务所需要的规格创建一个新 实例， 并将该新 实例确定为目标数据同步 实例； 其中， 所述规格 包括带宽和存 储空间中的至少一个。 4.根据权利要求1所述的系统， 其特 征在于， 所述当前同步任务管理模块， 进一步用于监听所述数据同步任务的运行进度， 并对全 局事务号进 行存储； 以及， 在所述数据同步任务重启后， 查询所述数据同步任务终止前最后 保存的所述全局事务号， 以恢复所述数据同步任务终止前的同步进度； 其中， 所述全局事务 号用于记录任务的执 行进度。 5.根据权利要求1至4中任一所述的系统， 其特 征在于， 所述数据同步模块， 进一步用于在接收到所述当前同步任务管理模块下发的数据同步 任务后， 对数据提供侧 和数据同步侧的配置进行 预检查， 并在检查 通过后执 行同步任务； 其中， 所述配置的项目包括如下中的至少一个： 数据提供侧和数据同步侧的数据库实例是否连通、 数据提供侧和数据同步侧的实例权 限、 以及数据提供侧和数据同步侧的全局事务号是否开启； 其中， 所述全局事务号用于记录 任务的执 行进度。 6.数据的同步方法， 其特 征在于， 包括： 利用至少一个同步任务管理模块中的当前同步任务管理模块接收数据提供侧的租户 提交的数据同步任务； 当所述当前同步任务管理模块为本区域的同步任务管理模块 时， 利用所述当前同步任 务管理模块确定所述租户对应的目标 数据同步实例；权　利　要　求　书 1/2 页 2 CN 115484274 A 2利用所述当前同步任务管理模块基于该目标数据同步实例下发所述数据同步任务； 其 中， 所述数据同步任务中包括： 数据提供侧的源端地址和数据同步侧的目标端地址； 利用数据同步模块在接收到所述当前同步任务管理模块下发的数据同步任务后， 建立 所述源端地址和所述目标端地址的通信连接； 利用所述数据同步模块从数据提供侧的源数据库中获取待同步数据； 利用所述数据同步模块将所述待同步数据写入中继缓存后向所述目标端地址发送， 以 由所述数据同步侧执 行数据同步任务。 7.根据权利要求6所述的方法， 其特 征在， 进一 步包括： 当所述当前同步任务管理模块不是本区域的同步任务管理模块 时， 利用所述当前同步 任务管理模块， 将所述数据同步任务分发至其他区域， 以由对应该数据同步任务的目标区 域完成该同步任务。 8.根据权利要求6所述的方法， 其特征在于， 所述利用所述当前同步任务管理模块确定 所述租户对应的目标 数据同步实例， 包括： 利用所述当前同步任务管理模块根据 所述数据同步任务， 查看所述租户的数据同步实 例资源池的空闲实例列表中是否有空 闲实例； 若所述数据同步实例资源池中具有空闲实例， 则利用所述当前同步任务管理模块查看 该空闲实例的规格是否满足预设要求； 若所述空闲实例的规格满足预设要求， 则利用所述当前同步任务管理模块将所述空闲 实例确定为目标 数据同步实例； 若所述数据同步实例资源池中不具有空闲实例， 或所述数据同步实例资源池中的空闲 实例的规格不满足预设要求， 则利用所述当前同步任务管理模块根据所述数据同步任务所 需要的规格创建一个新 实例， 并将该新实例确定为目标数据同步 实例； 其中， 所述规格包括 带宽和存 储空间中的至少一个。 9.根据权利要求6所述的方法， 其特 征在于， 进一 步包括： 利用所述当前同步任务管理模块监 听所述数据同步任务的运行进度， 并对全局事务号 进行存储； 在所述数据同步任务重启后， 利用所述当前同步任务管理模块查询所述数据同步任务 终止前最后保存的所述全局事务号， 以恢复所述数据同步任务终止前的同步进度； 其中， 所 述全局事务 号用于记录任务的执 行进度。 10.根据权利要求6至9中任一所述的方法， 其特征在于， 在利用数据同步模块在接收到 所述当前同步任务管理模块下发的数据同步任务后， 进一 步包括： 利用所述数据同步模块对数据提供侧和数据同步侧的配置进行预检查， 并在检查通过 后执行同步任务； 其中， 所述配置的项目包括如下中的至少一个： 数据提供侧和数据同步侧的数据库实例是否连通、 数据提供侧和数据同步侧的实例权 限、 以及数据提供侧和数据同步侧的全局事务号是否开启； 其中， 所述全局事务号用于记录 任务的执 行进度。权　利　要　求　书 2/2 页 3 CN 115484274 A 3