Spring4+Springmvc+quartz實作多線程動态定時排程

scheduler定時排程系統是大多行業項目都需要的，傳統的spring-job模式，個人感覺已經out了，因為存在很多的問題，特别是定時排程的追加、修改、删除等，需要修改xml，xml的配置生效無非是熱部署灰階釋出方案或者直接停止、重新開機伺服器，完全不能做到自動啟動、修複方式。

提醒：可以對應用進行叢集部署，在對定時排程配置時可以使用叢集方式或者單邊配置應用方式，今天講解的是使用spring4+scheduler實作定時排程，閑話少說，直接把步驟記錄下來：

1. 在項目的pom.xml檔案中引入quartz的jar包，如下：

Java代碼

lt;dependency>

<groupId>org.quartz-scheduler</groupId>

<artifactId>quartz</artifactId>

lt;/dependency>

2. 定義quartz的配置檔案spring-context-quartz.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"

xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="

http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd

http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd"

default-lazy-init="false">

</bean>

</beans>

3. 在項目的web.xml檔案中引入spring-context-quartz.xml配置檔案

classpath*:spring-context-quartz.xml

4. 定義job實體對象

public class Job{

private static final long serialVersionUID = 1L;

/**

* 任務執行周期cron表達式

public static int EXECYCLE_CRON = 2;

* 任務執行周期自定義

public static int EXECYCLE_DEFINE = 1;

* 執行周期-分鐘

public static int EXECYCLE_MINUTE = 1;

* 執行周期-小時

public static int EXECYCLE_HOUR = 2;

* 執行周期-日

public static int EXECYCLE_DAY = 3;

* 執行周期-月

public static int EXECYCLE_WEEK = 4;

public static int EXECYCLE_MONTH = 5;

private String jobType; // 任務類型(1首頁靜态化、2欄目頁靜态化、3内容頁靜态化、4采集、5分發)

private String jobName; // 任務名稱

private String jobClass; // 任務類

private String execycle; // 執行周期分類(1非表達式 2 cron表達式)

private String dayOfMonth; // 每月的哪天

private String dayOfWeek; // 周幾

private String hour; // 小時

private String minute; // 分鐘

private String intervalHour; // 間隔小時

private String intervalMinute; // 間隔分鐘

private String jobIntervalUnit; // 1分鐘、2小時、3日、4周、5月

private String cronExpression; // 規則表達式

private String isEnable; // 是否啟用

public Job() {

super();

}

public Job(String id){

super(id);

@Length(min=1, max=1, message="任務類型(1首頁靜态化、2欄目頁靜态化、3内容頁靜态化、4采集、5分發)長度必須介于 1 和 1 之間")

public String getJobType() {

return jobType;

public void setJobType(String jobType) {

this.jobType = jobType;

@Length(min=1, max=255, message="任務名稱長度必須介于 1 和 255 之間")

public String getJobName() {

return jobName;

public void setJobName(String jobName) {

this.jobName = jobName;

@Length(min=1, max=255, message="任務類長度必須介于 1 和 255 之間")

public String getJobClass() {

return jobClass;

public void setJobClass(String jobClass) {

this.jobClass = jobClass;

@Length(min=1, max=1, message="執行周期分類(1非表達式 2 cron表達式)長度必須介于 1 和 1 之間")

public String getExecycle() {

return execycle;

public void setExecycle(String execycle) {

this.execycle = execycle;

@Length(min=0, max=11, message="每月的哪天長度必須介于 0 和 11 之間")

public String getDayOfMonth() {

return dayOfMonth;

public void setDayOfMonth(String dayOfMonth) {

this.dayOfMonth = dayOfMonth;

@Length(min=0, max=1, message="周幾長度必須介于 0 和 1 之間")

public String getDayOfWeek() {

return dayOfWeek;

public void setDayOfWeek(String dayOfWeek) {

this.dayOfWeek = dayOfWeek;

@Length(min=0, max=11, message="小時長度必須介于 0 和 11 之間")

public String getHour() {

return hour;

public void setHour(String hour) {

this.hour = hour;

@Length(min=0, max=11, message="分鐘長度必須介于 0 和 11 之間")

public String getMinute() {

return minute;

public void setMinute(String minute) {

this.minute = minute;

@Length(min=0, max=11, message="間隔小時長度必須介于 0 和 11 之間")

public String getIntervalHour() {

return intervalHour;

public void setIntervalHour(String intervalHour) {

this.intervalHour = intervalHour;

@Length(min=0, max=11, message="間隔分鐘長度必須介于 0 和 11 之間")

public String getIntervalMinute() {

return intervalMinute;

public void setIntervalMinute(String intervalMinute) {

this.intervalMinute = intervalMinute;

@Length(min=0, max=1, message="1分鐘、2小時、3日、4周、5月長度必須介于 0 和 1 之間")

public String getJobIntervalUnit() {

return jobIntervalUnit;

public void setJobIntervalUnit(String jobIntervalUnit) {

this.jobIntervalUnit = jobIntervalUnit;

@Length(min=0, max=255, message="規則表達式長度必須介于 0 和 255 之間")

public String getCronExpression() {

return cronExpression;

public void setCronExpression(String cronExpression) {

this.cronExpression = cronExpression;

@Length(min=1, max=1, message="是否啟用長度必須介于 1 和 1 之間")

public String getIsEnable() {

return isEnable;

public void setIsEnable(String isEnable) {

this.isEnable = isEnable;

}

5. 編寫quartz的jobServvice類：

package com.ml.honghu.job.service;

import java.text.ParseException;

import java.util.List;

import java.util.UUID;

import org.quartz.CronTrigger;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import com.ml.honghu.StringUtils;

import com.ml.honghu.common.persistence.Page;

import com.ml.honghu.common.service.CrudService;

import com.ml.honghu.job.dao.JobDao;

import com.ml.honghu.job.entity.Job;

/**

* 定時排程任務Service

* @author honghu

@Service

@Transactional(readOnly = true)

public class JobService extends CrudService<JobDao, Job> {

@Autowired

private JobDao jobDao;

private Logger logger = LoggerFactory.getLogger(getClass());

public Job get(String id) {

return super.get(id);

public List<Job> findList(Job job) {

return super.findList(job);

public Page<Job> findPage(Page<Job> page, Job job) {

return super.findPage(page, job);

@Transactional(readOnly = false)

public void save(Job job) {

super.save(job);

// 啟用則啟動任務

if (StringUtils.equals("1", job.getIsEnable())) {

startTask(job, job.getId());

}

public void update(Job job) {

//結束定時排程

endTask(job.getId());

job.preUpdate();

jobDao.update(job);

public void delete(Job job) {

//結束任務

super.delete(job);

* 系統初始加載任務

public void loadJob() throws Exception {

List<Job> jobList = this.findList(new Job());

if (null != jobList && jobList.size() > 0) {

for (int i = 0; i < jobList.size(); i++) {

Job job = jobList.get(i);

// 任務開啟狀态執行任務排程

if (StringUtils.equals("1", job.getIsEnable())) {

try {

JobDetail jobDetail = new JobDetail();

// 設定任務名稱

if (StringUtils.isNotBlank(job.getId())) {

jobDetail.setName(job.getId());

} else {

UUID uuid = UUID.randomUUID();

jobDetail.setName(uuid.toString());

job.setId(uuid.toString());

}

jobDetail.setGroup(Scheduler.DEFAULT_GROUP);

// 設定任務執行類

jobDetail.setJobClass(getClassByTask(job.getJobClass()));

// 添加任務參數

CronTrigger cronTrigger = new CronTrigger("cron_" + i, Scheduler.DEFAULT_GROUP,

jobDetail.getName(), Scheduler.DEFAULT_GROUP);

cronTrigger.setCronExpression(getCronExpressionFromDB(job.getId()));

// 排程任務

scheduler.scheduleJob(jobDetail, cronTrigger);

} catch (SchedulerException e) {

logger.error("JobService SchedulerException", e);

} catch (ClassNotFoundException e) {

logger.error("JobService ClassNotFoundException", e);

} catch (Exception e) {

logger.error("JobService Exception", e);

}

* @param taskClassName

* 任務執行類名

* @return

* @throws ClassNotFoundException

@SuppressWarnings("rawtypes")

private Class getClassByTask(String taskClassName) throws ClassNotFoundException {

return Class.forName(taskClassName);

public String getCronExpressionFromDB(String id) throws Exception {

// 設定任務規則

Job job = this.get(id);

if (null != job) {

if (Job.EXECYCLE_CRON == Integer.parseInt(job.getExecycle())) {

return job.getCronExpression();

} else {

Integer execycle = Integer.parseInt(job.getJobIntervalUnit());

String excep = "";

if (execycle.equals(Job.EXECYCLE_MONTH)) {

excep = "0 " + job.getMinute() + " " + job.getHour() + " " + job.getDayOfMonth() + " * ?";

} else if (execycle.equals(Job.EXECYCLE_WEEK)) {

excep = "0 " + job.getMinute() + " " + job.getHour() + " " + " ? " + " * " + job.getDayOfWeek();

} else if (execycle.equals(Job.EXECYCLE_DAY)) {

excep = "0 " + job.getMinute() + " " + job.getHour() + " " + " * * ?";

} else if (execycle.equals(Job.EXECYCLE_HOUR)) {

excep = "0 0 */" + job.getIntervalHour() + " * * ?";

} else if (execycle.equals(Job.EXECYCLE_MINUTE)) {

excep = "0 */" + job.getIntervalMinute() + " * * * ?";

return excep;

return "";

private void startTask(Job job, String id) {

try {

String cronExpress = getCronExpressionFromDB(id);

if (StringUtils.isNotEmpty(cronExpress) && cronExpress.indexOf("null") == -1) {

JobDetail jobDetail = new JobDetail();

jobDetail.setName(id);

jobDetail.setGroup(Scheduler.DEFAULT_GROUP);

jobDetail.setJobClass(getClassByTask(job.getJobClass()));

CronTrigger cronTrigger = new CronTrigger("cron_" + id, Scheduler.DEFAULT_GROUP, jobDetail.getName(),

Scheduler.DEFAULT_GROUP);

cronTrigger.setCronExpression(cronExpress);

scheduler.scheduleJob(jobDetail, cronTrigger);

} catch (ParseException e) {

logger.error("JobService ParseException", e);

} catch (Exception e) {

logger.error("JobService Exception", e);

private void endTask(String id) {

scheduler.deleteJob(id, Scheduler.DEFAULT_GROUP);

} catch (SchedulerException e) {

logger.error("JobService endTask", e);

private Scheduler scheduler;

import java.text.ParseException;

import java.util.List;

import java.util.UUID;

import org.quartz.CronTrigger;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import com.ml.honghu.StringUtils;

import com.ml.honghu.common.persistence.Page;

import com.ml.honghu.common.service.CrudService;

import com.ml.honghu.job.dao.JobDao;

import com.ml.honghu.job.entity.Job;

/**

定時排程任務Service

@author honghu

@Service

@Transactional(readOnly = true)

public class JobService extends CrudService<JobDao, Job> {

@Autowired

private JobDao jobDao;

private Logger logger = LoggerFactory.getLogger(getClass());

public Job get(String id) {

return super.get(id);

public List<Job> findList(Job job) {

return super.findList(job);

public Page<Job> findPage(Page<Job> page, Job job) {

return super.findPage(page, job);

@Transactional(readOnly = false)

public void save(Job job) {

super.save(job);

// 啟用則啟動任務

if (StringUtils.equals("1", job.getIsEnable())) {

startTask(job, job.getId());

public void update(Job job) {

//結束定時排程

endTask(job.getId());

public void delete(Job job) {

//結束任務

系統初始加載任務

public void loadJob() throws Exception {

List<Job> jobList = this.findList(new Job());

if (null != jobList && jobList.size() > 0) {

for (int i = 0; i < jobList.size(); i++) {

Job job = jobList.get(i);

// 任務開啟狀态執行任務排程

try {

JobDetail jobDetail = new JobDetail();

// 設定任務名稱

if (StringUtils.isNotBlank(job.getId())) {

jobDetail.setName(job.getId());

} else {

UUID uuid = UUID.randomUUID();

jobDetail.setName(uuid.toString());

job.setId(uuid.toString());

jobDetail.setGroup(Scheduler.DEFAULT_GROUP);

// 設定任務執行類

jobDetail.setJobClass(getClassByTask(job.getJobClass()));

// 添加任務參數

CronTrigger cronTrigger = new CronTrigger("cron_" + i, Scheduler.DEFAULT_GROUP,

jobDetail.getName(), Scheduler.DEFAULT_GROUP);

@param taskClassName

@return

@throws ClassNotFoundException

@SuppressWarnings("rawtypes")

private Class getClassByTask(String taskClassName) throws ClassNotFoundException {

return Class.forName(taskClassName);

public String getCronExpressionFromDB(String id) throws Exception {

// 設定任務規則

Job job = this.get(id);

if (null != job) {

if (Job.EXECYCLE_CRON == Integer.parseInt(job.getExecycle())) {

return job.getCronExpression();

Integer execycle = Integer.parseInt(job.getJobIntervalUnit());

String excep = "";

if (execycle.equals(Job.EXECYCLE_MONTH)) {

excep = "0 " + job.getMinute() + " " + job.getHour() + " " + job.getDayOfMonth() + " * ?";

} else if (execycle.equals(Job.EXECYCLE_WEEK)) {

excep = "0 " + job.getMinute() + " " + job.getHour() + " " + " ? " + " * " + job.getDayOfWeek();

} else if (execycle.equals(Job.EXECYCLE_DAY)) {

excep = "0 " + job.getMinute() + " " + job.getHour() + " " + " * * ?";

} else if (execycle.equals(Job.EXECYCLE_HOUR)) {

excep = "0 0 */" + job.getIntervalHour() + " * * ?";

} else if (execycle.equals(Job.EXECYCLE_MINUTE)) {

excep = "0 */" + job.getIntervalMinute() + " * * * ?";

return excep;

return "";

private void startTask(Job job, String id) {

String cronExpress = getCronExpressionFromDB(id);

if (StringUtils.isNotEmpty(cronExpress) && cronExpress.indexOf("null") == -1) {

jobDetail.setName(id);

CronTrigger cronTrigger = new CronTrigger("cron_" + id, Scheduler.DEFAULT_GROUP, jobDetail.getName(),

Scheduler.DEFAULT_GROUP);

cronTrigger.setCronExpression(cronExpress);

scheduler.scheduleJob(jobDetail, cronTrigger);

} catch (ParseException e) {

logger.error("JobService ParseException", e);

} catch (Exception e) {

logger.error("JobService Exception", e);

private void endTask(String id) {

scheduler.deleteJob(id, Scheduler.DEFAULT_GROUP);

} catch (SchedulerException e) {

logger.error("JobService endTask", e);

private Scheduler scheduler;

6. 編寫相關job的Controller、dao、dao.xml我這邊就不寫了，其實就是對資料的增删改查操作

7. 啟動項目驗證quartz是否成功：

項目啟動個控制台：

任務清單：

任務添加和修改界面：

到此完畢！

Spring4+Springmvc+quartz實作多線程動态定時排程

繼續閱讀

馴服爛代碼_馴服Tomcat：Tomcat 5的過濾技巧

基于Springboot+VUE+Mysql的大學生校園疫情防控管理系統

Using MessageConverter

馴服爛代碼_C＃中的馴服配置

Spring Cloud整合Sleuth，當請求完成後，Zipkin沒有鍊路資訊

遊戲性能優化（基礎）

JAVA自學之路——馬士兵

Rabbitmq指令行手動建立隊列

整合 Spring 開發架構及服務端技術

SSM整合02---Spring-SpringMVC層一、添加web架構支援二、web.xml三、spring-mvc.xml

SSM架構（二）------------表現層的SpringMVC

Intellij idea基于Maven 的SSM 架構整合

Spring資料和Redis

SpringMVC的啟動過程源碼分析1 SpringMVC 配置XML的方式啟動2 SpringMVC純注解模式啟動

Java Spring 架構

SpringCloud微服務（四）之ribbon筆記ribbon是什麼？入門案例自定義均衡負載算法