spring boot 2.0 quartz 轻松实现定时任务和作业调度 - 好文

    最近在做一个彩票相关的项目，主要涉及到不定时开奖，不定时封盘，原本打算使用spring boot
自带的Schedule进行这一系列的工作，由于不能自动的添加定时任务，所以使用quartz，spring boot
2.0集成了quartz，所以决定尝试下quartz用于实现作业调度。

做的时候查看了很多资料，都写的花里胡哨的，要么就是做的东西太完整了，要么就是完全不能理解，要么就是很早以前的做法了，让人很头晕，所以说做个很简单明了的教程，说一下如何使用

    https://docs.spring.io/spring-boot/docs/2.0.3.RELEASE/reference/htmlsingle/#boot-features-quartz

build.gradle:
buildscript { ext { springBootVersion = '2.0.3.RELEASE' } repositories {
maven{ url 'http://maven.aliyun.com/nexus/content/groups/public'} }
dependencies {
classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
} } apply plugin: 'java' apply plugin: 'idea' apply plugin:
'org.springframework.boot' apply plugin: 'io.spring.dependency-management'
group = 'com.zhu' version = '0.0.1-SNAPSHOT' sourceCompatibility = 1.8
repositories { maven{ url
'http://maven.aliyun.com/nexus/content/groups/public'} } dependencies {
compile('org.springframework.boot:spring-boot-starter-web')
compile('org.springframework.boot:spring-boot-starter-quartz')
testCompile('org.springframework.boot:spring-boot-starter-test') }
build.gradle中引入spring-boot-starter-quartz

之后如果没什么特殊需求的话，根本不需要任何的花里胡哨的配置，直接编码。

    创建
ScheduleService.java，用于创建定时任务，这里动态的创建了两个定时任务，每隔1秒和每隔2秒运行。创建时需要新建JobDetail（任务）以及CronTrigger（定时任务触发器）
，并且scheduler.scheduleJob(jobDetail,cronTrigger);把任务添加到任务队列中。
package com.zhu.zqjc.schedule; import com.zhu.zqjc.bean.enums.FootballStatus;
import com.zhu.zqjc.dao.FootBallMatchDao; import
com.zhu.zqjc.entity.FootBallMatch; import org.quartz.*; import
org.springframework.beans.factory.annotation.Autowired; import
org.springframework.stereotype.Service; import
org.springframework.web.bind.annotation.GetMapping; import
java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import
java.util.List; @Service public class ScheduleService { @Autowired private
Scheduler scheduler; public void testScheduleTask() throws SchedulerException {
for (int i = 1; i < 3; i++) { JobDetail jobDetail =
JobBuilder.newJob(TestSchedule.class) .withIdentity("updateMatch"+i,
"updateMatch") .withDescription("定时比赛Id为"+i) .build(); //cron表达式表示每隔i秒执行
CronScheduleBuilder scheduleBuilder =
CronScheduleBuilder.cronSchedule(String.format("0/%d * * * * ? ",i))
.withMisfireHandlingInstructionDoNothing(); CronTrigger cronTrigger =
TriggerBuilder.newTrigger() .withIdentity("updateMatch"+i, "updateMatch")
.withDescription("定时比赛Id为"+i) .withSchedule(scheduleBuilder)
.startNow().build(); scheduler.scheduleJob(jobDetail,cronTrigger); } } }
TestSchedule.java 定时任务的执行类，在executeInternal函数中执行定时任务的逻辑
package com.zhu.zqjc.schedule; import org.quartz.JobExecutionContext; import
org.quartz.JobExecutionException; import
org.springframework.scheduling.quartz.QuartzJobBean; public class TestSchedule
extends QuartzJobBean { /** * Execute the actual job. The job data map will
already have been * applied as bean property values by execute. The contract is
* exactly the same as for the standard Quartz execute method. * * @param
context * @see #execute */ @Override protected void
executeInternal(JobExecutionContext context) throws JobExecutionException {
System.out.println("定时任务执行 " + context.getJobDetail().getDescription()); } }
StartListen.java 执行定时任务
package com.zhu.zqjc.listener; import com.zhu.zqjc.bean.enums.FootballStatus;
import com.zhu.zqjc.conf.SystemConf; import com.zhu.zqjc.dao.FootBallMatchDao;
import com.zhu.zqjc.entity.FootBallMatch; import
com.zhu.zqjc.schedule.ScheduleService; import
com.zhu.zqjc.schedule.UpdateMatchSchedule; import org.quartz.*; import
org.springframework.beans.factory.annotation.Autowired; import
org.springframework.beans.factory.annotation.Value; import
org.springframework.boot.context.event.ApplicationReadyEvent; import
org.springframework.context.ApplicationListener; import
org.springframework.stereotype.Component; import
weixin.popular.support.TokenManager; import java.util.Arrays; import
java.util.List; /** * Created by zhu yingzhi on 2018/6/6. * @author yingzhi zhu
* */ @Component public class StartListen implements
ApplicationListener<ApplicationReadyEvent> { @Autowired private ScheduleService
scheduleService; @Override public void onApplicationEvent(final
ApplicationReadyEvent event) { try { scheduleService.testScheduleTask(); }
catch (Exception e) { e.printStackTrace(); } } }
运行效果：

热门工具换一换