(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210721974.3 (22)申请日 2022.06.24 (65)同一申请的已公布的文献号 申请公布号 CN 114827278 A (43)申请公布日 2022.07.29 (73)专利权人 小米汽车 科技有限公司 地址 100176 北京市北京经济技 术开发区 科创十街15号院5号楼6层618室 (72)发明人 何逸凡　 (74)专利代理 机构 北京法胜知识产权代理有限 公司 11922 专利代理师 戎郑华 (51)Int.Cl. H04L 67/60(2022.01) H04L 67/61(2022.01)G06F 16/2455(2019.01) (56)对比文件 CN 113849320 A,2021.12.28 CN 114598593 A,202 2.06.07 CN 114356599 A,2022.04.15 CN 112527528 A,2021.0 3.19 US 2022058181 A1,202 2.02.24 审查员 宫磊 (54)发明名称 基于消息队列 的任务调度方法、 系统、 装置 及设备 (57)摘要 本公开是关于一种基于消息队列的任务调 度方法、 系统、 装置及设备， 其中， 该方法应用于 客户端， 该方法包括： 向消息中间件服务端发送 半事务消息； 消息中间件服务端将半事务消息加 入半消息队列， 并返回半事务消息的消息标识信 息； 接收消息中间件服务端发送的消息标识信 息； 将半事务消息对应的任务信息和半事务消息 的消息标识信息存储至数据库； 从数据库中读取 存储的任务信息， 并根据消息标识信息对读取到 的任务信息进行筛选处理以获得待调度任务； 基 于消息中间件服务端的消息回查将待调度任务 加入消息中间件服务端中的消息队列， 以供消息 订阅方消费待调度任务。 通过本公开的技术方 案， 可以减轻服 务端的负担， 加快任务 提交速度。 权利要求书4页 说明书14页 附图6页 CN 114827278 B 2022.09.02 CN 114827278 B 1.一种基于消息队列的任务调度方法， 其特征在于， 所述方法应用于客户端， 所述方法 包括： 向消息中间件服务端发送半事务消息； 所述消息中间件服务端将所述半事务消息加入 半消息队列， 并返回所述半事务消息的消息标识信息； 接收所述消息中间件服 务端发送的所述消息标识信息； 将所述半事务消息对应的任务信息和所述半事务消息的消息标识信息存 储至数据库； 从所述数据库中读取存储的任务信 息， 并根据所述消息标识信 息对读取到的任务信 息 进行筛选处理以获得待调度任务； 基于所述消息中间件服务端的消息回查将所述待调度任务加入所述消息中间件服务 端中的消息队列， 以供消息订阅方消费所述待调度任务。 2.如权利要求1所述的方法， 其特征在于， 所述根据 所述消息标识信 息对读取到的任务 信息进行筛 选处理以获得待调度任务， 包括： 根据当前业务场景和所述消息标识信 息， 从所述读取到的任务信 息中筛选出满足要求 的任务信息； 将所述满足要求的任务信息确定为所述待调度任务。 3.如权利要求2所述的方法， 其特征在于， 所述根据当前业务场景和所述消息标识信 息， 从所述读取到的任务信息中筛 选出满足要求的任务信息， 包括： 根据当前业 务场景确定对应的任务调度方式； 从所述读取到的任务信息中筛 选出满足所述任务调度方式的任务信息 。 4.如权利要求3所述的方法， 其特征在于， 所述任务信息包括任务的优先级等级， 所述 任务调度方式包括按照优先级等级高低进 行任务调 度的方式； 所述从所述读取到的任务信 息中筛选出满足所述任务调度方式的任务信息， 包括： 根据任务的优先级等级对所述读取到的任务信 息进行排队， 并将排队后的任务信 息确 定为满足所述任务调度方式的任务信息 。 5.如权利要求3所述的方法， 其特征在于， 所述任务信息包括任务的优先级等级， 所述 任务调度方式包括对优先级等级排在前N的任务进行调度的方式； 所述从所述读取到的任 务信息中筛 选出满足所述任务调度方式的任务信息， 包括： 根据任务的优先级等级， 从所述读取到的任务信息中找出优先级等级排在前N的任务 信息； 其中， 所述 N为正整数； 将优先级等级排在前N的任务信息确定为满足所述任务调度方式的任务信息 。 6.如权利要求1所述的方法， 其特征在于， 所述基于所述消息 中间件服务端的消息回查 将所述待调度任务加入所述消息中间件服 务端中的消息队列， 包括： 基于所述消息 中间件服务端的消息回查， 将状态为目标状态的待调度任务加入所述消 息中间件服 务端中的消息队列； 其中， 所述目标状态为对所述消息订阅方 可见的状态。 7.一种基于消息队列的任务调度方法， 其特征在于， 所述方法应用于客户端， 所述方法 包括： 向消息中间件服务端发送半事务消息； 所述消息中间件服务端将所述半事务消息加入 半消息队列， 并返回所述半事务消息的消息标识信息； 接收所述消息中间件服 务端发送的所述消息标识信息；权　利　要　求　书 1/4 页 2 CN 114827278 B 2将所述半事务消息对应的任务信 息和所述半事务消息的消息标识信 息存储至数据库， 以使消息处理器从所述数据库中读取存储的任务信息和消息标识信息， 并根据所述消息标 识信息对所述读取到的任务信息进行筛选处理以获得待调 度任务， 并基于所述消息中间件 服务端的消息回查将所述待调 度任务加入所述消息中间件服务端中的消息队列， 以供消息 订阅方消费所述待调度任务。 8.一种基于消息队列的任务调度方法， 其特征在于， 所述方法应用于消息中间件服务 端， 所述方法包括： 接收客户端发送的半事务消息； 将所述半事务消息加入半消息队列， 并返回所述半事务消息的消息标识信息； 其中， 所述消息标识信 息用于指示所述客户端将所述半事务消息对应的任务信 息和所 述半事务消息的消息标识信息存储至数据库， 以使消息处理器从所述数据库中读取存储的 任务信息， 并根据所述消息标识信息对读取到的任务信息进行筛选处理以获得待调度任 务， 并基于所述消息中间件服务端的消息回查将所述待调 度任务加入所述消息中间件服务 端中的消息队列， 以供消息订阅方消费所述待调度任务。 9.一种基于消息队列的任务调度方法， 其特征在于， 所述方法应用于消息处理器， 所述 方法包括： 从数据库中读取存储的任务信息和消息标识信息； 其中， 所述数据库中存储的任务信 息与客户端向消息中间件服务端发送的半事务消息对应， 与数据库中存储的任务信息对应 的半事务消息经所述消息中间件服务端加入半消息队列并返回所述半事务消息的消息标 识信息； 所述数据库中存 储的任务信息和 消息标识信息是由所述 客户端存 储的； 根据所述消息标识信息对所述读取到的任务信息进行筛 选处理以获得待调度任务； 基于所述消息中间件服务端的消息回查将所述待调度任务加入所述消息中间件服务 端中的消息队列， 以供消息订阅方消费所述待调度任务。 10.一种基于消息队列的任务调度系统， 其特征在于， 包括客户端、 消息中间件服务端、 消息处理器和消息订阅方， 其中， 所述客户端， 用于向所述消息中间件服 务端发送半事务消息； 所述消息中间件服务端， 用于将所述半事务消息加入半消息队列， 并返回所述半事务 消息的消息标识信息； 所述客户端还用于接收所述消息 中间件服务端发送的所述消息标识信 息， 并将所述半 事务消息对应的任务信息和所述半事务消息的消息标识信息存 储至数据库； 所述消息处理器， 用于从所述数据库中读取存储的任务信息， 并根据所述消息标识信 息对读取到的任务信息进 行筛选处理以获得待调 度任务， 以及基于所述消息中间件服务端 的消息回查将所述待调 度任务加入所述消息中间件服务端中的消息队列， 以供消息订阅方 消费所述待调度任务。 11.一种基于消息队列的任务调度装置， 其特征在于， 所述装置应用于客户端， 所述装 置包括： 发送模块， 用于向消息中间件服务端发送半事务消息； 所述消息中间件服务端将所述 半事务消息加入半消息队列， 并返回所述半事务消息的消息标识信息； 接收模块， 用于 接收所述消息中间件服 务端发送的所述消息标识信息；权　利　要　求　书 2/4 页 3 CN 114827278 B 3