利索能及
我要发布
收藏
专利号: 2018101022504
申请人: 平安科技(深圳)有限公司
专利类型:发明专利
专利状态:已下证
更新日期:2026-09-09
缴费截止日期: 暂无
联系人

摘要:

权利要求书:

1.一种电子装置,其特征在于,所述电子装置包括存储器、及与所述存储器连接的处理器,所述处理器用于执行所述存储器上存储的分布式系统任务分配程序,所述分布式系统任务分配程序被所述处理器执行时实现如下步骤:A1、监测分布式系统各个服务节点执行的任务以及所述任务的执行状态,根据监测到的任务以及任务的执行状态生成所述分布式系统各个服务节点的任务执行编码,将所述任务执行编码存储在预先确定的数据库中;

A2、在接收到新的任务执行指令后,根据预先确定的任务识别编码生成规则生成接收到的任务执行指令中待执行任务的任务识别编码;

A3、根据预先确定的任务分配规则分析所述预先确定的数据库中存储的任务执行编码及所述任务识别编码,确定执行所述待执行任务的服务节点,或者确定向各个服务节点发出拒绝执行所述待执行任务的指令。

2.如权利要求1所述的电子装置,其特征在于,所述根据预先确定的任务识别编码生成规则生成接收到的任务执行指令中待执行任务的任务识别编码的步骤,具体包括:获取所述任务执行指令中待执行任务的第二名称、及接收到所述任务执行指令的第二时间;

根据所述第二名称及所述第二时间生成包括所述第二名称及所述第二时间的任务识别编码。

3.如权利要求2所述的电子装置,其特征在于,所述任务执行编码包括监测到的任务对应的第一名称、监测到执行任务的第一时间;所述根据预先确定的任务分配规则分析所述预先确定的数据库中存储的任务执行编码及所述任务识别编码,确定执行所述待执行任务的服务节点,或者确定向各个服务节点发出拒绝执行所述待执行任务的指令的步骤,具体包括:将所述第二名称分别与所述第一名称进行匹配,若有第一名称与所述第二名称相匹配,则获取相匹配的第一名称对应的任务执行编码中的第一时间;

计算该第一时间与所述第二时间的时间差值,若所述时间差值小于预设的时间差阈值,则向各个服务节点发出拒绝执行所述待执行任务的指令;

若没有第一名称与所述第二名称相匹配,则根据预设的时间频率同时向各个服务节点发送执行所述第二任务的请求,并在监测到有服务节点响应该请求并开始执行所述第二任务后,向除该服务节点之外的其他各个服务节点发送不再执行所述第二任务的指令;

根据所述预先确定的任务执行编码生成规则生成所述第二任务对应的任务执行编码,将生成的任务执行编码存入所述预先确定的数据库中。

4.如权利要求3所述的电子装置,其特征在于,所述任务执行编码还包括执行任务的状态,所述执行任务的状态包括任务执行中、任务待执行、以及任务执行完成;所述根据预先确定的任务分配规则分析所述预先确定的数据库中存储的任务执行编码及所述任务识别编码,确定执行所述待执行任务的服务节点,或者确定向各个服务节点发出拒绝执行所述待执行任务的指令的步骤,具体包括:若检测到有服务节点的执行任务的状态为任务执行中或者任务待执行,则确定向该服务节点发出拒绝执行所述待执行任务的指令;

或者,若检测到有服务节点的执行任务的状态为任务执行完成,则确定向该服务节点发送执行所述待执行任务的指令。

5.如权利要求3所述的电子装置,其特征在于,所述第一时间与所述第二具有相同的时间单位。

6.一种分布式系统任务分配方法,其特征在于,所述方法包括如下步骤:

S1、监测分布式系统各个服务节点执行的任务以及所述任务的执行状态,根据监测到的任务以及任务的执行状态生成所述分布式系统各个服务节点的任务执行编码,将所述任务执行编码存储在预先确定的数据库中;

S2、在接收到新的任务执行指令后,根据预先确定的任务识别编码生成规则生成接收到的任务执行指令中待执行任务的任务识别编码;

S3、根据预先确定的任务分配规则分析所述预先确定的数据库中存储的任务执行编码及所述任务识别编码,确定执行所述待执行任务的服务节点,或者确定向各个服务节点发出拒绝执行所述待执行任务的指令。

7.如权利要求6所述的分布式系统任务分配方法,其特征在于,所述根据预先确定的任务识别编码生成规则生成接收到的任务执行指令中待执行任务的任务识别编码的步骤,具体包括获取所述任务执行指令中待执行任务的第二名称、及接收到所述任务执行指令的第二时间;

根据所述第二名称及所述第二时间生成包括所述第二名称及所述第二时间的任务识别编码。

8.如权利要求7所述的分布式系统任务分配方法,其特征在于,所述任务执行编码包括监测到的任务对应的第一名称、监测到执行任务的第一时间;所述根据预先确定的任务分配规则分析所述预先确定的数据库中存储的任务执行编码及所述任务识别编码,确定执行所述待执行任务的服务节点,或者确定向各个服务节点发出拒绝执行所述待执行任务的指令的步骤,具体包括:将所述第二名称分别与所述第一名称进行匹配,若有第一名称与所述第二名称相匹配,则获取相匹配的第一名称对应的任务执行编码中的第一时间;

计算该第一时间与所述第二时间的时间差值,若所述时间差值小于预设的时间差阈值,则向各个服务节点发出拒绝执行所述待执行任务的指令;

若没有第一名称与所述第二名称相匹配,则根据预设的时间频率同时向各个服务节点发送执行所述第二任务的请求,并在监测到有服务节点响应该请求并开始执行所述第二任务后,向除该服务节点之外的其他各个服务节点发送不再执行所述第二任务的指令;

根据所述预先确定的任务执行编码生成规则生成所述第二任务对应的任务执行编码,将生成的任务执行编码存入所述预先确定的数据库中。

9.如权利要求7或8所述的分布式任务系统分配方法,其特征在于,所述任务执行编码包括执行任务的状态,所述执行任务的状态包括任务执行中、任务待执行、以及任务执行完成;所述根据预先确定的任务分配规则分析所述预先确定的数据库中存储的任务执行编码及所述任务识别编码,确定执行所述待执行任务的服务节点,或者确定向各个服务节点发出拒绝执行所述待执行任务的指令的步骤,具体包括:若检测到有服务节点的执行任务的状态为任务执行中或者任务待执行,则确定向该服务节点发出拒绝执行所述待执行任务的指令;

或者,若检测到有服务节点的执行任务的状态为任务执行完成,则确定向该服务节点发送执行所述待执行任务的指令。

10.一种计算机可读存储介质,所述计算机可读存储介质存储有分布式系统任务分配程序,所述分布式任务系统分配程序可被至少一个处理器执行,以使所述至少一个处理器执行如权利要求6-9中任一项所述的分布式任务系统分配方法的步骤。