(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211150626.1 (22)申请日 2022.09.21 (71)申请人 浙江省人力资源和社会保障信息中 心 地址 310000 浙江省杭州市体 育场路538号 金祝大厦 申请人 浙江浙大网新软件产业 集团有限公 司 (72)发明人 杨国蓉　黄益民　朱国耀　邵震洲　 姚迪　邓林　 (74)专利代理 机构 杭州五洲普华专利代理事务 所(特殊普通 合伙) 33260 专利代理师 姚宇吉 (51)Int.Cl. G06F 16/27(2019.01)G06F 16/22(2019.01) G06F 16/23(2019.01) (54)发明名称 一种数据同步方法、 系统、 电子设备及可存 储介质 (57)摘要 本发明涉及数据处理技术领域， 公开了一种 数据同步方法、 系统、 电子设备及可存储介质， 通 过日志分析器读取不同源数据库的redo日志并 得到json文件， 按照不同源数据库以及获取顺序 依次存入第一缓冲池的不同队列中， 再将按顺序 存储到rocketmq中间件中； 再通过写入器按 顺序 获取json文件， 将json文件同样依次存入到第二 缓冲池的不同队列中， 根据json文件得到对应不 同数据表名的SQL语句， 写入到相应数据表中。 解 决了当写入器发生异常时需要再重新从头开始 同步的问题， 而是使 得能够从中断的地方开始写 入， 提高同步效率， 并且通过增加缓冲池， 使得能 够按顺序记录不同数据库的变动， 并按照顺序写 入， 防止写 入错误。 权利要求书2页 说明书4页 附图1页 CN 115495521 A 2022.12.20 CN 115495521 A 1.一种数据同步方法， 其特 征在于， 包括以下步骤： 读取不同源数据库的redo日志并进行解析， 对解析出来的日志文件进行处理得到json 文件， 将json文件按照不同源数据库以及获取顺序依次存入第一缓冲池的不同队列中， 再 将所述jso n文件按顺序存 储到rocketmq中间件中； 按顺序获取所述rocketmq中间件中的json文件， 将json文件按照不同源数据库以及获 取顺序依次存入到第二缓冲池的不同队列中， 依次对所述json文件进行解析， 得到对应不 同数据表名的SQ L语句， 写入到与源数据库对应的目标 数据库的相应数据表中。 2.根据权利要求1所述的数据同步方法， 其特征在于， 在所述json文件按顺序存储到 rocketmq中间件的过程当中， 所述rocketmq中间件中每存入一个json文件， 都会自动匹配 一个唯一编码， 记录排列顺序并根据排列顺序依次获取所述rocketmq中间件中的json文 件。 3.根据权利 要求2所述的数据同步方法， 其特征在于， 在按顺序获取所述rocketmq中间 件中的json文件的过程中还包括： 当发生异常导致中断获取， 接收到重新获取指令后根据 排列顺序从中断的地方开始 依次获取 所述rocketmq中间件中的jso n文件。 4.根据权利要求1所述的数据同步方法， 其特征在于， 将json文件按照不同源数据库以 及获取顺序依 次存入第一缓冲池的不同队列中的过程中， 当与源数据库连接异常， 第一缓 冲池开启监听模式， 监听是否恢复正常连接， 如果正常， 继续存入， 如果不正常， 继续与其他 源数据库的存 入。 5.根据权利要求1所述的数据同步方法， 其特征在于， 将json文件按照不同源数据库以 及获取顺序依 次存入到第二缓冲池的不同队列中的过程中， 当与目标数据库连接异常， 第 二缓冲池开启监听模式， 监听是否恢复正常连接， 如果正常， 继续写入， 如果不正常， 继续与 其他目标数据库的写入。 6.一种数据同步系统， 其特 征在于， 包括： 日志分析器， 读取不同源数据库的redo日志并进行解析， 对解析出来的日志文件进行 处理得到json文件， 将json文件按照不同源数据库以及获取顺序 依次存入第一 缓冲池的不 同队列中， 再将所述jso n文件按顺序存 储到rocketmq中间件中； 写入器， 按顺序获取所述rocketmq中间件中的json文件， 将json文件按照不同源数据 库以及获取顺序依次存入到第二缓冲池的不同队列中， 依次对所述json文件进行解析， 得 到对应不同数据表名的SQ L语句， 写入到与源数据库对应的目标 数据库的相应数据表中。 7.根据权利要求6所述的数据同步系统， 其特征在于， 将json文件按照不同源数据库以 及获取顺序依 次存入第一缓冲池的不同队列中的过程中， 当与源数据库连接异常， 第一缓 冲池开启监听模式， 监听是否恢复正常连接， 如果正常， 继续存入， 如果不正常， 继续与其他 源数据库的存 入。 8.根据权利要求6所述的数据同步系统， 其特征在于， 将json文件按照不同源数据库以 及获取顺序依 次存入到第二缓冲池的不同队列中的过程中， 当与目标数据库连接异常， 第 二缓冲池开启监听模式， 监听是否恢复正常连接， 如果正常， 继续写入， 如果不正常， 继续与 其他目标数据库的写入。 9.一种电子设备， 其特征在于， 包括： 至少一个处理器， 与至少一个所述处理器通信连 接的存储器； 至少一个所述处理器用于读取所述存储器中的程序， 用于执行如权利要求 1‑5权　利　要　求　书 1/2 页 2 CN 115495521 A 2中任一项所述方法。 10.一种计算机可读存储介质， 其特征在于， 所述介质上存储有指令， 当所述指令在计 算机上运行时， 使得计算机执 行如权利要求1 ‑5任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115495521 A 3