Quartz 存储方式有两种：MEMORY 和 JDBC。默认是内存形式维护任务信息，意味着服务重启了任务就从头再来，就像喝酒断片了一样；而 JDBC 形式就是能够把任务信息持久化到数据库，虽然服务重启了，依然还能接着来。
1. 内存方式存储任务信息
1.1 定义任务类
可以通过实现 Job 接口来定义任务，也可以通过继承 QuartzJobBean 这个抽象类来定义任务，其实 QuartzJobBean 本身也实现了 Job 接口，其本质都是实现 Job 接口来定义任务。
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;/*** 定义任务*/
public class DongAoJob extends QuartzJobBean {private static final Log logger = LogFactory.getLog(DongAoJob.class);@Overrideprotected void executeInternal(JobExecutionContext context) throws JobExecutionException {logger.info("幼年是盼盼，青年是晶晶，中年是冰墩墩，生活见好逐渐发福");}
}1.2 定义任务描述及任务触发规则
定义每隔 5 秒执行一次任务，代码如下
import com.example.demo.quartz.task.DongAoJob;
import org.quartz.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 定义任务描述和具体的执行时间*/
@Configuration
public class QuartzConfig {@Beanpublic JobDetail jobDetail() {//指定任务描述具体的实现类return JobBuilder.newJob(DongAoJob.class)// 指定任务的名称.withIdentity("dongAoJob")// 任务描述.withDescription("任务描述：用于输出冬奥欢迎语")// 每次任务执行后进行存储.storeDurably().build();}@Beanpublic Trigger trigger() {//创建触发器return TriggerBuilder.newTrigger()// 绑定工作任务.forJob(jobDetail())// 每隔 5 秒执行一次 job.withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(5)).build();}
}1.3 程序入口 main 函数
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class DemoJobApplication {public static void main(String[] args) {SpringApplication.run(DemoJobApplication.class, args);}
}
2. 数据库方式存储任务信息
2.1 引入依赖
在 pom.xml 文件中加入如下依赖信息。
2.3 初始化 Quartz 数据表信息
下载 Quartz 发布包，下载完成后，解压缩进入 quartz-2.2.3/docs/dbTables 目录，找到匹配数据库的 SQL 文件。
动态任务管理与高级特性
在实际应用中，你可能需要动态地添加、修改或删除任务。Quartz提供了强大的API来支持这些操作。通过注入Scheduler实例，你可以实现对任务的动态管理。以下是一个动态任务管理的示例：
import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class QuartzService {@Autowiredprivate Scheduler scheduler;/** * 添加任务 * * @param jobName 任务名称 * @param jobGroup 任务组 * @param jobClass 任务类 * @param cron Cron表达式 * @throws SchedulerException*/public void addJob(String jobName, String jobGroup, Class<? extends Job> jobClass, String cron) throws SchedulerException {JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroup).build();Trigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroup).withSchedule(CronScheduleBuilder.cronSchedule(cron)).build();scheduler.scheduleJob(jobDetail, trigger);}/** * 删除任务 * * @param jobName 任务名称 * @param jobGroup 任务组 * @throws SchedulerException*/public void deleteJob(String jobName, String jobGroup) throws SchedulerException {scheduler.deleteJob(JobKey.jobKey(jobName, jobGroup));}/** * 暂停任务 * * @param jobName 任务名称 * @param jobGroup 任务组 * @throws SchedulerException*/public void pauseJob(String jobName, String jobGroup) throws SchedulerException {scheduler.pauseJob(JobKey.jobKey(jobName, jobGroup));}/** * 恢复任务 * * @param jobName 任务名称 * @param jobGroup 任务组 * @throws SchedulerException*/public void resumeJob(String jobName, String jobGroup) throws SchedulerException {scheduler.resumeJob(JobKey.jobKey(jobName, jobGroup));}
}
通过这个服务类，你可以动态地管理任务的生命周期，例如在运行时添加新的任务、暂停或恢复任务，以及删除不再需要的任务。这种动态管理能力使得Quartz能够适应复杂多变的业务需求，为你的应用提供强大的灵活性。