(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210841476.2 (22)申请日 2022.07.18 (65)同一申请的已公布的文献号 申请公布号 CN 114911872 A (43)申请公布日 2022.08.16 (73)专利权人 北京智芯微电子科技有限公司 地址 100192 北京市海淀区西小口路6 6号 中关村东升科技园A区3号楼 专利权人 北京智芯 半导体科技有限公司 (72)发明人 隋永鑫　冯鹏洲　阎坤　潘雨　 李涛　刘国静　司运成　于秀丽　 (74)专利代理 机构 北京清亦华知识产权代理事 务所(普通 合伙) 11201 专利代理师 赵静(51)Int.Cl. G06F 16/27(2019.01) G06F 16/2455(2019.01) H04L 67/1095(2022.01) H04L 9/40(2022.01) 审查员 张慧娟 (54)发明名称 内外网数据同步方法、 装置、 系统、 外网服务 器及存储介质 (57)摘要 本发明公开了一种内外网数据同步方法、 装 置、 系统、 外网服务器及存储介质， 内外网之间通 过安全隔离装置进行隔离， 内外网数据同步方法 包括： 查询内网数据同步数据库， 获得内网数据 同步数据库中存储的待同步数据表， 其中， 待同 步数据表由内网数据监测组件通过监听内网业 务数据库的入库数据生成； 将待同步数据表中的 数据发布到消息队列； 对消息队列进行订阅和监 听， 以便根据消息类型将待同步数据表中的数据 同步到外网业务数据库。 根据本发 明的内外网数 据同步方法、 装置、 系统、 外网服务器及存储介 质， 能够实现内网业务数据库的数据与外网业务 数据库的数据的实时同步。 权利要求书2页 说明书12页 附图6页 CN 114911872 B 2022.12.27 CN 114911872 B 1.一种内外网数据同步方法， 其特征在于， 所述内外网之间通过安全隔离装置进行隔 离， 所述方法包括： 查询内网数据同步数据库， 获得所述内网数据同步数据库中存储的待 同步数据表， 其 中， 所述待同步数据表由内网数据监测组件通过监听内网业务数据库的入库数据生成； 其 中， 所述待同步数据 表包括SQL语句的类型、 SQL语句； 其中， 所述SQL语句的类型用于表 示对 内网业务数据库进行 数据同步或者对外网业 务数据库进行 数据同步； 将所述待 同步数据表中的数据发布到消息队列； 其中， 所述消息队列中的消息是基于 所述待同步数据表中的数据生成的； 其中， 所述消息队列中消息的消息内容包括消息类型、 所述SQL语句； 其中所述消息类型采用所述SQ L语句的类型； 对所述消息队列进行订 阅和监听， 以便根据消息类型将所述待同步数据表中的数据同 步到外网业务数据库； 其中， 所述根据消息类型将所述待同步数据表中的数据同步到外网 业务数据库， 包括： 根据所述消息类型、 所述待同步数据表中的SQL语句同步所述外网业务 数据库。 2.根据权利要求1所述的内外网数据同步方法， 其特征在于， 所述内网数据监测组件通 过监听内网业务系统数据变化时产生的第一数据库操作SQL语句， 并将所述第一数据库操 作SQL语句记录 到表名相匹配的待同步数据表中。 3.根据权利要求2所述的内外网数据同步方法， 其特征在于， 将所述待同步数据表中的 数据发布到消息队列， 包括： 按照表名为消息主题、 所述第一数据库操作SQL语句为消息内容发布消息到所述消息 队列， 其中， 所述消息类型根据内网确定 。 4.根据权利要求1 ‑3中任一项所述的内外网数据同步方法， 其特征在于， 在对所述消息 队列进行订阅和监听之前， 所述方法还 包括： 通过外网数据监测组件监 听所述外网业务数据库的入库 数据， 以将外网业务系统数据 变化时产生的第二数据库操作SQ L语句发布到所述消息队列。 5.根据权利要求4所述的内外网数据同步方法， 其特征在于， 将外网业务系统数据变化 时产生的第二数据库操作SQ L语句发布到所述消息队列， 包括： 按照表名为消息主题、 所述第二数据库操作SQL语句为消息内容发布消息到所述消息 队列， 其中， 所述消息类型根据外网确定 。 6.根据权利要求5所述的内外网数据同步方法， 其特征在于， 在对所述消息队列进行订 阅和监听之后， 所述方法还 包括： 根据所述消息类型将所述第 二数据库操作SQL语句发送给所述内网业务数据库进行同 步。 7.根据权利要求6所述的内外网数据同步方法， 其特征在于， 在对所述消息队列进行监 听时， 所述方法还 包括： 将以表名为所述消息主题的消息按消息末尾的时间字符串 进行排序。 8.一种计算机可读存储介质， 其特征在于， 其上存储有内外网数据同步程序， 该内外网 数据同步 程序被处 理器执行时实现权利要求1 ‑7中任一项所述的内外网数据同步方法。 9.一种外网服务器， 其特征在于， 包括存储器、 处理器及存储在存储器上并可在处理器 上运行的内外网数据同步程序， 所述处理器执行所述内外网数据同步程序时， 实现权利要权　利　要　求　书 1/2 页 2 CN 114911872 B 2求1‑7中任一项所述的内外网数据同步方法。 10.一种内外网数据同步装置， 其特 征在于， 包括： 查询模块， 用于查询内网数据同步数据库， 获得所述内网数据同步数据库中存储的待 同步数据表， 其中， 所述待同步数据表由内网数据监测组件通过监听内网业务数据库的入 库数据生成； 第一发布模块， 用于将所述待同步数据表中的数据发布到消息队列； 第一同步模块， 用于对所述消息队列进行订阅和监听， 以便根据消息类型将所述待 同 步数据表中的数据同步到 外网业务数据库。 11.一种内外网数据同步系统， 其特征在于， 所述内外网之间通过安全隔离装置进行隔 离， 所述系统包括： 内网数据监测组件， 用于通过监 听内网业务数据库的入库数据， 以生成待同步数据表， 并将所述待同步数据 表存储到内网数据同步数据库； 其中， 所述待同步数据 表包括SQL语句 的类型、 SQL语句； 其中， 所述SQL语句的类型用于表示对内网业务数据库进 行数据同步 或者 对外网业 务数据库进行 数据同步； 数据同步组件， 用于查询所述内网数据同步数据库， 获得所述内网数据同步数据库中 存储的待同步数据表， 并将所述待同步数据表中的数据发布到消息队列， 以及对所述消息 队列进行订阅和监听， 以便根据消息类型将所述待同步数据 表中的数据同步到外网业务数 据库； 其中， 所述消息队列中的消息是基于所述待同步数据表中的数据生成的； 其中， 所述 消息队列中消息的消息内容包括消息类型、 所述SQL语句； 其中所述消息类型采用所述SQL 语句的类型； 其中， 所述根据消息类型将所述待同步数据表中的数据同步到外网业务数据 库， 包括： 根据所述消息类型、 所述待同步数据表中的SQ L语句同步所述外网业 务数据库。 12.根据权利要求11所述的内外网数据同步系统， 其特征在于， 所述内网数据监测组件 通过监听内网业务系统数据变化时产生的第一数据库操作SQL语句， 并将所述第一数据库 操作SQL语句记录 到表名相匹配的待同步数据表中。 13.根据权利要求12所述的内外网数据同步系统， 其特征在于， 所述数据同步组件还用 于， 按照表名为消息主题、 所述第一数据库操作SQL语句为消息内容 发布消息到所述消息队 列， 其中， 所述消息类型根据内网确定 。 14.根据权利要求1 1‑13中任一项所述的内外网数据同步系统， 其特 征在于， 还 包括： 外网数据监测 组件， 用于监听所述外网业务数据库的入库数据， 以将外网业务系统数 据变化时产生的第二数据库操作SQ L语句发布到所述消息队列。 15.根据权利要求14所述的内外网数据同步系统， 其特征在于， 所述外网数据监测组件 还用于， 按照表名为消息主题、 所述第二数据库操作SQL语句为消息内容 发布消息到所述消 息队列， 其中， 所述消息类型根据外网确定 。 16.根据权利要求15所述的内外网数据同步系统， 其特征在于， 所述数据同步组件还用 于， 根据所述消息类型将所述第二数据库操作SQL语句发送给所述内网业务数据库进行同 步。 17.根据权利要求16所述的内外网数据同步系统， 其特征在于， 所述数据同步组件还用 于， 在对所述消息队列进行监听时， 将以表名为所述消息主题的消息按消息末尾的时间字 符串进行排序。权　利　要　求　书 2/2 页 3 CN 114911872 B 3