利索能及
我要发布
收藏
专利号: 2016109801926
申请人: 杭州海康威视数字技术股份有限公司
专利类型:发明专利
专利状态:已下证
更新日期:2025-10-25
缴费截止日期: 暂无
联系人

摘要:

权利要求书:

1.一种执行计划的生成方法,其特征在于,包括:确定任务的属性信息;

根据所述属性信息,确定与所述属性信息相匹配的计算节点,作为执行所述任务的第一计算节点;

根据所述第一计算节点的标识,生成所述任务的第一执行计划;所述第一执行计划,包含所述第一计算节点的标识;

将所述第一执行计划和所述任务,发送给执行所述任务的第一计算节点,以使所述第一计算节点根据所述第一执行计划执行所述任务;

当接收到所述第一计算节点发送的节点故障通知消息时,根据所述任务的属性信息重新生成执行计划;所述节点故障通知消息为所述第一计算节点在确定不存在用于接收服务结果、且处于正常工作状态的接收方节点的情况下发送;所述服务结果为所述第一计算节点执行所述任务后得到的执行结果。

2.如权利要求1所述的方法,其特征在于,根据所述属性信息,确定与所述属性信息相匹配的第一计算节点,作为执行所述任务的第一计算节点,包括:根据所述属性信息,以及第一计算节点的资源占用情况,确定与所述属性信息相匹配,且资源占用情况符合预设资源占用要求的第一计算节点,作为执行所述任务的第一计算节点。

3.如权利要求1所述的方法,其特征在于,将所述第一执行计划和所述任务,发送给执行所述任务的第一计算节点后,所述方法还包括:接收执行所述任务的第一计算节点发送的节点故障通知消息;

基于所述节点故障通知消息,根据所述属性信息生成第二执行计划;

所述第二执行计划,包含执行所述任务的第二计算节点的标识。

4.如权利要求1~3任一权项所述的方法,其特征在于,所述第一执行计划,还包含下述信息中的至少一种:

所述任务的类型;

完成所述任务所需服务的类型;

各第一计算节点提供服务的顺序;

所述任务对应的任务完成结果的接收方信息;

所述任务的唯一标识;

当前将要执行所述任务的第一计算节点的标识的索引信息。

5.如权利要求1~3任一权项所述的方法,其特征在于,所述方法应用于分布式计算系统;则

所述方法还包括:

在所述分布式计算系统中发生计算节点切换为非正常工作状态的事件后,更新已存储的所述分布式计算系统中的计算节点的注册信息;所述注册信息,包括所述分布式计算系统中处于正常工作状态的各计算节点的标识;

将更新后的所述注册信息同步至所述分布式计算系统中的计算节点。

6.一种任务执行方法,应用于分布式计算系统中的计算节点,其特征在于,所述方法包括:

接收第一执行计划和任务;所述第一执行计划,包含第一计算节点的标识;所述第一计算节点,包括根据所述属性信息确定出的、与所述属性信息相匹配的计算节点;

根据所述第一执行计划,执行所述任务,得到服务结果;

判断是否存在用于接收所述服务结果、且处于正常工作状态的接收方节点;若否,则向调度服务器发送节点故障通知消息,以使所述调度服务器根据所述任务的属性信息重新生成执行计划。

7.如权利要求6所述的任务执行方法,其特征在于,根据所述第一执行计划,执行所述任务,包括:

基于本地提供的服务类型,判断本地是否具备根据所述第一执行计划执行所述任务的能力;

在判断结果为是时,根据所述第一执行计划,执行所述任务。

8.如权利要求6所述的任务执行方法,其特征在于,判断是否存在用于接收服务结果、且处于正常工作状态的接收方节点,包括:通过解析所述第一执行计划,确定预期接收所述服务结果的接收方节点的标识;

判断本地是否保存有所述预期接收所述服务结果的接收方节点的注册信息;若保存有所述预期接收所述服务结果的接收方节点的注册信息,则判定存在用于接收服务结果、且处于正常工作状态的接收方节点;否则,判定不存在用于接收服务结果、且处于正常工作状态的接收方节点;

其中,本地保存的注册信息,包括本地已存储的、处于正常工作状态的计算节点的信息。

9.如权利要求8所述的任务执行方法,其特征在于,所述方法应用于分布式计算系统中的计算节点;则

所述方法还包括:

在所述分布式计算系统中的计算节点的注册信息发生变化时,通过所述调度服务器获取变化后的注册信息,并根据变化后的注册信息,更新本地保存的注册信息。

10.如权利要求6所述的方法,其特征在于,执行所述任务后,所述方法还包括:将服务结果、所述第一执行计划,以及所述任务,发送给接收方节点;

所述服务结果,为本地根据所述第一执行计划执行所述任务后得到的执行结果。

11.如权利要求6所述的方法,其特征在于,所述第一计算节点,具体包括:根据所述属性信息以及计算节点的资源占用情况确定出的、与所述属性信息相匹配,且资源占用情况符合预设资源占用要求的计算节点;则所述方法还包括:

