(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210843643.7 (22)申请日 2022.07.18 (71)申请人 中国银联股份有限公司 地址 200135 上海市浦东 新区含笑路36号 (72)发明人 张晓宇　俞江烽　宋伟男　章澄　 佘明星　陈付强　查世政　杨晟　 肖家麟　 (74)专利代理 机构 北京同达信恒知识产权代理 有限公司 1 1291 专利代理师 彭燕 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/25(2019.01) G06F 9/54(2006.01) (54)发明名称 一种配置信息同步方法、 系统、 介质、 设备 (57)摘要 本申请提供一种配置信息同步方法、 系统、 介质、 设备， 涉及数据库技术领域。 其中方法包 括： 同步系统中的转换组件从配置源获取待同步 信息并将待同步信息进行转换处理后存储至消 息队列， 同步系统中的N个写入组件分别从消息 队列中获取转换后的待同步信息并写入各自对 应的N个目标端； N个目标端用于响应外部访问。 在上述方法中， 通过设置多个目标端可以使 得目 标端在响应外部访问时可以满足多种吞吐量的 要求， 在外部访问目标端需要更多的吞吐量时， 可以通过增加目标端的数量对目标端的进行扩 展， 使得目标端可 以支持更高的吞吐量要求； 对 应的， 在需要较少的吞吐量时， 可 以减少目标端 的数量。 实现了目标端的高扩 展性。 权利要求书3页 说明书10页 附图4页 CN 115168493 A 2022.10.11 CN 115168493 A 1.一种配置信息同步方法， 其特 征在于， 所述方法包括： 同步系统中的转换组件从配置源获取待同步信息并将所述待同步信息进行转换处理 后存储至消息队列， 所述 转换处理用于使得 所述待同步信息符合目标端的使用要求； 所述同步系统中的N个写入组件分别从所述消息队列中获取转换后的待同步信 息并写 入各自对应的N个目标端； 所述 N个目标端用于响应外 部访问。 2.如权利要求1所述的方法， 其特 征在于， 所述转换组件中设置有第一控制线程、 第一增量线程和第一全量线程； 所述写入组件 中设置有第二控制线程、 第二增量线程和第二全量线程； 同步系统中的转换组件从配置源获取待同步信息并将所述待同步信息进行转换处理 后存储至消息队列， 包括： 所述转换组件基于所述第一控制线程， 启动所述第一增量线程或所述第一全量线程， 并将启动结果同步至所述 N个写入组件各自的第二控制线程； 基于所述第一增量线程从配置源获取前一全量周期后新增的待同步信息并将所述待 同步信息进行转换 处理后存储至增量消息队列； 基于所述第一全量线程从所述配置源获取 全量周期期间新增的各待同步信息并将所述各待同步信息进行转换处理后存储至全量消 息队列； 所述同步系统中的N个写入组件分别从所述消息队列中获取转换后的待同步信 息并写 入各自对应的N个目标端， 包括： 针对任一写入组件， 所述写入组件基于所述第二控制线程获取的所述启动结果， 启动 所述第二增量线程或所述第二全量线程； 基于所述第二增量线程从所述增量消息队列中获取转换后的待同步信息并写入对应 的目标端； 基于所述第二全量线程从所述全量消息队列中获取转换后的待同步信息并写入 对应的目标端。 3.如权利要求2所述的方法， 其特 征在于， 所述方法还 包括： 所述转换组件基于所述第 一控制线程， 在任一全量周期到达时生成全量周期对应的批 次号并将所述批次号同步至所述第二控制线程； 将所述待同步信息进行转换处 理后存储至增量消息队列， 包括： 所述转换组件基于所述第一增量线程将所述待同步信息进行转换处理并添加所述批 次号后存 储至增量消息队列； 将所述各待同步信息进行转换处 理后存储至全量消息队列， 包括： 所述转换组件基于所述第一全量线程将所述待同步信息进行转换处理并添加所述批 次号后存 储至全量消息队列； 基于所述第 二增量线程从所述增量消息队列中获取转换后的待同步信 息之后， 写入对 应的目标端之前， 还 包括： 基于所述第二增量线程确定转换后的待同步信息的批次号与从所述第二控制线程获 取的批次号相同； 基于所述第 二全量线程从所述全量消息队列中获取转换后的待同步信 息之后， 写入对 应的目标端之前， 还 包括： 基于所述第二全量线程确定转换后的待同步信息的批次号与从所述第二控制线程获权　利　要　求　书 1/3 页 2 CN 115168493 A 2取的批次号相同。 4.如权利要求3所述的方法， 其特 征在于， 所述方法还 包括： 若基于所述第二增量线程确定转换后的待同步信息的批次号与从所述第二控制线程 获取的批次号 不相同， 则丢弃 所述转换后的待同步信息 。 5.如权利要求3所述的方法， 其特 征在于， 所述方法还 包括： 若基于所述第二全量线程确定转换后的待同步信息的批次号与从所述第二控制线程 获取的批次号 不相同， 则丢弃 所述转换后的待同步信息 。 6.如权利要求2所述的方法， 其特 征在于， 所述方法还 包括： 所述转换组件基于所述第 一控制线程， 获取所述第 一增量线程或所述第 一全量线程执 行过程中的第一异常信息， 并将所述第一异常信息同步至所述第二控制线程； 所述写入组件基于所述第 二控制线程获得的所述第 一异常信 息， 停止所述第 二增量线 程或所述第二全量线程对待同步信息的写入操作。 7.如权利要求2所述的方法， 其特 征在于， 所述方法还 包括： 所述写入组件基于所述第 二控制线程， 获取所述第 二增量线程或所述第 二全量线程执 行过程中的第二异常信息； 所述写入组件基于所述第 二控制线程获得的所述第 二异常信 息， 停止所述第 二增量线 程或所述第二全量线程对待同步信息的写入操作。 8.如权利要求6或7所述的方法， 其特征在于， 停止所述第二增量线程对待 同步信息的 写入操作， 包括： 所述写入组件通过所述第二增量线程丢弃所述第一异常信息指示的待 同步信息， 和/ 或， 所述第二异常信息指示的待同步信息 。 9.如权利要求6或7所述的方法， 其特征在于， 停止所述第二全量线程对待 同步信息的 写入操作， 包括： 所述写入组件通过所述第 二全量线程丢弃所述第 一异常信 息和/或所述第 二异常信 息 指示的同一批次号的待同步信息， 并对已写入目标端的同一批次号的待同步信息进行回滚 操作。 10.如权利要求6或7 所述的方法， 其特 征在于， 所述方法还 包括： 所述第一控制线程 通过信号控制队列 与所述第二控制线程进行信息同步。 11.一种配置信息同步系统， 其特征在于， 所述系统包括： 转换组件、 消息队列和N个写 入组件； 所述转换组件， 用于从配置源获取待同步信 息并将所述待同步信 息进行转换处理后存 储至消息队列， 所述 转换处理用于使得 所述待同步信息符合目标端的使用要求； 所述消息队列， 用于存 储转换处 理后的待同步信息； 所述N个写入组件， 用于分别从所述消息队列中获取转换后的待 同步信息并写入各自 对应的N个目标端； 所述 N个目标端用于响应外 部访问。 12.如权利要求11所述的系统， 其特征在于， 所述转换组件中设置有第一控制线程、 第 一增量线程和第一全量线程； 所述写入组件中设置有第二控制线程、 第二增 量线程和第二 全量线程； 所述消息队列包括增量消息队列和全量消息队列； 所述第一控制线程， 用于启动所述第一增量线程或所述第一全量线程， 并将启动结果权　利　要　求　书 2/3 页 3 CN 115168493 A 3