(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211020691.2 (22)申请日 2022.08.24 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 田利利　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 丁曼曼 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/25(2019.01) G06F 16/27(2019.01) (54)发明名称 一种数据同步方法及装置 (57)摘要 本申请公开了一种数据同步方法及装置， 可 应用于人工智能领域以及金融领域， 该方法获取 到数据更新请求后， 确定数据更新请求中的待更 新对象是否在配置文件中， 以确定是否需要执行 双写。 在确定需要执行双写时， 将数据更新请求 发送至异步双写中间件， 异步双 写中间件将数据 更新请求分发至其他数据中心的异步双写中间 件， 并调用各自对应的数据接口服务来对数据更 新请求进行解析， 将解析结果发送至各自对应的 数据库， 使得数据库执行数据更新。 由于各个数 据中心的数据库均响应同一数据更新请求， 因此 保证了数据库内数据的同步。 使得不具备软件复 制功能的数据库也可以保持各个数据库内数据 的一致性， 不受数据库类型的限制， 提高了方法 的适用性。 权利要求书2页 说明书9页 附图3页 CN 115391362 A 2022.11.25 CN 115391362 A 1.一种数据同步方法， 其特 征在于， 包括： 获取数据更新请求； 所述数据更新请求包括待更新对象以及更新操作； 确定所述待更新对象是否在预 先设置的配置文件中； 若所述待更新对象在预先设置的配置文件中， 则将所述数据更新请求发送至本数据中 心的异步双写中间件， 通过本数据中心的异 步双写中间件再将所述数据更新请求 发送至其 他数据中心的异步双写中间件； 其他数据中心的异步双写中间件将所述数据更新请求分发给各个数据中心的数据接 口服务； 各个所述数据接口服务对数据更新请求进行解析， 得到解析结果， 并将解析结果发送 至各自对应的数据库， 使得 数据库响应所述 解析结果以完成数据更新。 2.根据权利要求1所述的数据同步方法， 其特征在于， 所述数据 更新请求以报文的形式 发送至异步双写中间件并通过所述异步双写中间件分发至各个数据中心的数据接口服务， 则所述各个所述数据接口服务对数据更新请求进行解析， 得到解析结果， 并将解析结果发 送至各自对应的数据库， 使得 数据库响应所述 解析结果以完成数据更新， 包括： 各个所述数据接口服务接收到报文形式的数据更新请求后， 对报文形式的数据 更新请 求进行报文解析， 得到sql命令； 将所述sql命令发送至各自对应的数据库， 使得 数据库执 行所述sql命令 。 3.根据权利要求2所述的数据同步方法， 其特征在于， 所述各个所述数据接口服务对数 据更新请求进 行解析， 得到解析结果， 并将解析结果 发送至各自对应的数据库， 使 得数据库 响应所述 解析结果以完成数据更新， 之后还 包括： 数据库将执 行所述sql命令后的执 行结果反馈 至对应的数据接口服 务； 各个所述数据接口服务分别对各自接收到的所述执行结果打包生成结果报文， 并发送 至分发所述数据更新请求的异步双写中间件； 接收到结果报文的异步双写中间件， 对接收到的不同结果报文进行比对， 得到比对结 果； 并将所述比对结果通过连接的异步双写中间件发送至数据更新请求发送方， 以基于所 述比对结果确定是否 完成数据库的同步更新。 4.根据权利要求1 ‑3任意一项所述的数据同步方法， 其特征在于， 所述待更新对象包括 参数标识和应用标识， 所述配置文件中存 储所有的参数 标识； 则， 确定所述待更新对象是否在预 先设置的配置文件中， 包括： 将所述待更新对象的标识与所述配置文件中的所有参数 标识逐一比对； 若所述待更新对象的标识与 所述配置文件中的参数标识相同， 则确定所述待更新对象 在预先设置的配置文件中。 5.根据权利要求4所述的数据同步方法， 其特征在于， 所述更新操作包括： 增加、 删除、 修改。 6.一种数据同步装置， 其特 征在于， 包括： 获取单元， 用于获取 数据更新请求； 所述数据更新请求包括待更新对象以及更新操作； 确定单元， 用于确定所述待更新对象是否在预 先设置的配置文件中； 发送单元， 用于若所述待更新对象在预先设置的配置文件中， 则将所述数据更新请求 发送至本数据中心的异 步双写中间件， 通过本数据中心的异 步双写中间件 再将所述数据更权　利　要　求　书 1/2 页 2 CN 115391362 A 2新请求发送至其 他数据中心的异步双写中间件； 分发单元， 用于其他数据中心的异步双写中间件将所述数据更新请求分发给各个数据 中心的数据接口服 务； 解析单元， 用于各个所述数据接口服务对数据 更新请求进行解析， 得到解析结果， 并将 解析结果发送至各自对应的数据库， 使得 数据库响应所述 解析结果以完成数据更新。 7.根据权利要求6所述的数据同步装置， 其特征在于， 所述数据 更新请求以报文的形式 发送至异步双写中间件并通过所述异步双写中间件分发至各个数据中心的数据接口服务， 则所述解析单元， 具体用于： 各个所述数据接口服务接收到报文形式的数据更新请求后， 对报文形式的数据 更新请 求进行报文解析， 得到 sql命令； 将所述s ql命令发送至各自对应的数据库， 使 得数据库执行 所述sql命令 。 8.根据权利要求7 所述的数据同步装置， 其特 征在于， 还 包括： 反馈单元， 用于数据库将执行所述sql命令后的执行结果反馈至对应的数据接口服务； 各个所述数据接口服务分别对各自接收到的所述执行结果打包生成结果报文， 并发送至分 发所述数据更新请求的异步双写中间件； 接 收到结果报文的异步双写中间件， 对接 收到的 不同结果报文进行比对， 得到比对结果； 并将所述比对结果通过连接的异步双写中间件发 送至数据更新请求发送方， 以基于所述比对结果确定是否 完成数据库的同步更新。 9.根据权利要求6 ‑8任意一项所述的数据同步装置， 其特征在于， 所述待更新对象包括 参数标识和应用标识， 所述配置文件中存 储所有的参数 标识； 则， 所述确定单 元具体用于： 将所述待更新对象的标识与 所述配置文件中的所有参数标识逐一比对； 若所述待更新 对象的标识与所述配置文件中的参数标识相同， 则确定所述待更新对象在预先设置的配置 文件中。 10.根据权利要求9所述的数据同步装置， 其特征在于， 所述更新操作包括： 增加、 删除、 修改。权　利　要　求　书 2/2 页 3 CN 115391362 A 3