(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210891887.2 (22)申请日 2022.07.27 (71)申请人 京东方科技 集团股份有限公司 地址 100015 北京市朝阳区酒仙桥路10号 (72)发明人 文晋晓　张宁　 (74)专利代理 机构 北京安信方达知识产权代理 有限公司 1 1262 专利代理师 解婷婷　曲鹏 (51)Int.Cl. G06F 9/54(2006.01) G06Q 10/06(2012.01) G06Q 10/08(2012.01) G06Q 50/04(2012.01) (54)发明名称 数据处理方法及装置、 存 储介质 (57)摘要 数据处理方法及装置、 存储介质， 所述数据 处理方法包括： 从调用方接收数据， 根据所述数 据生成第一消息发送至第一消息队列； 听所述第 一消息队列， 监听到所述第一消息队列中存在第 一消息后， 根据所述第一消息队列中的所述第一 消息获取所述数据， 根据所述数据进行预设处 理， 生成至少一种处理结果； 根据所述处理结果 生成结果消息发送至所述处理结果对应的结果 消息队列； 监听所述结果消息队列， 监听到所述 结果消息队列中存在结果消息后， 根据所述结果 消息队列的所述结果消息获取处理结果， 发送所 述处理结果至所述调用方。 本实施例提供的方 案， 可以实现异步处理， 减少处理时间， 且实现解 耦和限流削峰。 权利要求书3页 说明书21页 附图4页 CN 115220935 A 2022.10.21 CN 115220935 A 1.一种数据处 理方法， 其特 征在于， 包括： 从调用方接收数据， 根据所述数据生成第一消息发送至第一消息队列； 监听所述第一消息队列， 监听到所述第一消息队列中存在第一消息后， 根据所述第一 消息队列中的所述第一消息获取所述数据， 根据所述数据进行预设处理， 生成至少一种处 理结果， 根据所述处 理结果生成结果消息发送至所述处 理结果对应的结果消息队列； 监听所述结果消息队列， 监听到所述结果消息队列中存在结果消息后， 根据所述结果 消息队列的所述结果消息获取处 理结果， 发送所述处 理结果至所述调用方。 2.根据权利要求1所述的数据处理方法， 其特征在于， 一种处理结果对应一个结果消息 队列。 3.根据权利要求1所述的数据处理方法， 其特征在于， 所述第 一消息中包括所述数据的 存储路径； 所述结果消息中包括所述处 理结果的存 储路径。 4.根据权利要求1所述的数据处理方法， 其特征在于， 所述生成至少一种处理结果包 括： 生成概要结果数据和明细结果数据， 所述概要结果数据的数据量小于所述明细结果数 据的数据量； 所述结果消息队列包括第二消息队列和第三消息队列； 所述根据处理结果生成结果消息 至所述处 理结果对应的结果消息队列包括： 根据所述概要结果数据生成第二消息至第二消息队列， 以及， 根据所述明细结果数据 生成第三消息 至第三消息队列； 所述监听所述结果消息队列， 监听到所述结果消息队列中存在结果消息后， 根据所述 结果消息队列的所述结果消息获取处 理结果， 发送所述处 理结果至所述调用方包括： 监听所述第二消息队列， 监听到所述第二消息队列中存在第二消息后， 根据所述第二 消息队列中的所述第二消息获取概要结果数据， 发送所述 概要结果数据至所述调用方； 以及， 监听所述第三消息队列， 监 听到所述第 三消息队列中存在第三消息后， 根据第三 消息队列中的所述第三消息获取明细结果数据， 发送所述明细结果数据至所述调用方。 5.根据权利要求4所述的数据处理方法， 其特征在于， 所述数据包括产品需求信 息和相 关物料信息； 所述概要结果数据包括以下至少之一： 所述产品的齐套数量、 所述产品的需求数量与 所述齐套数量之间差缺的数量； 所述明细结果数据包括： 所述产品的可能的物料配方。 6.根据权利要求1所述的数据处 理方法， 其特 征在于， 所述从调用方接收数据包括： 从所述调用方接收分包所 得的数据包； 接收完同一批次数据的数据包后， 将该批次数据的数据包合并生成数据文件， 其中， 一 个批次数据为可以进行一次所述预设处 理的数据； 所述根据 所述数据生成第 一消息发送至第 一消息队列包括： 将当前批次的数据的数据 文件的存 储路径发送至所述第一消息队列。 7.根据权利要求6所述的数据处理方法， 其特征在于， 所述从所述调用方接收数据包， 接收完同一批次数据的数据包 包括： 获取所述数据包中携带的批次信 息和总包数， 对接收到的批次信 息相同且非重复的数 据包进行计数， 当计数值达 到所述总包数时， 确定 接收完同一批次数据的数据包。 8.根据权利要求6所述的数据处理方法， 其特征在于， 所述发送所述处理结果至所述调权　利　要　求　书 1/3 页 2 CN 115220935 A 2用方包括： 将同一批次数据的同一种处理结果按预设大小拆分为数据包， 发送拆分所得的所述数 据包至所述调用方。 9.根据权利要求8所述的数据处理方法， 其特征在于， 所述处理结果包括概要结果数据 和明细结果数据， 所述方法还包括， 发送拆分所得的所述数据包至所述调用方时， 携带数据 种类指示信息， 指示所述数据包为 概要结果数据或者明细结果数据。 10.根据权利要求1至9任一所述的数据处理方法， 其特征在于， 所述根据 所述第一消息 队列中的所述第一消息获取所述数据， 根据所述数据进行预设处理， 生成至少一种处理结 果包括： 使用多进程分别从所述第一消息队列中的多个第一消息中获取所述数据， 根据所 述数据进行 预设处理， 生成至少一种处 理结果。 11.根据权利要求1至9任一所述的数据处理方法， 其特征在于， 所述从调用方接收数 据， 根据所述数据生成第一消息发送至第一消息队列包括： 接口应用服务从调用方接收数据， 根据所述数据生成第一消息发送至消息中间件； 所 述消息中间件将所述第一消息发送给第一消息队列； 所述监听所述第一消息队列， 监听到所述第一消息队列中存在第一消息后， 根据所述 第一消息队列中的所述第一消息获取所述数据， 根据所述数据进行预设处理， 生成至少一 种处理结果， 根据所述处理结果生成结果消息发送至所述处理结果对应的结果消息队列包 括： 算法服务监听所述第一消息队列， 监听到所述第一消息队列中存在第一消息后， 根据 所述第一消息队列中的所述第一消息获取所述数据， 根据所述数据进行预设处理， 生成至 少一种处理结果， 根据所述处理结果生成结果消息发送至所述消息中间件； 所述消息中间 件将所述结果消息发送至所述处 理结果对应的结果消息队列； 所述监听所述结果消息队列， 监听到所述结果消息队列中存在结果消息后， 根据所述 结果消息队列的所述结果消息获取处 理结果， 发送所述处 理结果至所述调用方包括： 所述接口应用服务监 听所述结果消息队列， 监 听到所述结果消息队列中存在结果消息 后， 根据所述结果消息队列的所述结果消息获取处理结果， 发送所述处理结果至所述调用 方。 12.一种计算机设备， 包括处理器以及存储有可在处理器上运行的计算机程序的存储 器， 其中， 所述处理器执行所述程序时实现如权利要求1 ‑11中任一项所述数据处理方法的 步骤。 13.一种计算机可读存储介质， 存储有程序指令， 当该程序指令被执行时可实现权利要 求1‑11任一项所述的数据处 理方法。 14.一种数据处理装置， 其特征在于， 包括： 接口应用服务、 消息中间件和算法服务， 其 中： 所述接口应用服务被配置为， 从调用方接收数据， 根据所述数据生成第一消息发送至 消息中间件； 以及， 监听结果消息队列， 监听到所述结果消息队列中存在结果消息后， 根据 所述结果消息队列的结果消息获取处 理结果， 发送所述处 理结果至所述调用方； 所述算法服务被配置为， 监听所述第一消息队列， 监听到所述第一消息队列中存在第 一消息后， 根据所述第一消息队列中的所述第一消息获取所述数据， 根据所述数据进行预权　利　要　求　书 2/3 页 3 CN 115220935 A 3