(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211119088.X (22)申请日 2022.09.13 (71)申请人 中国建设银行股份有限公司 地址 100033 北京市西城区金融大街25号 申请人 建信金融科技有限责任公司 (72)发明人 申冠豪　李彬　李卓　张佶　 (74)专利代理 机构 北京同立钧成知识产权代理 有限公司 1 1205 专利代理师 孟凡林　刘芳 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/54(2006.01) G06F 16/27(2019.01) G06Q 40/04(2012.01) (54)发明名称 数据处理方法和设备 (57)摘要 本申请提供一种数据处理方法和设备， 涉及 分布式数据处理技术领域。 在交易系统发起交易 订单时， 生成交易订单对应的异步任务， 进而通 过守护线程从任务队列获取待处理异步任务， 并 采用分布式锁的方式处理待处理异步任务， 从而 完成对待处理异步任务对应交易订单的处理， 其 中， 任务队列包括每起交易订单对应的异步任 务。 生成每起交易订单对应的异步任务， 采用守 护线程处理每个待处理异步任务， 通过异步方式 和消息机制解决分布式场景下数据的一致性问 题。 同时， 异步方式解决了同步处理带来的相互 等待问题， 从而提高了交易系统吞吐率， 可以保 证交易处理性能。 并且， 分布式锁的使用可以解 决分布式场景 下的并发问题， 保证交易可靠性。 权利要求书2页 说明书9页 附图4页 CN 115437769 A 2022.12.06 CN 115437769 A 1.一种数据处 理方法， 其特 征在于， 包括： 在交易系统发起交易 订单时， 生成所述交易 订单对应的异步任务； 通过守护线程从任务队列获取待处理异步任务， 采用分布式锁的方式处理所述待处理 异步任务， 以完成对所述待处 理异步任务对应交易 订单的处 理； 其中， 所述任务队列包括每起交易 订单对应的异步任务。 2.根据权利要求1所述的数据处理方法， 其特征在于， 所述采用分布式锁的方式处理所 述待处理异步任务， 包括： 通过所述守护线程获取 所述待处 理异步任务对应的分布式锁； 在所述守护线程查询到所述分布式锁未被任一节点占用时， 采用反射机制处理所述待 处理异步任务。 3.根据权利要求2所述的数据处理方法， 其特征在于， 所述通过所述守护线程获取所述 待处理异步任务对应的分布式锁， 包括： 通过所述守护线程获取所述待处理异步任务的任务编 号， 将获取到的任务编号确定为 所述分布式锁。 4.根据权利要求2或3所述的数据处理方法， 其特征在于， 所述采用反射机制处理所述 待处理异步任务， 包括： 通过所述守护线程调用所述待处理异步任务对应的任务处理函数， 并利用所述任务处 理函数调用所述待处 理异步任务对应的交易处 理服务和交易 参数； 若调用所述交易处理服务未超时， 采用所述反射机制获取所述交易处理服务对应的目 标处理方法； 利用所述目标处 理方法和所述交易 参数处理所述待处 理异步任务对应的交易 订单。 5.根据权利要求4所述的数据处理方法， 其特征在于， 所述利用所述任务处理函数调用 所述待处 理异步任务对应的交易处 理服务和交易 参数， 包括： 利用所述任务处理函数解析所述待处理异步任务对应的任务包， 以调用所述待处理异 步任务对应的交易处 理服务和交易 参数。 6.根据权利要求4所述的数据处理方法， 其特征在于， 若调用所述交易处理服务超时， 将所述待处 理异步任务送回所述任务队列等待下次轮询。 7.根据权利要求1所述的数据处理方法， 其特征在于， 所述生成所述交易订单对应的异 步任务， 包括： 调用任务封装函数， 以利用所述任务封装函数生成所述交易 订单对应的异步任务。 8.根据权利要求1所述的数据处理方法， 其特征在于， 任务存储表存储于所述交易系统 的数据库中， 所述任务存储表用于记录所述每起交易订单对应的异步任务的参数数据， 所 述参数数据包括每个异 步任务的任务编号、 任务处理类和方法以及 全类地址、 交易参数、 任 务状态、 重试次数以及处 理时间中的一种或多种。 9.根据权利要求1所述的数据处理方法， 其特征在于， 所述守护线程对应有多个节点， 每个节点用于处 理所述待处 理异步任务对应的交易 订单。 10.一种数据处 理装置， 其特 征在于， 包括： 第一处理模块， 用于在交易系统发起交易 订单时， 生成所述交易 订单对应的异步任务； 第二处理模块， 用于通过守护线程从任务队列获取待处理异步任务， 采用分布式锁的权　利　要　求　书 1/2 页 2 CN 115437769 A 2方式处理所述待处 理异步任务， 以完成对所述待处 理异步任务对应交易 订单的处 理； 其中， 所述任务队列包括每起交易 订单对应的异步任务。 11.一种电子设备， 其特 征在于， 包括： 处 理器， 以及与所述处 理器通信连接的存 储器； 所述存储器存储计算机执 行指令； 所述处理器执行所述存储器存储的计算机执行指令， 以实现如权利要求1至9任一项所 述的数据处 理方法。 12.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质中存储有计算机 执行指令， 所述计算机执行指 令被处理器执行时用于实现如权利要求 1至9任一项 所述的数 据处理方法。 13.一种计算机程序产品， 包括计算机执行指令， 该计算机执行指令被处理器执行时用 于实现如权利要求1至9任一项所述的数据处 理方法。权　利　要　求　书 2/2 页 3 CN 115437769 A 3