在pom.xml
配置文件内添加,如下配置:
相关配置
内存方式
ApiBoot Quartz
在使用内存方式存储任务时,不需要做配置调整。
需要在application.yml
配置文件内修改api.boot.quartz.job-store-type
参数,如下所示:
- api:
- boot:
- quartz:
- # Jdbc方式
- job-store-type: jdbc
Quartz所需表结构
Quartz
的数据库方式内部通过DataSource
获取数据库连接对象来进行操作数据,所操作数据表的表结构是固定的,ApiBoot
把Quartz
所支持的所有表结构都进行了整理,访问Quartz支持数据库建表语句列表查看,复制执行对应数据库语句即可。
创建任务类
我们只需要让新建类集成QuartzJobBean
就可以完成创建一个任务类,如下简单示例:
- /**
- * 任务定义示例
- * 与Quartz使用方法一致,ApiBoot只是在原生基础上进行扩展,不影响原生使用
- * <p>
- * 继承QuartzJobBean抽象类后会在项目启动时会自动加入Spring IOC
- *
- * @author:恒宇少年 - 于起宇
- * <p>
- * DateTime:2019-03-28 17:26
- * WebSite:http://www.jianshu.com/u/092df3f77bca
- * Gitee:https://gitee.com/hengboy
- * GitHub:https://github.com/hengboy
- */
- public class DemoJob extends QuartzJobBean {
- /**
- * logger instance
- */
- static Logger logger = LoggerFactory.getLogger(DemoJob.class);
- @Override
- protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
- logger.info("定时任务Job Key : {}", context.getJobDetail().getKey());
- logger.info("定时任务执行时所携带的参数:{}", JSON.toJSONString(context.getJobDetail().getJobDataMap()));
- //...处理逻辑
- }
- }
任务参数
在任务执行时传递参数是必须的,ApiBoot Quartz
提供了比较方便的传递方式,不过最终Quartz
会把传递的值都会转换为String
类型数据。
任务Key默认值
自定义任务开始时间
任务开始时间可以通过startAtTime
方法进行设置,在不设置的情况下,任务创建完成后会立刻执行。
Cron 表达式任务
创建Cron
类型任务如下所示:
Cron 表达式任务由ApiBootCronJobWrapper
类进行构建。
上面的DemoJob
任务类将会每隔5秒
执行一次。
Loop 重复任务
Loop
循环任务,当在不传递重复执行次数时,不进行重复执行,仅仅执行一次,如下所示:
- String jobKey = apiBootQuartzService.newJob(
- ApiBootLoopJobWrapper.Context()
- // 参数
- .param(
- ApiBootJobParamWrapper.wrapper()
- .put("userName", "恒宇少年")
- .put("userAge", 24)
- )
- // 每次循环的间隔时间,单位:毫秒
- .loopIntervalTime(2000)
- // 循环次数
- .repeatTimes(5)
- // 开始时间,10秒后执行
- // 任务类
- .jobClass(DemoJob.class)
- .wrapper()
- );
Loop 任务由ApiBootLoopJobWrapper
类进行构建。
上面的定时任务将会重复执行5次
,连上自身执行的一次也就是会执行6次
,每次的间隔时间为2秒
,在任务创建10秒
后进行执行。
Once 一次性任务
- Map paramMap = new HashMap(1);
- paramMap.put("paramKey", "参数值");
- String jobKey = apiBootQuartzService.newJob(
- ApiBootOnceJobWrapper.Context()
- .jobClass(DemoJob.class)
- // 参数
- .param(
- ApiBootJobParamWrapper.wrapper()
- .put("mapJson", JSON.toJSONString(paramMap))
- )
- // 开始时间,2秒后执行
- .startAtTime(new Date(System.currentTimeMillis() + 2000))
- .wrapper()
- );
Once 任务由ApiBootOnceJobWrapper
类进行构建。
在参数传递时可以是对象、集合,不过需要进行转换成字符串才可以进行使用。
暂停任务执行
任务在执行过程中可以进行暂停操作,通过ApiBoot Quartz
提供的pauseJob
方法就可以很简单的实现,当然暂停时需要传递Job Key
,Job Key
可以从创建任务方法返回值获得。
暂停任务如下所示:
任务执行完暂停后,如果想要恢复可以使用如下方式:
- // 恢复指定Job Key的任务执行
- apiBootQuartzService.resumeJob(jobKey);
- // 恢复多个暂停任务
- apiBootQuartzService.resumeJobs(jobKey,jobKey,jobKey);
修改Cron表达式
修改表达式的场景如下:
- 已创建 & 未执行
- 已创建 & 已执行
修改方法如下所示:
- // 修改执行Job Key任务的Cron表达式
- apiBootQuartzService.updateJobCron(jobKey, "0/5 * * * * ?");
删除任务
想要手动释放任务时可以使用如下方式:
- 暂停触发器
- 移除触发器
- 删除任务