quartz学习笔记(一)简单入门

xiaoxiao2021-02-28  8

前言

quartz是Java编写的一款开源的任务调度开发框架,在项目开发中很多场景都可以用到,比如订单超期自动收货。

所谓程序源于生活,生活中也有很多场景可以用quartz来模拟,比如工作日早上七点起床,再比如,每天八杯水,

隔一小时一杯,在这里我就根据这两个例子来给大家初步介绍quartz。

粗糙类图+流程介绍

1.简要画一下quartz大致结构,画的不好,还望见谅:)

 

 

2.使用quartz开发,首先得知道自己的需要去完成的任务,quartz提供一个Job接口,只要实现它的execute()方法即可,然后创建调度工厂拿到调度实例,

设置好触发器,将任务和触发器加入到调度中即可,具体实现请参考后续代码。

 

编码实现

开发环境

gradle 4.1 quartz 2.2.1 jdk1.7

新建gradle项目

group 'com.haq.quartz' version '1.0-SNAPSHOT' apply plugin: 'java' sourceCompatibility = 1.7 repositories { mavenCentral() } dependencies { compile group: 'org.quartz-scheduler', name: 'quartz', version: '2.2.1' compile group: 'org.slf4j', name: 'slf4j-api', version: '1.7.21' compile group: 'ch.qos.logback', name: 'logback-core', version: '1.1.7' compile group: 'ch.qos.logback', name: 'logback-classic', version: '1.1.7' testCompile group: 'junit', name: 'junit', version: '4.12' }

 创建quartz配置文件quartz.properties

1 #============================================================================ 2 # Scheduler configration 3 #============================================================================ 4 org.quartz.scheduler.instanceName = MyScheduler 5 org.quartz.scheduler.instanceId = AUTO 6 7 org.quartz.scheduler.skipUpdateCheck: true 8 9 #============================================================================ 10 # jobstore configration 11 #============================================================================ 12 org.quartz.jobStore.class=org.quartz.simpl.RAMJobStore 13 #============================================================== 14 # threadPool configuration 15 #============================================================== 16 #org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool 17 org.quartz.threadPool.threadCount = 10 18 #org.quartz.threadPool.threadPriority = 5 19 #org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

新建任务类

分别创建MorningJob和DrinkJob

1 package com.haq.quartz.job; 2 3 import org.quartz.Job; 4 import org.quartz.JobExecutionContext; 5 import org.quartz.JobExecutionException; 6 import org.slf4j.Logger; 7 import org.slf4j.LoggerFactory; 8 9 import java.util.Date; 10 11 public class DrinkJob implements Job { 12 13 private static final Logger log = LoggerFactory.getLogger(DrinkJob.class); 14 15 @Override 16 public void execute(JobExecutionContext context) throws JobExecutionException { 17 log.info(new Date() + " hey! it is time to drink some water!"); 18 } 19 20 } 1 package com.haq.quartz.job; 2 3 import org.quartz.Job; 4 import org.quartz.JobExecutionContext; 5 import org.quartz.JobExecutionException; 6 import org.quartz.JobKey; 7 import org.slf4j.Logger; 8 import org.slf4j.LoggerFactory; 9 10 import java.util.Date; 11 12 public class MorningJob implements Job { 13 14 private static final Logger log = LoggerFactory.getLogger(MorningJob.class); 15 16 @Override 17 public void execute(JobExecutionContext context) throws JobExecutionException { 18 log.info(new Date() + " Morning , it is time to get up!"); 19 } 20 }

创建调度类 TestSchedule

1 package com.haq.quartz.schedule; 2 3 import com.haq.quartz.job.DrinkJob; 4 import com.haq.quartz.job.MorningJob; 5 import org.quartz.*; 6 import org.quartz.impl.StdSchedulerFactory; 7 8 9 public class TestSchedule { 10 public static void main(String[] args) throws SchedulerException, InterruptedException { 11 SchedulerFactory sf = new StdSchedulerFactory(); 12 13 Scheduler scheduler = sf.getScheduler(); 14 JobDetail drinkjob = JobBuilder.newJob(DrinkJob.class) 15 .withIdentity("drinkjob", "group1") 16 .build(); 17 Trigger drinktrgger = TriggerBuilder.newTrigger() 18 .withIdentity("drinktrgger", "group1") 19 .startNow() 20 .withSchedule(SimpleScheduleBuilder.simpleSchedule() 21 // .withIntervalInHours(1) 为方便测试,改为5秒执行一次 22 .withIntervalInSeconds(5) 23 .withRepeatCount(8)) 24 .build(); 25 26 27 28 JobDetail morningjob = JobBuilder.newJob(MorningJob.class) 29 .withIdentity("morningjob", "group1") 30 .build(); 31 Trigger morningtrgger = TriggerBuilder.newTrigger() 32 .withIdentity("morningtrgger", "group1") 33 .startNow() 34 .withSchedule(DailyTimeIntervalScheduleBuilder.dailyTimeIntervalSchedule() 35 // .onMondayThroughFriday() 为方便测试将时间调整为当前时间 36 .onSaturdayAndSunday() 37 .startingDailyAt(new TimeOfDay(12,35,0)) 38 .withRepeatCount(5)) 39 .build(); 40 41 42 scheduler.scheduleJob(drinkjob, drinktrgger); 43 scheduler.scheduleJob(morningjob, morningtrgger); 44 45 scheduler.start(); 46 47 Thread.sleep(90L * 1000L); 48 49 scheduler.shutdown(); 50 } 51 }

运行结果如下:

源码下载:

https://github.com/xiaodongio/quartz_learning/tree/day1

  

 

转载请注明原文地址: https://www.6miu.com/read-1100213.html

最新回复(0)