一种分布式资源调度系统及其方法

摘要

本发明提供了一种分布式资源调度方法，包括如下步骤：(a)服务节点将需要处理的任务打包生成格式统一的任务包，并将所述任务包发送至调度服务器；(b)所述调度服务器接收并管理所述服务节点发来的任务包，以预设规则将其分配至计算节点；(c)所述计算节点接收所述调度服务器发来的任务包，并对所述任务包进行处理，将处理的结果包发送至所述调度服务器。本发明可以使系统内计算机分工明确，便于管理，可以使得整个分布式系统的计算任务不受计算机语言、操作系统平台等限制。

主权项

一种分布式资源调度方法，其特征在于，包括如下步骤：(a)，服务节点将需要处理的任务打包生成格式统一的任务包，并将所述任务包发送至调度服务器；(b)，所述调度服务器接收并管理所述服务节点发来的任务包，并按照合理的调度算法将其分配至计算节点；(c)，所述计算节点提取所述调度服务器上的任务包，并对所述任务包进行处理，将处理的结果包发送回所述调度服务器；其中所述服务器节点的数量至少为一台，所述调度服务器的数量为一台，所述计算节点的数量至少为一台；所述步骤(a)还包括：(a1)，将需要处理的程序或任务进行打包，封装为独立任务包文件；(a2)，将需要处理的任务包放置在预设目录下，并对该目录进行扫描，向所述调度服务器查询每个任务包的状态；(a3)，根据返回的查询状态，作相应的处理，具体包括：任务正在计算中，不作处理；任务已经完成，则将相应的任务包移入相应的目录下并进行后续操作；任务错误，则选择重发该任务包或取消该任务包；所述步骤(a2)还包括：(a4)，扫描预设目录下的每个任务包时，每隔预设时间将其发送至所述调度服务器，发送完毕后，休眠预设时间；所述步骤(b)还包括：(b1)，接收并登记所述服务节点发来的任务包，向所述服务节点提供任务包的状态查询；(b2)，所述调度服务器以优先级为0～9的预设规则将任务包分配给计算节点；所述步骤(b)还包括：(b3)，所述调度服务器响应所述服务节点的查询，如果发现该查询的任务包已经完成，则向所述服务节点返回结果包；所述步骤(c)还包括：(c1)，计算节点向调度服务器提交本机所支持的运行环境，并从所述调度服务器中获取所述任务包列表；(c2)，所述调度服务器从所述任务包列表中选择其中一个任务包，并将该任务包的连接地址返回给所述计算节点，同时记录该任务包的信息并使该任务包生存次数自减；(c3)，所述计算节点根据所述任务包的连接地址下载任务包，解包，并运行主程序中指定的可执行程序进行处理；执行所述步骤(c3)之后还包括：(c31)，所述调度服务器根据所述计算节点返回的结果处理任务包，并登记处理结束的时间，修改任务包状态，并将已处理的任务包移入已完成列表。