(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211130739.5 (22)申请日 2022.09.16 (71)申请人 浪潮卓数 大数据产业发展 有限公司 地址 214002 江苏省无锡市无锡经济开发 区金融一街15号1101、 1102、 1103、 1104、 1105、 1106、 1107、 1108 (72)发明人 赵海兴　李捷明　罗超　荀海峰　 (74)专利代理 机构 北京君慧知识产权代理事务 所(普通合伙) 11716 专利代理师 肖鹏 (51)Int.Cl. G06F 16/27(2019.01) G06F 9/54(2006.01) (54)发明名称 一种多数据源台账数据的同步方法、 设备及 介质 (57)摘要 本申请公开了一种多数据源台账数据的同 步方法、 设备及介质， 用以解决现有的台账系统 的多个数据库之间的数据无法实时同步的技术 问题。 方法包括： 通过数据监听服务对台账系统 中的所有数据库进行实时监听， 以确定待同步数 据； 将所述待同步数据发送至消息队列中； 通过 数据转换服务接收所述消息队列传输的所述待 同步数据， 并对所述待同步数据进行处理； 将处 理后的所述待同步数据分发至待同步数据库。 本 申请通过上述方法实现了台账系统多个数据库 的数据实时同步。 权利要求书1页 说明书4页 附图2页 CN 115455118 A 2022.12.09 CN 115455118 A 1.一种多数据源台账 数据的同步方法， 其特 征在于， 所述方法包括： 通过数据监听服 务对台账系统中的所有数据库进行实时监听， 以确定待同步数据； 将所述待同步数据发送至消息队列中； 通过数据转换服务接收所述消息队列传输的所述待同步数据， 并对所述待同步数据进 行处理； 将处理后的所述待同步数据分发至待同步数据库。 2.根据权利要求1所述的一种 多数据源台账数据的同步方法， 其特征在于， 将所述待同 步数据发送至消息队列中， 具体包括： 将所述待同步数据的关键信息发送至消息队列中。 3.根据权利要求2所述的一种 多数据源台账数据的同步方法， 其特征在于， 所述关键信 息至少包括以下任一项或者多项： 数据 表名、 数据变动方式、 待同步数据库类型以及数据源 库类型； 所述数据变动方式至少包括以下任一项或者多 项： 增加数据、 删除数据以及更新数据。 4.根据权利要求1所述的一种 多数据源台账数据的同步方法， 其特征在于， 将所述待同 步数据发送至消息队列中之后， 所述方法还 包括： 建立java数据转换服 务。 5.根据权利要求4所述的一种多数据源台账数据的同步方法， 其特征在于， 所述java数 据转换服 务向上对接所述消息队列， 向下对接所述台账系统中的所有数据库。 6.根据权利要求1所述的一种 多数据源台账数据的同步方法， 其特征在于， 对所述待同 步数据进行处 理， 具体包括： 确定所述待同步数据对应的待同步数据库类型； 根据所述待同步数据库类型对所述待同步数据进行封装处 理； 将封装处 理后的所述待同步数据分发至待同步数据库。 7.根据权利要求6所述的一种 多数据源台账数据的同步方法， 其特征在于， 在确定所述 待同步数据对应的待同步数据库类型之前， 所述方法还 包括： 确定所述待同步数据对应的数据变动方式； 根据所述数据变动方式生成变动数据。 8.根据权利要求7所述的一种 多数据源台账数据的同步方法， 其特征在于， 将封装处理 后的所述待同步数据分发至待同步数据库， 具体包括： 将封装处 理后的所述变动数据分发至所述待同步数据库的相应库表中。 9.一种多数据源台账 数据的同步设备， 其特 征在于， 所述设备包括： 处理器； 以及， 存储器， 其上存储有可执行指令， 当所述可执行指令被执行时， 使得所述处理器执行如 权利要求1 ‑8任一项所述的一种多数据源台账 数据的同步方法。 10.一种非易失性计算机存储介质， 存储有计算机可执行指令， 其特征在于， 所述计算 机可执行指令设置为执行如权利要求1 ‑8任一项所述的一种多数据源台账数据的同步方 法。权　利　要　求　书 1/1 页 2 CN 115455118 A 2一种多数据源台账数据的同步方 法、 设备及介质 技术领域 [0001]本申请涉及软件开发技术领域， 尤其涉及一种多数据源台账数据的同步方法、 设 备及介质。 背景技术 [0002]台账系统由于不同的使用场景， 导致涉及的数据库类型较多， 例如： 为了快速搜索 使用了ElasticSearch数据库、 为了展示台账关系又使用了neo4j数据库、 普通的业务又使 用了mysql数据库或者postgresql数据库等。 [0003]台账系统使用的多种数据库， 如果其中一个数据库 中的数据发生了变化， 那么其 他一些需要使用变化数据的多个库， 就无法实现数据同步， 导致这些数据库共同使用的数 据无法同步、 数据不全的问题出现。 发明内容 [0004]本申请实施例提供了一种多数据源台账数据的同步方法、 设备及介质， 用以解决 现有的台账系统的多个数据库之间的数据无法实时同步的技 术问题。 [0005]第一方面， 本申请实施例提供了一种多数据源台账数据的同步方法， 所述方法包 括： 通过数据监听服务对台账系统中的所有 数据库进 行实时监听， 以确定待同步数据； 将所 述待同步数据发送至消息队列中； 通过数据转换服务接收所述消息队列传输的所述待同步 数据， 并对所述待同步数据进行处 理； 将处理后的所述待同步数据分发至待同步数据库。 [0006]在本申请说明书的一个或多个实施例中， 将所述待同步数据发送至消息队列 中， 具体包括： 将所述待同步数据的关键信息发送至消息队列中。 [0007]在本申请说明书的一个或多个实施例中， 所述关键信息至少包括以下任一项或者 多项： 数据表名、 数据变动方式、 待同步数据库类型以及数据源库类型； 所述数据变动方式 至少包括以下任一项或者多 项： 增加数据、 删除数据以及更新数据。 [0008]在本申请说明书的一个或多个实施例中， 将所述待同步数据发送至消息队列中之 后， 所述方法还 包括： 建立java数据转换服 务。 [0009]在本申请说明书的一个或多个实施例中， 所述java数据转换服务向上对接所述消 息队列， 向下对接所述台账系统中的所有数据库。 [0010]在本申请说明书的一个或多个实施例中， 对所述待同步数据进行处理， 具体包括： 确定所述待同步数据对应的待同步数据库类型； 根据所述待同步数据库类型对所述待同步 数据进行封装处 理； 将封装处 理后的所述待同步数据分发至待同步数据库。 [0011]在本申请说明书的一个或多个实施例中， 在确定所述待同步数据对应的待同步数 据库类型之前， 所述方法还包括： 确定所述待同步数据对应的数据变动方式； 根据所述数据 变动方式生成变动数据。 [0012]在本申请说明书的一个或多个实施例中， 将封装处理后的所述待同步数据分发至 待同步数据库， 具体包括： 将封装处理后的所述变动数据分发至所述待同步数据库的相应说　明　书 1/4 页 3 CN 115455118 A 3