本章節(jié)使用Quartz的基于內(nèi)存,非集群模式的任務(wù)調(diào)度StdScheduler講解

  <dependency>
      <groupId>org.quartz-scheduler</groupId>
      <artifactId>quartz</artifactId>
      <version>2.2.1</version>
  </dependency>

import org.quartz.*;
import org.quartz.impl.JobDetailImpl;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.triggers.AbstractTrigger;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Arrays;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * @author paul
 * @description
 * @date 2018/11/8
 */
public class QuartzTest {

    //    <dependency>
    //        <groupId>org.quartz-scheduler</groupId>
    //        <artifactId>quartz</artifactId>
    //        <version>2.2.1</version>
    //    </dependency>
    public static void main(String[] args) throws SchedulerException {
        SchedulerFactory schedulerFactory = new StdSchedulerFactory();
        Scheduler scheduler = schedulerFactory.getScheduler();
        JobDetailImpl jobDetail = (JobDetailImpl) JobBuilder.newJob(JobRun.class).build();
        {
            jobDetail.setName("JobDetail-A1");
            jobDetail.setGroup("Job-Group-A");
            JobDataMap jobDataMap = jobDetail.getJobDataMap();
            jobDataMap.put("job-data-key", "job-data-value");
        }

        CronTrigger cronTrigger = TriggerBuilder.newTrigger().startNow()
                .withSchedule(
                        CronScheduleBuilder.cronSchedule("*/1 * * * * ?").withMisfireHandlingInstructionDoNothing()
                ).build();
        {
            cronTrigger.getJobDataMap().put("trigger-data-key", "trigger-data-value");
            ((AbstractTrigger) cronTrigger).setName("SimpleTrigger-A1");
            ((AbstractTrigger) cronTrigger).setGroup("Trigger-Group-A");

            SchedulerContext context = scheduler.getContext();
            context.put("context-data-key", "context-data-value");
        }
        scheduler.scheduleJob(jobDetail, cronTrigger);
        scheduler.start();

    }

    @PersistJobDataAfterExecution //是否要存儲上一次運(yùn)行的數(shù)據(jù),只針對jobDetail.getJobDataMap()
    @DisallowConcurrentExecution  //不允許job對于在單trigger或者多trigger并發(fā)執(zhí)行
    public static class JobRun implements Job {
        private static final Logger LOGGER = LoggerFactory.getLogger(JobRun.class);
        public static final AtomicInteger ATOMIC_INTEGER = new AtomicInteger(0);

        @Override
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
            JobDataMap jobDataMap = jobExecutionContext.getJobDetail().getJobDataMap();
            LOGGER.info("run..." + Arrays.deepToString(jobDataMap.getKeys()));
            int i = ATOMIC_INTEGER.incrementAndGet();
            jobDataMap.put("key-" + i, "value-" + i);
        }
    }
}