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

谁践踏了优雅 2022-06-06 14:15 129阅读 0赞

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

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

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

<dependency>  
         <groupId>org.quartz-scheduler</groupId>  
         <artifactId>quartz</artifactId>  
         <version>1.8.5</version>  
    </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 name="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">   
                 
            <property name="applicationContextSchedulerContextKey" value="applicationContext" />  
        </bean>    
          
        <bean id="jobService" class="com.ml.honghu.job.service.JobService" init-method="loadJob" />  
    </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());  
            }  
        }  
          
        @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 (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) {  
            try {  
                scheduler.deleteJob(id, Scheduler.DEFAULT_GROUP);  
            } catch (SchedulerException e) {  
                logger.error("JobService endTask", e);  
            }  
        }  
      
        @Autowired  
        private Scheduler scheduler;  
      
    }

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

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

**    项目启动个控制台：**

![Center][]  
**任务列表：**  
![Center 1][]  
**任务添加和修改界面：**

**![Center 2][]**  
到此结束！！

[Center]: /images/20220606/dbf663276173405a88e269a2c6a41268.png
[Center 1]: /images/20220606/0f658ba5d4b644fdbecaa31f4dd57af8.png
[Center 2]: /images/20220606/8314d73de2f441f481b747aa12d5d0e8.png