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

JavaEdge

发布于 2023-11-08 10:07:19

4280

发布于 2023-11-08 10:07:19

文章被收录于专栏：JavaEdge

1 任务调度整体流程

2 组件

调度器：工厂类创建Scheduler，根据触发器定义的时间规则调度任务
任务：Job表示被调度的任务
触发器：Trigger 定义调度时间的元素，按啥时间规则执行任务。一个Job可被多个Trigger关联，但是一个Trigger 只能关联一个Job

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：