(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211128721.1 (22)申请日 2022.09.16 (71)申请人 上海浦东发展银行股份有限公司 地址 200001 上海市黄浦区中山 东一路12 号 (72)发明人 司梦柯　邓仁伟　林明宇　 (74)专利代理 机构 华进联合专利商标代理有限 公司 44224 专利代理师 黄丽霞 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/23(2019.01) (54)发明名称 业务信息同步方法、 装置、 计算机设备和存 储介质 (57)摘要 本申请涉及一种业务信息同步方法、 装置、 计算机设备和存储介质。 所述方法包括： 获取数 据库从节 点已提交事务的日志； 日志记载有数据 库主节点实时同步至数据库从节点过程中已提 交的事务标记信息和所有库表变动记录信息； 将 数据库从节 点的日志拆解 成多个日志片段， 提取 日志片段的库表 变动记录信息， 根据预先建立的 库表和业务字段映射关系， 将日志片段的每条库 表变动记录信息转换为业务报文； 将各事务标记 信息对应的所有库表变动记录信息对应的业务 报文打包成标准的业务报文数 组， 并将整合后的 业务报文数 组实时地推送给多个目标系统。 采用 本方法能够在不改造核心系统结构的前提下， 提 高同步时效并使目标系统实时感知核心系统的 表结构变动。 权利要求书2页 说明书16页 附图6页 CN 115481195 A 2022.12.16 CN 115481195 A 1.一种业 务信息同步方法， 其特 征在于， 所述方法包括： 获取数据库从节点已提交事务的日志； 所述日志记载有数据库主节点实时同步至数据 库从节点过程中已提交的事务标记信息和所有库表变动记录信息； 将数据库从节点的日志拆解成多个日志片段， 提取日志片段的库表变动记录信息， 根 据预先建立的库 表和业务字段映射关系， 将日志片段的每条库 表变动记录信息转换为业务 报文； 将各所述事务标记信息对应的所有库表变动记录信息对应的业务报文打包成标准的 业务报文数组， 并将整合后的业 务报文数组实时地推送给多个目标系统。 2.根据权利要求1所述的方法， 其特征在于， 所述将数据库从节点的日志拆解成多个日 志片段， 提取日志片段的库 表变动记录信息， 根据预先建立的库 表和业务字段映射关系， 将 日志片段的每条库表变动记录信息转换为 业务报文， 包括： 将数据库从节点的日志拆解成多个日志片段， 并采用事务标记和序号标记的双重标记 方式对日志片段进行 标记， 所属相同事务的日志片段的事务标记信息相同； 提取日志片段的业务字段， 并对库表记录信息中变化后的业务字段赋予字段值， 根据 所述字段值 为所述日志片段 标识变动标志； 根据预先建立的库表和业 务字段映射关系， 确定所述 业务字段对应的库表名称； 将日志片段的每条库表变动记录信 息转换为业务报文； 所述库表变动记录信 息包括所 述业务字段、 所述变动标志、 所述业务字段对应的库 表名称、 所述业务字段所属的事务标记 信息、 事务 提交时间和系列号。 3.根据权利要求2所述的方法， 其特 征在于， 所述 提取日志片段的业 务字段， 包括： 读取信号文件， 得到日志片段的事务标记信 息以及所述事务标记信 息对应的最大的序 号标记； 所述信号文件 存储有各事务标记信息以及事务标记信息对应的最大的序号标记； 根据所述事务标记信息对应的最大的序号标记， 确定抽数子进程的数量， 每个抽数子 进程读取多个日志片段； 各所述抽数子进程依次读取当前所属所述事务标记信 息的日志片段， 同时加载预先建 立的库表和业 务字段映射关系， 根据映射关系提取日志片段中库表的业 务字段。 4.根据权利要求1所述的方法， 其特征在于， 所述将各所述事务标记信 息对应的所有库 表变动记录信息对应的业务报文打包成标准的业务报文数组， 并将整合后的业务报文 数组 实时地推送给多个目标系统， 包括： 读取各事务标记信 息对应的所有库表变动记录信 息对应的业务报文， 并按照系列号排 序； 根据当前所述事务标记信息对应的库表的结构属性， 确定所述库表是否包括主键； 若 所述库表不包括主键， 则确定所述库 表中当前所述事务标记信息对应的所有库 表变动记录 信息对应的终态业 务报文； 提取所述终态业务报文的事务标记信息、 事务提交时间、 记录数和数组编号作为公共 信息头， 将所述终态业务报文中业务字段和变动标识作为数组的元素， 得到标准的业务报 文数组。 5.根据权利要求4所述的方法， 其特征在于， 所述读取同一事务标记信 息对应的所有库 表变动记录信息对应的业 务报文， 并按照系列号 排序， 包括：权　利　要　求　书 1/2 页 2 CN 115481195 A 2读取结果文件， 获得所有的事务标记信息以及各事务标记信息对应的库表种类数； 所 述结果文件 存储有所有的事务标记信息以及各事务标记信息对应的库表种类数； 根据当前的事务标记信息对应的库表种类数确定打包子进程的数量； 各所述打包子进程依次读取所属当前的事务标记信息对应的库表变动记录信息对应 的业务报文， 并按照系列号 排序。 6.根据权利要求4所述的方法， 其特征在于， 若所述库表包括主键， 则提取业务报文的 主键字段值和变动标识， 筛 选主键字段值不唯一的业 务报文， 得到主键值唯一的业 务报文； 确定所述库表的库表变动记录信 息对应的变动模式， 将所述变动模式与预设变动模式 进行匹配， 过滤掉所述库表的库表变动记录信息连续变动对应的业务报文， 取所述库表变 动记录信息最后一次变动时对应的业 务报文作为 最终态的业 务报文。 7.根据权利要求4所述的方法， 其特征在于， 若所述记录数超过预设值， 则将所述终态 业务报文整合成多个业 务报文数组， 并记录数据编号。 8.一种业 务信息同步装置， 其特 征在于， 所述装置包括： 获取模块， 用于获取数据库从节点已提交事务的日志； 日志记载有数据库主节点实时 同步至数据库从节点过程中已提交的事务标记信息和所有库表变动记录信息； 拆解模块， 用于将数据库从节点的日志拆解成多个日志片段， 提取日志片段的库表变 动记录信息， 根据预先建立的库表和业务字段映射关系， 将日志片段 的每条库表变动记录 信息转换为 业务报文； 推送模块， 用于将各事务标记信 息对应的所有库表变动记录信 息对应的业务报文打包 成标准的业 务报文数组， 并将整合后的业 务报文数组实时地推送给多个目标系统。 9.一种计算机设备， 包括存储器和处理器， 所述存储器存储有计算机程序， 其特征在 于， 所述处 理器执行所述计算机程序时实现权利要求1至7中任一项所述的方法的步骤。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1至7中任一项所述的方法的步骤。权　利　要　求　书 2/2 页 3 CN 115481195 A 3