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

https://blog.csdn.net/asd1098626303/article/details/80831114

最近在做一个彩票相关的项目，主要涉及到不定时开奖，不定时封盘，原本打算使用springboot 自带的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:

uildscript {

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();

}

运行效果：

拓展阅读：

where2go 团队

微信号：算法与编程之美

本站仅提供存储服务，所有内容均由用户发布，如发现有害或侵权内容，请点击举报。