(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210211572.9 (22)申请日 2022.03.04 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 姜俊秀　赵书祥　宋子晨　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 杨丹　沈珍珠 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 数据双写方法及装置 (57)摘要 本发明提供了一种数据双 写方法及装置， 适 用于大数据技术领域， 该方法包括： 在接收到写 请求后， 将数据写入单元数据库， 将写入的数据 的状态标记 为待同步； 在接收到单元数据库反馈 的写入成功通知后， 将数据的关系数据写入网关 路由信息缓存； 在接收到网关路由信息缓存反馈 的写入成功通知后， 将关系数据写入网关路由信 息表， 且不等待网关路由信息数据库反馈； 通过 异步进程查询单元数据库中状态为待同步的数 据对应的关系数据是否在网关路由信息表中写 成功； 若写成功， 更新单元数据库中数据的状态； 若未写成功， 将关系数据补 充写入网关路由信息 表， 在补充写成功时， 更新单元数据库中数据的 状态。 本发明可以提高数据双写的效率和成功 率。 权利要求书2页 说明书7页 附图7页 CN 114595237 A 2022.06.07 CN 114595237 A 1.一种数据双写方法， 其特 征在于， 包括： 在接收到写请求后， 将数据写入单 元数据库， 将写入的数据的状态标记为待同步； 在接收到单元数据库反馈的写入成功通知后， 将数据的关系数据写入 网关路由信 息缓 存； 在接收到网关路由信 息缓存反馈的写入成功通知后， 将数据的关系数据写入 网关路由 信息数据库中的网关路由信息表， 且不 等待网关路由信息数据库反馈； 通过异步进程查询单元数据库中状态为待同步的数据对应的关系数据是否在网关路 由信息表中写成功； 若写成功， 更新单 元数据库中数据的状态为已更新； 若未写成功， 将数据的关系数据补充写入网关路由信息表， 在补充写成功时， 更新单元 数据库中数据的状态为已更新。 2.如权利要求1所述的方法， 其特征在于， 通过异步进程查询单元数据库中状态为待同 步的数据对应的关系数据是否在网关路由信息表中写成功， 包括： 轮询提取 单元数据库中状态为待同步的数据的键值； 通过键值 查询对应的关系数据在网关路由信息表是否写成功。 3.如权利要求1所述的方法， 其特 征在于， 还 包括： 在接收到删除请求后， 将删除请求中的数据在网关路由信 息表对应的关系数据打标为 不使用， 且不在网关路由信息数据库中进行删除。 4.如权利要求1所述的方法， 其特 征在于， 还 包括： 在接收到读请求时， 读取读请求中的数据在网关路由信息缓存中对应的关系数据， 若 网关路由信息缓存中没有所述对应的关系 数据， 读取网关路由信息表， 并将网关路由信息 表所述对应的关系数据放入网关路由信息缓存； 在接收到更新请求时， 基于更新请求中的数据对应的关系数据的类型， 进行 更新操作。 5.如权利要求4所述的方法， 其特征在于， 基于更新请求中的数据对应的关系数据的类 型， 进行更新操作， 包括： 若网关路由信 息缓存中存储的关系数据满足第 一条件， 基于更新请求中的数据对应的 关系数据， 更新网关路由信息缓存， 然后更新网关路由信息表； 所述第一条件为关系数据为 键值与数据值结构， 且在预设时长内收到的读请求的数量大于第一阈值， 且在预设时长内 收到的更新请求的数量小于第二阈值： 若网关路由信 息缓存中存储的关系数据满足第 二条件， 删除网关路由信 息缓存中更新 请求中的数据对应的关系 数据的历史数据， 基于更新请求中的数据对应的关系数据， 更新 网关路由信息表； 所述第二条件在预设时长内收到的更新请求的数量大于第三阈值。 6.如权利要求 4所述的方法， 其特 征在于， 还 包括： 若网关路由信 息缓存中存储的关系数据满足第 二条件， 将接收到的读请求与 更新请求 串行执行。 7.一种数据双写装置， 其特 征在于， 包括： 写入单元数据库模块， 用于在接收到写请求后， 将数据写入单元数据库， 将写入的数据 的状态标记为待同步； 写入缓存模块， 用于在接收到单元数据库反馈的写入成功通知后， 将数据的关系数据权　利　要　求　书 1/2 页 2 CN 114595237 A 2写入网关路由信息缓存； 写入网关路由信 息数据库模块， 用于在接收到网关路由信 息缓存反馈的写入成功通知 后， 将数据的关系 数据写入网关路由信息数据库中的网关路由信息表， 且不等待网关路由 信息数据库反馈； 数据写成功查询模块， 用于通过异步进程查询单元数据库中状态为待同步的数据对应 的关系数据是否在 网关路由信息表中写成功； 若写成功， 更新单元数据库中数据的状态为 已更新； 若未写成功， 将数据的关系数据补充写入网关路由信息表， 在补充写成功 时， 更新 单元数据库中数据的状态为已更新。 8.如权利要求7 所述的装置， 其特 征在于， 数据写成功查询模块具体用于： 轮询提取 单元数据库中状态为待同步的数据的键值； 通过键值 查询对应的关系数据在网关路由信息表是否写成功。 9.如权利要求7 所述的装置， 其特 征在于， 还 包括请求处 理模块， 用于： 在接收到删除请求后， 将删除请求中的数据在网关路由信 息表对应的关系数据打标为 不使用， 且不在网关路由信息数据库中进行删除。 10.如权利要求9所述的装置， 其特 征在于， 请求处 理模块还用于： 在接收到读请求时， 读取读请求中的数据在网关路由信息缓存中对应的关系数据， 若 网关路由信息缓存中没有所述对应的关系 数据， 读取网关路由信息表， 并将网关路由信息 表所述对应的关系数据放入网关路由信息缓存； 在接收到更新请求时， 基于更新请求中的数据对应的关系数据的类型， 进行 更新操作。 11.如权利要求10所述的装置， 其特 征在于， 请求处 理模块还用于： 若网关路由信 息缓存中存储的关系数据满足第 一条件， 基于更新请求中的数据对应的 关系数据， 更新网关路由信息缓存， 然后更新网关路由信息表； 所述第一条件为关系数据为 键值与数据值结构， 且在预设时长内收到的读请求的数量大于第一阈值， 且在预设时长内 收到的更新请求的数量小于第二阈值： 若网关路由信 息缓存中存储的关系数据满足第 二条件， 删除网关路由信 息缓存中更新 请求中的数据对应的关系 数据的历史数据， 基于更新请求中的数据对应的关系数据， 更新 网关路由信息表； 所述第二条件在预设时长内收到的更新请求的数量大于第三阈值。 12.如权利要求10所述的装置， 其特 征在于， 请求处 理模块还用于： 若网关路由信 息缓存中存储的关系数据满足第 二条件， 将接收到的读请求与 更新请求 串行执行。 13.一种计算机设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计 算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求1至6任一所述方 法。 14.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机程 序， 所述计算机程序被处 理器执行时实现权利要求1至 6任一所述方法。 15.一种计算机程序产品， 其特征在于， 所述计算机程序产品包括计算机程序， 所述计 算机程序被处 理器执行时实现权利要求1至 6任一所述方法。权　利　要　求　书 2/2 页 3 CN 114595237 A 3