将本地的资源使用情况,发送给所述分布式系统中的调度服务器。

12.一种执行计划的生成装置,其特征在于,包括:信息确定单元,用于确定任务的属性信息;

节点确定单元,用于根据所述属性信息,确定与所述属性信息相匹配的计算节点,作为执行所述任务的第一计算节点;

计划生成单元,用于根据所述第一计算节点的标识,生成所述任务的第一执行计划;所述第一执行计划,包含所述第一计算节点的标识;

发送单元,用于将所述第一执行计划和所述任务,发送给执行所述任务的第一计算节点,以使所述第一计算节点根据所述第一执行计划执行所述任务;

当接收到所述第一计算节点发送的节点故障通知消息时,根据所述任务的属性信息重新生成执行计划;所述节点故障通知消息为所述第一计算节点在确定不存在用于接收服务结果、且处于正常工作状态的接收方节点的情况下发送;所述服务结果为所述第一计算节点执行所述任务后得到的执行结果。

13.如权利要求12所述的装置,其特征在于,节点确定单元,用于:根据所述属性信息,以及第一计算节点的资源占用情况,确定与所述属性信息相匹配,且资源占用情况符合预设资源占用要求的第一计算节点,作为执行所述任务的第一计算节点。

14.如权利要求12所述的装置,其特征在于,所述装置还包括:消息接收单元,用于在发送单元将所述第一执行计划和所述任务,发送给执行所述任务的第一计算节点后,接收执行所述任务的第一计算节点发送的节点故障通知消息;

所述计划生成单元,还用于基于消息接收单元接收到的所述节点故障通知消息,根据所述属性信息生成第二执行计划;

所述第二执行计划,包含执行所述任务的第二计算节点的标识。

15.如权利要求12~14任一权项所述的装置,其特征在于,所述第一执行计划,还包含下述信息中的至少一种:

所述任务的类型;

完成所述任务所需服务的类型;

各第一计算节点提供服务的顺序;

所述任务对应的任务完成结果的接收方信息;

所述任务的唯一标识;

当前将要执行所述任务的第一计算节点的标识的索引信息。

16.如权利要求12~14任一权项所述的装置,其特征在于,所述装置应用于分布式计算系统;则

所述装置还包括:

同步单元,用于在所述分布式计算系统中发生计算节点切换为非正常工作状态的事件后,更新本地保存的所述分布式计算系统中的计算节点的注册信息;所述注册信息,包括所述分布式计算系统中处于正常工作状态的各计算节点的标识;将更新后的所述注册信息同步至所述分布式计算系统中的计算节点。

17.一种任务执行装置,其特征在于,包括:接收单元,用于接收第一执行计划和任务;所述第一执行计划,包含第一计算节点的标识;所述第一计算节点,包括根据所述属性信息确定出的、与所述属性信息相匹配的计算节点;

执行单元,用于根据所述第一执行计划,执行所述任务,得到服务结果;

消息发送单元,用于判断是否存在用于接收所述服务结果、且处于正常工作状态的接收方节点;若否,则向调度服务器发送节点故障通知消息,以使所述调度服务器根据所述任务的属性信息重新生成执行计划。

18.如权利要求17所述的任务执行装置,其特征在于,执行单元,用于:基于本地提供的服务类型,判断本地是否具备根据所述第一执行计划执行所述任务的能力;

在判断结果为是时,根据所述第一执行计划,执行所述任务。

19.如权利要求17所述的任务执行装置,其特征在于,所述消息发送单元,用于:通过解析所述第一执行计划,确定预期接收所述服务结果的接收方节点的标识;

判断本地是否保存有所述预期接收所述服务结果的接收方节点的注册信息;若保存有所述预期接收所述服务结果的接收方节点的注册信息,则判定存在用于接收所述服务结果、且处于正常工作状态的接收方节点;否则,判定不存在用于接收所述服务结果、且处于正常工作状态的接收方节点;

其中,本地保存的注册信息,包括本地已存储的、处于正常工作状态的计算节点的信息。

20.如权利要求19所述的任务执行装置,其特征在于,所述装置应用于分布式计算系统中的计算节点;则

所述装置还包括:

更新单元,用于在所述分布式计算系统中的计算节点的注册信息发生变化时,通过所述调度服务器获取变化后的注册信息,并根据变化后的注册信息,更新本地保存的注册信息。

21.如权利要求17所述的装置,其特征在于,所述装置还包括:计划发送单元,用于在执行单元执行所述任务后,将服务结果、所述第一执行计划,以及所述任务,发送给接收方节点;

所述服务结果,为本地根据所述第一执行计划执行所述任务后得到的执行结果。

22.如权利要求17所述的装置,其特征在于,所述装置应用于分布式计算系统中的计算节点;所述第一计算节点,具体包括:根据所述属性信息以及计算节点的资源占用情况确定出的、与所述属性信息相匹配,且资源占用情况符合预设资源占用要求的计算节点;则所述装置还包括:

资源情况发送单元,用于将本地的资源使用情况,发送给所述分布式系统中的调度服务器。