(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210833695.6 (22)申请日 2022.07.14 (71)申请人 重庆医药 数据信息科技有限公司 地址 401336 重庆市南岸区南滨路132号 (72)发明人 魏然　罗成　张冰峰　黄煜楠　 (74)专利代理 机构 重庆市前沿专利事务所(普 通合伙) 50211 专利代理师 张青龙　肖秉城 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/22(2019.01) G06F 16/23(2019.01) G06F 16/2457(2019.01) (54)发明名称 一种基于双队列的数据同步方法和系统 (57)摘要 本发明公开一种基于双队列的数据 同步方 法和系统， 包括第一业务系统和第二业务系统， 还包括第一数据同步应用端和第二数据同步应 用端； 所述第一业务系统将变更数据的第一消息 发送到第一消息队列， 所述第一消息包括变更数 据对应的ID值和变更类型； 第一数据同步应用 端， 用于根据第一消息队列发送的第一消息查询 第一业务系统中的第一数据库以获取变更数据， 再将变更数据和第一消息转换成第二消息发送 到第二消息队列； 第二数据同步应用端， 用于对 第二消息队列发送的第二消息进行校验， 校验成 功后， 将变更数据同步到第二业务系统中的第二 数据库。 权利要求书2页 说明书7页 附图1页 CN 115269720 A 2022.11.01 CN 115269720 A 1.一种基于双队列的数据同步系统， 包括第 一业务系统和第 二业务系统， 其特征在于， 还包括第一数据同步应用端和第二数据同步应用端； 所述第一业务系统将变更数据的第 一消息发送到第 一消息队列， 所述第 一消息包括变 更数据对应的ID值和变更类型； 第一数据同步应用端， 用于根据第 一消息队列发送的第 一消息查询第 一业务系统中的 第一数据库以获取变更数据， 再将变更数据和 第一消息转换成第二消息发送到第二消息队 列； 第二数据同步应用端， 用于对第 二消息队列发送的第 二消息进行校验， 校验成功后， 将 变更数据同步到第二 业务系统中的第二数据库。 2.如权利要求1所述的一种基于双队列的数据同步系统， 其特征在于， 所述第 一业务系 统中内置有数据同步代理类， 用于实时捕捉第一数据库的数据变更， 输出变更数据对应的 ID值和变更类型到第一消息队列。 3.如权利要求2所述的一种基于双队列的数据同步系统， 其特征在于， 所述数据同步代 理类， 采用springAop切面代理技术， 在第一数据库增删改方法中添加注解， 通过解析注解 的值， 最后从解析 结果中通过Jdk的反射 技术获得变更 数据的ID值和变更类型。 4.如权利要求3所述的一种基于双队列的数据同步系统， 其特征在于， 所述注解包括队 列名称、 实体 类型、 ID的字段名称。 5.基于权利要求1 ‑4任一所述系统 的一种基于双队列的数据同步方法， 其特征在于， 包 括以下步骤： S1： 数据同步代理类使用sprin gAop切面代理技术， 在第一数据库增删改方法中添加注 解； 当第一数据库发生变化时， 捕捉变更数据， 并解析增删改方法上 的注解得到第一消息， 再输出第一消息 到第一消息队列， 第一消息包括变更 数据对应的ID和变更类型； S2： 第一数据同步应用端从第一消息队列中获取第一消息， 根据第一消息查询第一数 据库以获取变更 数据， 将变更 数据转换成第二消息， 发送第二消息 到第二消息队列； S3： 第二数据同步应用端从第二消息队列获取第二消息后， 进行校验， 校验成功后， 将 变更数据同步到第二 业务系统的第二数据库中。 6.如权利要求5所述的一种基于双队列的数据同步方法， 其特征在于， 所述S1具体包 括： S1‑1： 数据同步代理类使用sprin gAop切面代理技术， 在第一数据库的增删改方法中添 加注解， 所述注解包括定义队列名称、 实体 类型、 ID的字段名称； S1‑2： 当第一数据库增删改方法调用之后， 实时捕捉变更数据并解析注解的值， 最后从 解析结果中通过Jdk的反射 技术获得变更 数据的ID， 再将ID和实体 类型打包成第一消息； S1‑3： 以json的格式将第一消息发送到第一消息队列。 7.如权利要求5所述的一种基于双队列的数据同步方法， 其特征在于， 所述S2具体包 括： S2‑1： 订阅第一消息队列， 实时接收数据同步代理类 推送的第一消息； S2‑2： 根据第一消息直接在第一业务系统中的第一数据库查询实体表或联表关联查询 以获取变更 数据； S2‑3： 将变更 数据打包成第二消息， 推送到第二消息队列。权　利　要　求　书 1/2 页 2 CN 115269720 A 28.如权利要求5所述的一种基于双队列的数据同步方法， 其特征在于， 所述S3具体包 括： S3‑1： 订阅第二消息队列， 实时接收第一数据同步应用端推送的第二消息； S3‑2： 对第二消息进行校验， 校验通过后， 将变更数据同步到第二业务系统的第二数据 库。权　利　要　求　书 2/2 页 3 CN 115269720 A 3