Spring4+Springmvc+quartz实现多线程动态定时调度

Spring4+Springmvc+quartz实现多线程动态定时调度
scheduler定时调度系统是大多行业项目都需要的，传统的spring-job模式，个人感觉已经out了，因为存在很多的问题，特别是定时调度的追加、修改、删除等，需要修改 ， 的配置生效无非是热部署灰度发布方案或者直接停止、重启服务器，完全不能做到自动启动、修复方式。

提醒：可以对应用进行集群部署，在对定时调度配置时可以使用集群方式或者单边配置应用方式，今天讲解的是使用spring4+scheduler实现定时调度，闲话少说，直接把步骤记录下来：

在项目的pom. 文件中引入quartz的jar包，如下：


org.quartz-scheduler
quartz
1.8.5

定义quartz的配置文件spring-context-quartz. ：
<? version="1.0" encoding="UTF-8"?>

 ns:context="http://www.spring work.org/schema/context" xsi:schemaLocation="      http://www.spring work.org/schema/beans http://www.spring work.org/schema/beans/spring-beans-4.0.xsd      http://www.spring work.org/schema/context http://www.spring work.org/schema/context/spring-context-4.0.xsd"  default-lazy-init="false">  <!-- 调度器 -->  <bean name="scheduler" class="org.spring work.scheduling.quartz.SchedulerFactoryBean">      <!-- 通过applicationContextSchedulerContextKey属性配置spring上下文 -->          <property name="applicationContextSchedulerContextKey" value="applicationContext" />  </bean>    <!--加载数据库任务-->  <bean id="jobService" class="top.alterem.job.service.JobService" init-method="loadJob" />  

1. 在项目的web. 文件中引入spring-context-quartz. 配置文件

​`

classpath*:spring-context-quartz.  

定义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 cron ;      // 规则表达式  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 getCron () {      return cron ;  }  public void setCron (String cron ) {      this.cron  = cron ;  }    @Length(min=1, max=1, message="是否启用长度必须介于 1 和 1 之间")  public String getIsEnable() {      return isEnable;  }  public void setIsEnable(String isEnable) {      this.isEnable = isEnable;  }    

}
编写quartz的jobServvice类：
package top.alterem.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.spring work.beans.factory.annotation.Autowired;
import org.spring work.stereotype.Service;
import org.spring work.transaction.annotation.Transactional;

import top.alterem.StringUtils;
import top.alterem.common.persistence.Page;
import top.alterem.common.service.CrudService;
import top.alterem.job.dao.JobDao;
import top.alterem.job.entity.Job;

/**

• 定时调度任务Service
• @author honghu
  */

@Service
@Transactional(readOnly = true)
public class JobService extends CrudService {

  @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());      }  }    @Transactional(readOnly = false)  public void update(Job job) {      //结束定时调度      endTask(job.getId());            job.preUpdate();      jobDao.update(job);            // 启用则启动任务      if (StringUtils.equals("1", job.getIsEnable())) {          startTask(job, job.getId());      }  }  @Transactional(readOnly = false)  public void delete(Job job) {      //结束任务      endTask(job.getId());            super.delete(job);  }  /**  * 系统初始加载任务  */  public void loadJob() throws Exception {      List<Job> jobList = this.findList(new Job());      if ( != 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.setCron (getCron FromDB(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 getCron FromDB(String id) throws Exception {      // 设置任务规则      Job job = this.get(id);      if ( != job) {          if (Job.EXECYCLE_CRON == Integer.parseInt(job.getExecycle())) {              return job.getCron ();          } 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 = getCron FromDB(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.setCron (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) {      try {          scheduler.deleteJob(id, Scheduler.DEFAULT_GROUP);      } catch (SchedulerException e) {          logger.error("JobService endTask", e);      }  }  @Autowired  private Scheduler scheduler;  

}
编写相关job的Controller、dao、dao. 我这边就不写了，其实就是对数据的增删改查操作

启动项目验证quartz是否成功：

项目启动个控制台：

点击查看原始大小图片
任务列表：
点击查看原始大小图片
任务添加和修改界面：
点击查看原始大小图片
到此完毕！
原文地址https://www.cnblogs.com/alterem/p/11301235.html