1.一种数据节点的任务分配方法,其特征在于,包括如下步骤:配置多个用于传输数据的数据节点;
实时监测传输栈队中是否存在待传输任务,如果存在待传输任务,则计算各数据节点完成当前任务的剩余传输时长;
将各数据节点完成当前任务的剩余传输时长由短至长进行排序,根据排序结果将排序在前n位的数据节点作为传输所述待传输任务的备选数据节点,其中,n≥2;
将备选数据节点中排序在首位的数据节点的剩余传输时长作为监测时长,当所述监测时长到达时,判断所述备选数据节点中是否存在空闲的数据节点,如果存在,则将所述待传输任务分配至所述空闲的数据节点中,否则,重新计算各所述备选数据节点完成当前任务的剩余传输时长,并根据重新计算得到的剩余传输时长评估备选数据节点中符合预设条件的最优数据节点,将所述待传输任务分配至所述最优数据节点中;
所述根据重新计算得到的剩余传输时长评估备选数据节点中符合预设条件的最优数据节点包括:将重新计算得到的各备选数据节点的剩余传输时长由短至长进行排序,得到排序在前的两个备选数据节点;
计算所述两个备选数据节点的剩余传输时长的时间差值t,并判断时间差值t是否小于或等于预设的时间差值T,如果满足,
则判断所述两个备选数据节点的传输速率是否相同,如果相同,则选择两个备选数据节点中剩余传输时长较短的备选数据节点作为最优数据节点,如果不相同,则选择两个备选数据节点中传输速率较快的备选数据节点作为最优数据节点;
如果不满足,
则选择两个备选数据节点中剩余传输时长较短的备选数据节点作为最优数据节点。
2.根据权利要求1所述的数据节点的任务分配方法,其特征在于,将所述待传输任务分配至所述最优数据节点后还包括步骤:根据最优数据节点的剩余传输时长监测最优数据节点是否完成当前任务,如果未完成,则将所述待传输任务重新分配至所述两个备选数据节点中另一个备选数据节点中。
3.根据权利要求2所述的数据节点的任务分配方法,其特征在于,将所述待传输任务重新分配至所述两个备选数据节点中另一个备选数据节点中后还包括步骤:根据已分配待传输任务的备选数据节点的剩余传输时长对该备选数据节点进行监测,如果未完成当前任务,则发出报警信息。
4.根据权利要求1-3任一项所述的数据节点的任务分配方法,其特征在于,所述配置多个用于传输数据的数据节点包括:配置各个数据节点的传输速率。
5.一种数据节点的任务分配装置,其特征在于,包括:
节点配置模块,用于配置多个用于传输数据的数据节点;
任务监测模块,用于实时监测传输栈队中是否存在待传输任务,如果存在待传输任务,则发送计算指令至计算模块;
计算模块,用于根据所述计算指令计算各数据节点完成当前任务的剩余传输时长;
分配处理模块,用于将各数据节点完成当前任务的剩余传输时长由短至长进行排序,根据排序结果将排序在前n位的数据节点作为传输所述待传输任务的备选数据节点;
还用于将备选数据节点中排序在首位的数据节点的剩余传输时长作为监测时长,当所述监测时长到达时,判断所述备选数据节点中是否存在空闲的数据节点,如果存在,则将所述待传输任务分配至所述空闲的数据节点中,否则,调用所述计算模块重新计算各所述备选数据节点完成当前任务的剩余传输时长,并根据所述计算模块重新计算得到的剩余传输时长评估备选数据节点中符合预设条件的最优数据节点,将所述待传输任务分配至所述最优数据节点中;
所述分配处理模块具体用于:
将重新计算得到的各备选数据节点的剩余传输时长由短至长进行排序,得到排序在前的两个备选数据节点;
并调用所述计算模块计算所述两个备选数据节点的剩余传输时长的时间差值t,当接收到所述计算模块反馈的所述时间差值t时,判断时间差值t是否小于或等于预设的时间差值T,如果满足,
则判断所述两个备选数据节点的传输速率是否相同,如果相同,则选择两个备选数据节点中剩余传输时长较短的备选数据节点作为最优数据节点,如果不相同,则选择两个备选数据节点中传输速率较快的备选数据节点作为最优数据节点;
如果不满足,
则选择两个备选数据节点中剩余传输时长较短的备选数据节点作为最优数据节点。
6.根据权利要求5所述的数据节点的任务分配装置,其特征在于,所述分配处理模块还具体用于,根据最优数据节点的剩余传输时长监测最优数据节点是否完成当前任务,如果未完成,则将所述待传输任务重新分配至所述两个备选数据节点中另一个备选数据节点中。
7.根据权利要求6所述的数据节点的任务分配装置,其特征在于,所述分配处理模块还具体用于,根据已分配待传输任务的备选数据节点的剩余传输时长对该备选数据节点进行监测,如果未完成当前任务,则发出报警信息。
8.根据权利要求5-7任一项所述的数据节点的任务分配装置,其特征在于,所述节点配置模块具体用于,配置各个数据节点的传输速率。