一种基于消息中间件的分布式任务调度方法及系统

摘要

本发明公开了一种基于消息中间件的分布式任务调度方法及系统，属于分布式系统的任务调度领域。本发明采用消息队列的方式进行分布式任务的调度，首先将待执行的任务保存到主节点的任务队列中，然后通过负载均衡将任务均衡地分配到主节点下的可用子节点中，由子节点启动各自独立的任务进程执行任务。在任务的调度执行过程中，通过监控节点对主节点和子节点的状态进行实时监控，当出现故障时，将待执行的任务或正在执行的任务切换到备用主节点或可用子节点中。通过本发明所述的方法及系统，保证了任务之间的独立性，提高了任务执行的效率。故障切换机制进一步保证了任务调度执行的可靠性。

主权项

一种基于消息中间件的分布式任务调度方法，包括以下步骤：（1）将待处理的任务保存到主节点的任务队列中；（2）将任务队列中的任务通过消息中间件由负载均衡管理器均衡分配到主节点下的可用子节点中，监听节点将第一个报上心跳信号的主节点指定为任命主节点，其它主节点为备用主节点，主节点在进行任务的调度分配时，会首先将要执行的任务信息同步到备用主节点中，然后再通过负载均衡后将任务分配到可用子节点中；由负载均衡管理器均衡分配的具体方式为：a.主节点获取其列表下的一个可用子节点，并向该子节点发送请求，查看该子节点是否可用；b.子节点接收到主节点的请求，将其执行状态回复主节点；c.主节点接收到回复信息，如果子节点可用，则将任务分配到该子节点；如果子节点不可用，则返回步骤a；（3）启动子节点的任务进程，由子节点的目标主机执行子节点的任务；当执行任务的子节点的目标主机发生故障时，将任务切换到子节点的其它目标主机上执行；当执行任务的子节点发生故障时，将任务切换到其它可用子节点上执行；当任命主节点发生故障时，启用备用主节点分配任务。