摘要:定时调度系统是大多行业项目都需要的,传统的模式,个人感觉已经了,因为存在很多的问题,特别是定时调度的追加修改删除等,需要修改,的配置生效无非是热部署灰度发布方案或者直接停止重启服务器,完全不能做到自动启动修复方式。
scheduler定时调度系统是大多行业项目都需要的,传统的spring-job模式,个人感觉已经out了,因为存在很多的问题,特别是定时调度的追加、修改、删除等,需要修改xml,xml的配置生效无非是热部署灰度发布方案或者直接停止、重启服务器,完全不能做到自动启动、修复方式。
提醒:可以对应用进行集群部署,在对定时调度配置时可以使用集群方式或者单边配置应用方式,今天讲解的是使用spring4+scheduler实现定时调度,闲话少说,直接把步骤记录下来:
在项目的pom.xml文件中引入quartz的jar包,如下:
org.quartz-scheduler quartz 1.8.5
定义quartz的配置文件spring-context-quartz.xml:
xml 3. 在项目的web.xml文件中引入spring-context-quartz.xml配置文件 ```xml classpath*:spring-context-quartz.xml
定义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; } }
编写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.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.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 findList(Job job) { return super.findList(job); } public Page findPage(Page 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 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.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 ( != 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; }
编写相关job的Controller、dao、dao.xml我这边就不写了,其实就是对数据的增删改查操作
启动项目验证quartz是否成功:
项目启动个控制台:
**任务列表:**
**任务添加和修改界面:**
到此完毕!
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/75825.html
摘要:也是自带的一个基于线程池设计的定时任务类。其每个调度任务都会分配到线程池中的一个线程执行,所以其任务是并发执行的,互不影响。 原创不易,如需转载,请注明出处https://www.cnblogs.com/baixianlong/p/10659045.html,否则将追究法律责任!!! 一、在JAVA开发领域,目前可以通过以下几种方式进行定时任务 1、单机部署模式 Timer:jdk中...
摘要:也是自带的一个基于线程池设计的定时任务类。问题的解决方式,可以通过自定义来修改当前的线程池。问题,则可以直接使用类实现自定义的定时调度规则。 定时调度 作为后端开发人员,我们总会遇到这样的业务场景:每周同步一批数据;每半个小时检查一遍服务器运行状况;每天早上八点给用户发送一份包含今日待办事项的邮件,等等。 这些场景中都离不开定时器,就像一个定好时间规则的闹钟,它会在指定时间触发,执行我...
摘要:类是一个抽象类,由安排为一次执行或重复执行的任务。也是自带的一个基于线程池设计的定时任务类。问题,则可以直接使用类实现自定义的定时调度规则。 定时调度作为后端开发人员,我们总会遇到这样的业务场景:每周同步一批数据;每半个小时检查一遍服务器运行状况;每天早上八点给用户发送一份包含今日待办事项的邮件,等等。 这些场景中都离不开定时器,就像一个定好时间规则的闹钟,它会在指定时间触发,执行我们...
阅读 686·2021-11-22 09:34
阅读 3824·2021-09-22 15:42
阅读 1331·2021-09-03 10:28
阅读 1073·2021-08-26 14:13
阅读 1902·2019-08-29 15:41
阅读 1429·2019-08-29 14:12
阅读 3365·2019-08-26 18:36
阅读 3310·2019-08-26 13:47