Quartz 简单使用

Scheduler 每次执行，都会根据JobDetail创建一个新的Job实例，这样就可以规避并发访问的问题（jobDetail的实例也是新的）
Quzrtz 定时任务默认都是并发执行，不会等待上一次任务执行完毕，只要间隔时间到就会执行，如果定时任务执行太长，会长时间占用资源，导致其它任务堵塞
@DisallowConcurrentExecution: job类上，禁止并发地执行同一个job定义 (JobDetail定义的)的多个实例。
简单示例

TestClient.Java

1. import org.quartz.*;
2. import org.quartz.impl.StdSchedulerFactory;
4. public class TaskClient {
6.     public static void main(String[] args) {
7.         JobDetail jobDetail = JobBuilder.newJob(TaskJob.class)
8.                 .withIdentity("job1", "group1")  //设置JOB的名字和组
9.                 .build();
11.         Trigger trigger = TriggerBuilder.newTrigger()
12.                 .withIdentity("trigger1", "trigger1")
13.                 .startNow()
14.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1)
15.                         .repeatForever())
16.                 .build();
17.         try {
18.             Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
19.             scheduler.scheduleJob(jobDetail,trigger);
20.             scheduler.start();
21.         } catch (SchedulerException ex) {
22.             ex.printStackTrace();
23.         }
25.     }
27. }

复制代码

TaskJob.Java

1. import cn.hutool.core.date.DateUtil;
2. import org.quartz.Job;
3. import org.quartz.JobExecutionContext;
4. import org.quartz.JobExecutionException;
6. public class TaskJob implements Job {
7.     @Override
8.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
9.         System.out.println("TaskJob => " + DateUtil.now());
10.     }
11. }

复制代码

usingJobData

通过 usingJobData 往定时任务中传递参数

1. import org.quartz.*;
2. import org.quartz.impl.StdSchedulerFactory;
4. public class TaskClient {
6.     public static void main(String[] args) {
7.         JobDetail jobDetail = JobBuilder.newJob(TaskJob.class)
8.                 .withIdentity("job1", "group1")
9.                 .usingJobData("job","jobDetail1.JobDataMap.Value")
10.                 .build();
12.         Trigger trigger = TriggerBuilder.newTrigger()
13.                 .withIdentity("trigger1", "trigger1")
14.                 .usingJobData("trigger","trigger.JobDataMap.Value")
15.                 .startNow()
16.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1)
17.                         .repeatForever())
18.                 .build();
19.         try {
20.             Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
21.             scheduler.scheduleJob(jobDetail,trigger);
22.             scheduler.start();
23.         } catch (SchedulerException ex) {
24.             ex.printStackTrace();
25.         }
27.     }
29. }

复制代码

TaskJob.java

1. import org.quartz.Job;
2. import org.quartz.JobDataMap;
3. import org.quartz.JobExecutionContext;
4. import org.quartz.JobExecutionException;
6. public class TaskJob implements Job {
7.     @Override
8.     public void execute(JobExecutionContext context) throws JobExecutionException {
9.         JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
10.         JobDataMap triggerMap = context.getTrigger().getJobDataMap();
11.         JobDataMap mergeMap = context.getMergedJobDataMap();
14.         System.out.println("jobDataMap => " + jobDataMap.getString("job"));
15.         System.out.println("triggerMap => " + triggerMap.getString("trigger"));
16.         System.out.println("mergeMap => " + mergeMap.getString("trigger"));
17.     }
18. }

复制代码

通过 属性赋值

1. import org.quartz.*;
2. import org.quartz.impl.StdSchedulerFactory;
4. public class TaskClient {
6.     public static void main(String[] args) {
7.         JobDetail jobDetail = JobBuilder.newJob(TaskJob.class)
8.                 .withIdentity("job1", "group1")
9.                 .usingJobData("job","jobDetail1.JobDataMap.Value")
10.                 .usingJobData("name","jobDetail1.name.Value") //通过 setName 自动赋值
11.                 .build();
13.         Trigger trigger = TriggerBuilder.newTrigger()
14.                 .withIdentity("trigger1", "trigger1")
15.                 .usingJobData("trigger","trigger.JobDataMap.Value")
16.                 .usingJobData("name","trigger.name.Value")  //如果 Trigger 有值，会覆盖 JobDetail
17.                 .startNow()
18.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1)
19.                         .repeatForever())
20.                 .build();
21.         try {
22.             Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
23.             scheduler.scheduleJob(jobDetail,trigger);
24.             scheduler.start();
25.         } catch (SchedulerException ex) {
26.             ex.printStackTrace();
27.         }
29.     }
31. }

复制代码

1. import org.quartz.*;
3. public class TaskJob implements Job {
5.     private String name;
7.     public void setName(String name) {
8.         this.name = name;
9.     }
11.     @Override
12.     public void execute(JobExecutionContext context) throws JobExecutionException {
14.         System.out.println("name => " + name);
15.     }
16. }

复制代码

非并发执行

@DisallowConcurrentExecution job类上，禁止并发地执行同一个job定义 (JobDetail定义的)的多个实例。

1. import cn.hutool.core.date.DateUtil;
2. import org.quartz.*;
4. @DisallowConcurrentExecution
5. public class TaskJob implements Job {
7.     @Override
8.     public void execute(JobExecutionContext context) {
9.         System.out.println("Time => " + DateUtil.now());
10.         try {
11.             Thread.sleep(3000);
12.         } catch (InterruptedException e) {
13.             e.printStackTrace();
14.         }
15.     }
16. }

复制代码

@PersistJobDataAfterExecution
持久化JobDetail中的JobDataMap（对 trigger 中的 datamap 无效），如果一个任务不是

1. import cn.hutool.core.date.DateUtil;
3. import org.quartz.*;
5. //持久化JobDetail中的JobDataMap（对 trigger 中的 datamap 无效），如果一个任务不是
6. @PersistJobDataAfterExecution
7. public class TaskJob implements Job {
9.     @Override
10.     public void execute(JobExecutionContext context) {
11.         JobDataMap triggerMap = context.getJobDetail().getJobDataMap();
12.         triggerMap.put("count", triggerMap.getInt("count") + 1);
13.         System.out.println("Time => " + DateUtil.now() + " count =>" + triggerMap.getInt("count"));
15.     }
16. }

复制代码

Client

1. import org.quartz.*;
2. import org.quartz.impl.StdSchedulerFactory;
4. public class TaskClient {
6.     public static void main(String[] args) {
7.         JobDetail jobDetail = JobBuilder.newJob(TaskJob.class)
8.                 .withIdentity("job1", "group1")
9.                 .usingJobData("job","jobDetail1.JobDataMap.Value")
10.                 .usingJobData("name","jobDetail1.name.Value") //通过 setName 自动赋值
11.                 .usingJobData("count",0) //通过 setName 自动赋值
12.                 .build();
14.         Trigger trigger = TriggerBuilder.newTrigger()
15.                 .withIdentity("trigger1", "trigger1")
16.                 .usingJobData("trigger","trigger.JobDataMap.Value")
17.                 .usingJobData("name","trigger.name.Value")  //如果 Trigger 有值，会覆盖 JobDetail
18.                 .startNow()
19.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1)
20.                         .repeatForever())
21.                 .build();
22.         try {
23.             Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
24.             scheduler.scheduleJob(jobDetail,trigger);
25.             scheduler.start();
26.         } catch (SchedulerException ex) {
27.             ex.printStackTrace();
28.         }
30.     }
32. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！