logo好方法网

任务调度方法、装置及计算机设备


技术摘要:
本发明实施例提供了一种任务调度方法,包括:通过任务调度器定时查询所述数据库中存储的任务表,并从所述任务表中获取预设数量的状态为待处理的任务;判断获取到的各个待处理任务对应的哈希值是否与所述quartz服务器节点预先配置的哈希值相匹配;及在判定出哈希值匹配  全部
背景技术:
Quartz框架是一个完全由java编写的开源作业调度框架,被广泛地应用于实现同 一数据库的单集群任务的任务管理及调度。Quartz框架在执行定时任务时,通过单个实例 节点从数据库任务表中有序抓取一批选中的异步任务,并在抓取到任务后,通过乐观锁的 机制对抓取到的任务进行锁定,以便集群中的其他实例节点不能再抓取该任务。 然而,随着业务场景的增加,平台对任务调度的依赖场景也越来越多,这种单个实 例节点的调度机制的任务处理效率较低,已无法满足高实时性的业务需求。
技术实现要素:
有鉴于此,本发明实施例的目的是提供一种任务调度方法、装置、计算机设备及计 算机可读存储介质,用于解决现有的任务调度机制效率较低,无法满足高实时性的业务需 求的问题。 为实现上述目的,本发明实施例提供了一种任务调度方法,包括: 通过任务调度器定时查询所述数据库中存储的任务表,并从所述任务表中获取预 设数量的状态为待处理的任务; 判断获取到的各个待处理任务对应的哈希值是否与所述quartz服务器节点预先 配置的哈希值相匹配;及 在判定出哈希值匹配时,确定哈希值匹配的待处理任务为与所述quartz服务器节 点相匹配的待处理任务,通过所述任务调度器对应的实例执行与所述quartz服务器节点相 匹配的待处理任务。 可选地,所述任务调度方法还包括: 在接收到基于quartz集群的配置文件,根据所述配置文件配置所述quartz服务器 对应的哈希槽,所述哈希槽中包括至少一个哈希值。 可选地,所述判断获取到的各个待处理任务对应的哈希值是否与所述quartz服务 器节点预先配置的哈希值相匹配包括: 采用预设的哈希算法计算得到的各个待处理任务对应的哈希值; 判断计算得到的各个哈希值是否与所述quartz服务器节点预先配置的哈希值相 匹配。 可选地,所述判断获取到的各个待处理任务对应的哈希值是否与所述quartz服务 器节点预先配置的哈希值相匹配包括: 查找与所述获取到的各个待处理任务关联保存的哈希值; 判断查找得到的各个哈希值是否与所述quartz服务器节点预先配置的哈希值相 匹配。 4 CN 111580948 A 说 明 书 2/10 页 可选地,所述通过所述任务调度器对应的实例执行与所述quartz服务器节点相匹 配的任务包括: 通过所述任务调度器创建调度器的工厂,并基于所述工厂生成所述任务调度的实 例; 通过所述实例执行与所述quartz服务器节点相匹配的任务。 可选地,所述任务调度方法还包括: 在任务执行完毕之后,通过所述任务调度器将任务的状态从待处理状态修改为已 处理状态。 可选地,所述任务调度方法还包括: 在任务执行失败之后,发送告警信息至管理员。 为实现上述目的,本发明实施例还提供了一种任务调度装置,包括: 查询模块,用于通过任务调度器定时查询所述数据库中存储的任务表,并从所述 任务表中获取预设数量的状态为待处理的任务; 判断模块,用于判断获取到的各个待处理任务对应的哈希值是否与所述quartz服 务器节点预先配置的哈希值相匹配;及 执行模块,用于在判定出哈希值匹配时,通过所述任务调度器对应的实例执行与 所述quartz服务器节点相匹配的任务。 为实现上述目的,本发明实施例还提供了一种计算机设备,包括存储器、处理器以 及存储在所述存储器上并可在所述处理器上运行的计算机程序,所述处理器执行所述计算 机程序时实现如上所述的任务调度方法的步骤。 为实现上述目的,本发明实施例还提供了一种计算机可读存储介质,所述计算机 可读存储介质内存储有计算机程序,所述计算机程序可被至少一个处理器所执行,以使所 述至少一个处理器执行如上所述的任务调度方法的步骤。 本发明实施例提供的任务调度方法、装置、计算机设备及计算机可读存储介质,通 过任务调度器定时查询所述数据库中存储的任务表,并从所述任务表中获取预设数量的状 态为待处理的任务;判断获取到的各个待处理任务对应的哈希值是否与所述quartz服务器 节点预先配置的哈希值相匹配;及在判定出哈希值匹配时,通过所述任务调度器对应的实 例执行与所述quartz服务器节点相匹配的任务。本发明实施例中quartz集群中的各个 quartz服务器节点可以同步从数据库中抓取任务进行处理,从而可以提高任务的时效性。 同时,通过各个quartz服务器节点只处理与其哈希值相对应的任务,进而可以充分利用到 quartz集群的资源并且避免出现数据库死锁问题。 附图说明 图1为本发明任务调度方法的一实施方式的步骤流程示意图。 图2为本发明一实施方式中判断获取到的各个待处理任务对应的哈希值是否与所 述quartz服务器节点预先配置的哈希值相匹配的步骤细化流程示意图。 图3为本发明另一实施方式中判断获取到的各个待处理任务对应的哈希值是否与 所述quartz服务器节点预先配置的哈希值相匹配的步骤细化流程示意图。 图4为本发明一实施方式中通过所述任务调度器对应的实例执行与所述quartz服 5 CN 111580948 A 说 明 书 3/10 页 务器节点相匹配的任务的步骤细化流程示意图。 图5为本发明一实施方式的任务调度装置的程序模块示意图。 图6为本发明一实施方式的计算机设备的硬件结构示意图。 本发明目的的实现、功能特点及优点将结合实施例,参照附图做进一步说明。
下载此资料需消耗2积分,
分享到:
收藏