程序员

分布式任务调度(00)--Quartz

2023-11-06  本文已影响0人  JavaEdge

1 任务调度整体流程

2 组件

import org.quartz.*;
import org.quartz.SchedulerException;
import org.quartz.impl.StdSchedulerFactory;

public class QuartzDemo {
    public static void main(String[] args) throws SchedulerException {
        // 创建JobDetail对象
        JobDetail jobDetail = JobBuilder.newJob(MyJob.class)
                .withIdentity("myJob", "group1")
                .build();

        // 创建Trigger对象
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("myTrigger", "group1")
                .startNow()
                .withSchedule(CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
                .build();

        // 创建Scheduler对象
        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();

        // 将Job和Trigger注册到Scheduler
        scheduler.scheduleJob(jobDetail, trigger);
    }
}

执行任务调度核心类QuartzSchedulerThread:

  1. 调度线程从JobStore中获取需要执行的的触发器列表,并修改触发器的状态
  2. Fire触发器,修改触发器信息(下次执行触发器的时间,以及触发器状态),并存储
  3. 最后创建具体的执行任务对象,通过worker线程池执行任务

3 集群部署方案

没有负责集中管理的节点,而是利用数据库行级锁实现并发控制。

scheduler实例在集群模式先获取{0}LOCKS表中的行锁,MySQL获取行锁:

1.3 Quartz的行级锁

解决了任务的分布式调度问题,同一个任务只能有一个节点运行,其他节点将不执行任务,当碰到大量短任务时,各节点频繁的竞争数据库锁,节点越多性能越差。

本文由博客一文多发平台 OpenWrite 发布!

上一篇下一篇

猜你喜欢

热点阅读