最近在做一個彩票相關的專案，主要涉及到不定時開獎，不定時封盤，原本打算使用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();
        }

    }

}

執行效果：