首先介绍maven依赖

quartz依赖如下

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

对应的Spring的版本是

<spring-version>4.2.3.RELEASE</spring-version>

applicationContext-job.xml对应的配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd"><!--自动注入工厂--><bean id="jobFactory" class="com.payment.scheduled.JobFactory"/><!-- 总配置 --><bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"><property name="jobFactory" ref="jobFactory"></property><!-- 加载 quartz.properties--><property name="configLocation" value="classpath:config/tes/quartz.properties"/></bean><!--第一次加载时启动--><bean id="jobService" class="com.payment.scheduled.task.JobService" init-method="loadJob"/>
</beans>

配置做啥用的这里再简单描述一下

jobFactory是提供对应定时任务代码的自动注入用的，不然定时任务代码注解是会报null值异常的。

jobService是系统启动时，默认运行一次的定时任务，这是为了从数据库中取出，需要运行的定时任务。

现在是最重要的类，代码如下

package com.payment.scheduled;import org.quartz.*;
import org.quartz.impl.triggers.CronTriggerImpl;
import org.springframework.stereotype.Component;import javax.annotation.Resource;/*** Created by hogan on 2018/9/14.*/
@Component
public class DynamicJobFactory {@Resourceprivate Scheduler scheduler;/*** 添加job** @param className* @param cronExpression* @throws Exception*/public void addJob(String className, String cronExpression) throws Exception {Class clazz = Class.forName(className);JobDetail jobDetail = JobBuilder.newJob(clazz).withIdentity("jobName:" + className, Scheduler.DEFAULT_GROUP)//如果需要给任务传递参数，可以用setJobData来设置参数.setJobData(new JobDataMap()).build();CronTriggerImpl cronTrigger = new CronTriggerImpl();cronTrigger.setName("jobTrigger:" + className);cronTrigger.setCronExpression(cronExpression);JobKey jobKey = new JobKey("jobName:" + className, Scheduler.DEFAULT_GROUP);if (!scheduler.checkExists(jobKey)) {scheduler.scheduleJob(jobDetail, cronTrigger);}}/*** 暂停job** @param className* @throws Exception*/public void pauseJob(String className) throws Exception {JobKey jobKey = new JobKey("jobName:" + className, Scheduler.DEFAULT_GROUP);scheduler.pauseJob(jobKey);}/*** 重启job** @param className* @throws Exception*/public void resumeJob(String className) throws Exception {JobKey jobKey = new JobKey("jobName:" + className, Scheduler.DEFAULT_GROUP);scheduler.resumeJob(jobKey);}/*** 停止job** @param className* @throws Exception*/public void stopJob(String className) throws Exception {JobKey jobKey = new JobKey("jobName:" + className, Scheduler.DEFAULT_GROUP);scheduler.deleteJob(jobKey);}/*** 修改job的执行时间** @param className* @param cronExpression* @throws Exception*/public void updateJobTime(String className, String cronExpression) throws Exception {TriggerKey triggerKey = new TriggerKey("jobTrigger:" + className, Scheduler.DEFAULT_GROUP);CronTriggerImpl trigger = (CronTriggerImpl) scheduler.getTrigger(triggerKey);if (trigger == null) {return;}String oldTime = trigger.getCronExpression();if (!oldTime.equalsIgnoreCase(cronExpression)) {trigger.setCronExpression(cronExpression);scheduler.rescheduleJob(triggerKey, trigger);}}/*** 获取job信息** @param className* @return JobDetail* @throws Exception*/public JobDetail getJobDetail(String className) throws Exception {JobKey jobKey = new JobKey("jobName:" + className, Scheduler.DEFAULT_GROUP);JobDetail detail = scheduler.getJobDetail(jobKey);return detail;}/*** 启动所有的任务** @throws Exception*/public void startJobs() throws Exception {scheduler.start();}/*** shutdown所有的任务** @throws Exception*/public void shutdownJobs() throws Exception {if (!scheduler.isShutdown()) {scheduler.shutdown();}}
}

这里对这个类使用了 @Component注解，我是扫描后注入ServiceImpl中使用，所以我这里是这样配置的

<!--配置自动扫描service-->
<context:component-scan base-package="com.payment.service" />
<context:component-scan base-package="com.payment.security" />
<!--配置自动扫描定时任务-->
<context:component-scan base-package="com.payment.scheduled"/>

先扫描Service，再扫描

对应的DynamicJobFactory类，然后在对应ServiceImpl中注入，并通过界面添加定时任务后调用，具体代码如下

@Service
@Slf4j
public class POrderServiceImpl implements POrderService {@Referenceprivate OrderProvider orderProvider;@Resourceprivate DynamicJobFactory dynamicJobFactory;String className = "com.payment.service.impl.task.UserFlowTaskServiceImpl";String cronExpression = "0 */1 * * * ?";/*** 生成定时任务** @param queryOrderDTO* @return PageResultBean*/@Overridepublic PageResultBean addTask(QueryOrderDTO queryOrderDTO) {try {dynamicJobFactory.addJob(className, cronExpression);} catch (Exception e){e.printStackTrace();}return new PageResultBean();}}

这里例子用的是 每隔1分钟执行一次 com.payment.service.impl.task.UserFlowTaskServiceImpl 代码中的逻辑。

UserFlowTaskServiceImpl代码逻辑如下

@Slf4j
public class UserFlowTaskServiceImpl extends QuartzJobBean {@AutowiredSysTaskLogMapper sysTaskLogMapper;@Resource(name="transactionManager")private DataSourceTransactionManager transactionManager;/*** 用户流水定时任务*/@Overridepublic void executeInternal(JobExecutionContext context) {DefaultTransactionDefinition def = new DefaultTransactionDefinition();def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);TransactionStatus transactionStatus = transactionManager.getTransaction(def); // 获得事务状态try {log.error("流水定时任务Start");this.insetLog("测试流水定时任务");if (1 == 1) {transactionManager.rollback(transactionStatus);throw new SqlException("测试回滚");}transactionManager.commit(transactionStatus);log.error("流水定时任务End");} catch (Exception e) {log.error(PrintUtil.errInfo(e));throw new SqlException(e.getMessage());}}private void insetLog(String memo) {SysTaskLog record = new SysTaskLog();record.setTaskName("111");record.setMemo(memo);record.setCreateDate(DateUtil.nowDate());sysTaskLogMapper.insertSelective(record);}
}

简单分析下，对应的定时任务实现类需要继承QuartzJobBean类

这里事务如果需要回滚的话，需要单独启用事务，然后手动提交及回滚。

然后界面添加定时任务及定时任务自动启动这块就完结了。现在添加定时任务表，表结构如下

drop table if exists SYS_TASK;/*==============================================================*/
/* Table: SYS_TASK                                              */
/*==============================================================*/
create table SYS_TASK
(SYS_TASK_ID          int(10) not null auto_increment comment '定时任务表ID',BEAN_NAME            varbinary(200) comment 'spring bean名称',METHOD_NAME          varbinary(100) comment '方法名称',CRON_EXPRESSION      varchar(100) comment 'cron表达式',STATUS               varchar(2) comment '任务状态 0:禁用 1:启用',REMARKS              varchar(255) comment '备注',CREATE_USER          varchar(32) comment '创建人',CREATE_DATE          datetime comment '创建时间',UPDATE_USER          varchar(32) comment '修改人',UPDATE_DATE          datetime comment '修改时间',primary key (SYS_TASK_ID)
);alter table SYS_TASK comment '定时任务表';

现在插入一条数据

默认1分钟执行一次，现在问题是，我需要系统启动代码时，就会去查询列表，然后执行对应状态值为1(启用)的定时任务，这里就需要上面提到的JobService类了，对应代码如下

@Slf4j
@Service
public class JobService {@ResourceDynamicJobFactory dynamicJobFactory;@AutowiredSysTaskMapper sysTaskMapper;public void loadJob() throws Exception {log.error("调用定时任务Start");List<SysTask> sysTaskList = sysTaskMapper.querySysTaskListByStatus(Constants.STATUS_ENABLED);for (SysTask sysTask : sysTaskList) {dynamicJobFactory.addJob(sysTask.getBeanName(), sysTask.getCronExpression());}log.error("调用定时任务End");}}

为了方便查看日志，是用的error输出的日志，修改下日志级别为error，启动项目，项目启动成功后依次调用了定时任务，日志如下

因为代码中添加了回滚，所以本次没有录入日志，对应数据库中日志表数据为空

现在修改下代码，修改后代码如下

@Slf4j
public class UserFlowTaskServiceImpl extends QuartzJobBean {@AutowiredSysTaskLogMapper sysTaskLogMapper;@Resource(name="transactionManager")private DataSourceTransactionManager transactionManager;/*** 用户流水定时任务*/@Overridepublic void executeInternal(JobExecutionContext context) {DefaultTransactionDefinition def = new DefaultTransactionDefinition();def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);TransactionStatus transactionStatus = transactionManager.getTransaction(def); // 获得事务状态try {log.error("流水定时任务Start");this.insetLog("测试流水定时任务");
//            if (1 == 1) {
//                transactionManager.rollback(transactionStatus);
//                throw new SqlException("测试回滚");
//            }transactionManager.commit(transactionStatus);log.error("流水定时任务End");} catch (Exception e) {log.error(PrintUtil.errInfo(e));throw new SqlException(e.getMessage());}}private void insetLog(String memo) {SysTaskLog record = new SysTaskLog();record.setTaskName("111");record.setMemo(memo);record.setCreateDate(DateUtil.nowDate());sysTaskLogMapper.insertSelective(record);}
}

启动项目，现在项目输出日志为

对应日志表中的数据如下

具体代码告一段落，剩下的无非就是开发界面，开发Controller，根据Controller中录入，调用addJob，修改定时任务调用updateJobTime，停用删除调用stopJob，这些就不啰嗦了。