(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210388943.0 (22)申请日 2022.04.13 (71)申请人 武汉大学 地址 430072 湖北省武汉市武昌区珞珈山 (72)发明人 桂浩　何志恒　颜泽坤　金正　 王浚洋　吴冠霆　 (74)专利代理 机构 武汉智权专利代理事务所 (特殊普通 合伙) 42225 专利代理师 张凯 (51)Int.Cl. G06F 9/48(2006.01) G06F 9/50(2006.01) G06F 9/54(2006.01) G06F 11/30(2006.01) (54)发明名称 基于消息队列的混合云原生高算力高并发 解决方法及装置 (57)摘要 本发明公开了一种基于消息队列的混合云 原生高算力高并发解决方法及装置， 涉及云原生 领域， 该方法包括创建消息队列， 并基于创建的 消息队列对高并发任务场景下不同类型的计算 任务进行存放； 创建任务调度算法， 并基于创建 的任务调度算法将消息队列中存放的计算任务 分发给监听了消息队列的消费者； 相同POD内的 消费者和计算容器间交互以将计算任务发送给 计算容器进行计算， 且消费者将计算结果返回至 消息队列； 与计算任务对应的监听者从reply队 列中获取得到输出结果， 并将获取的输出结果写 入数据库。 本发 明能够实现对高算力海量并发计 算任务的有效响应和处 理。 权利要求书2页 说明书6页 附图1页 CN 114741174 A 2022.07.12 CN 114741174 A 1.一种基于消息队列的混合云原生高算力高并发解决方法， 其特征在于， 具体包括以 下步骤： 创建消息队列， 并基于创建的消息队列对高并发任务场景下不同类型的计算任务进行 存放； 创建任务调度算法， 并基于创建的任务调度算法将消息队列中存放的计算任务分发给 监听了消息队列的消费者； 相同POD内的消费者和计算容器间交互以将计算任务发送给计算容器进行计算， 且消 费者将计算结果返回至消息队列； 与计算任务对应的监听者从reply队列中获取得到输出结果， 并将获取的输出结果写 入数据库。 2.如权利要求1所述的一种基于消息队列的混合云原生高算力 高并发解决方法， 其特 征在于： 所述消息队列包括消费队列、 Reply队列和死信队列； 所述消费队列用于存放待 进行计算的计算任务； 所述Reply队列用于存放已被消费者正确相应的计算任务， 以及存放计算任务被计算 容器正确计算后得到的计算结果； 所述死信队列用于存放计算 容器计算过程中出现异常或未知错 误时的计算任务。 3.如权利要求2所述的一种基于消息队列的混合云原生高算力 高并发解决方法， 其特 征在于， 对于计算任务在消息队列中的存放， 具体包括： 生产者将计算任务发送至默认交换机； 默认交换机根据路由将计算任务 转发至对应的消息队列。 4.如权利要求1所述的一种基于消息队列的混合云原生高算力 高并发解决方法， 其特 征在于： 所述消费者所在的消费者 容器中设置有环境变量标识； 所述环境变量标识用于声明消费者所监听的消息队列； 所述消费者从监 听的队列中获取计算任务的状态变化， 且消费者仅能从该消费者监 听 的消息队列中取 出计算任务。 5.如权利要求1所述的一种基于消息队列的混合云原生高算力 高并发解决方法， 其特 征在于： 当基于创建的任务调度算法将消息队列中存放的计算任务分发给监听了消息队列的 消费者之后， 还 包括： 消费者 根据自身类型， 基于预设策略来实现资源调度； 所述消费者的类型包括公有云和私有云； 所述预设策略为类型为私有云的消费者优先领取计算任务， 当私有云资源有限而无法 完成计算任务时， 类型为公有云的消费者进行计算任务领 取。 6.如权利要求5所述的一种基于消息队列的混合云原生高算力 高并发解决方法， 其特 征在于， 所述相同POD内的消费者和 计算容器间交互以将计算任务发送给计算容器进行计 算， 具体步骤 包括： 消费者接收计算任务后从对象存储服务中获取得到该计算任务对应的输入参数文件， 所述公有云和私有云中均部署有对象存 储服务；权　利　要　求　书 1/2 页 2 CN 114741174 A 2在计算容器和消费者容器的共享存 储卷中建立 开始标识； 计算容器实时监 听共享存储卷， 并当计算容器得知开始标识后从共享存储卷中获取计 算任务的输入参数文件； 计算容器调用计算 容器内部的计算模型并使用机器 计算资源 对计算任务进行计算。 7.如权利要求6所述的一种基于消息队列的混合云原生高算力 高并发解决方法， 其特 征在于， 当相同POD内的消费者和 计算容器间交互以将计算任务发送给计算容器进行计算 之后， 还包括： 计算容器持续 监听计算模型直至计算模型停止计算； 计算容器停止计算进程并在共享存 储卷中建立end文件作为结束标识； 消费者容器在共享存储卷中得知结束标识后， 将计算任务的计算结果放入Reply队列 中， 同时将计算结果对应的输入结果文件 存储至对象存 储服务中。 8.如权利要求7所述的一种基于消息队列的混合云原生高算力 高并发解决方法， 其特 征在于， 所述与计算任务对应的监听者从reply队列中获取 得到输出结果， 具体步骤 包括： 监听者实时监听消息队列中的reply队列； 监听者从reply队列中获取已经计算完成的计算任务的消息信息； 基于消息信息， 从对象存 储服务中获取对应的输入结果文件。 9.如权利要求8所述的一种基于消息队列的混合云原生高算力 高并发解决方法， 其特 征在于， 所述将获取的输出 结果写入数据库， 具体步骤 包括： 监听者将获取的输入结果文件下载至本地， 并读取输入结果文件， 将读取的结果数据 存储至数据库。 10.一种基于消息队列的混合云原生高算力高并发解决系统， 其特 征在于， 包括： 第一创建模块， 其用于创建消息队列， 并基于创建的消息队列对高并发任务场景下不 同类型的计算任务进行存放； 第二创建模块， 其用于创建任务调度算法， 并基于创建的任务调度算法将消息队列中 存放的计算任务分发给监听了消息队列的消费者； 计算模块， 其用于驱使相同POD内的消费者和计算容器间交互以将计算任务发送给计 算容器进行计算， 且消费者将计算结果返回至消息队列； 写入模块， 其用于驱使与计算任务对应的监听者从reply队列中获取得到输出结果， 并 将获取的输出 结果写入数据库。权　利　要　求　书 2/2 页 3 CN 114741174 A 3