摘要:定時調度系統是大多行業項目都需要的,傳統的模式,個人感覺已經了,因為存在很多的問題,特別是定時調度的追加修改刪除等,需要修改,的配置生效無非是熱部署灰度發布方案或者直接停止重啟服務器,完全不能做到自動啟動修復方式。
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是否成功:
項目啟動個控制臺:
**任務列表:**
**任務添加和修改界面:**
到此完畢!
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/75825.html
摘要:也是自帶的一個基于線程池設計的定時任務類。其每個調度任務都會分配到線程池中的一個線程執行,所以其任務是并發執行的,互不影響。 原創不易,如需轉載,請注明出處https://www.cnblogs.com/baixianlong/p/10659045.html,否則將追究法律責任!!! 一、在JAVA開發領域,目前可以通過以下幾種方式進行定時任務 1、單機部署模式 Timer:jdk中...
摘要:也是自帶的一個基于線程池設計的定時任務類。問題的解決方式,可以通過自定義來修改當前的線程池。問題,則可以直接使用類實現自定義的定時調度規則。 定時調度 作為后端開發人員,我們總會遇到這樣的業務場景:每周同步一批數據;每半個小時檢查一遍服務器運行狀況;每天早上八點給用戶發送一份包含今日待辦事項的郵件,等等。 這些場景中都離不開定時器,就像一個定好時間規則的鬧鐘,它會在指定時間觸發,執行我...
摘要:類是一個抽象類,由安排為一次執行或重復執行的任務。也是自帶的一個基于線程池設計的定時任務類。問題,則可以直接使用類實現自定義的定時調度規則。 定時調度作為后端開發人員,我們總會遇到這樣的業務場景:每周同步一批數據;每半個小時檢查一遍服務器運行狀況;每天早上八點給用戶發送一份包含今日待辦事項的郵件,等等。 這些場景中都離不開定時器,就像一個定好時間規則的鬧鐘,它會在指定時間觸發,執行我們...
閱讀 683·2021-11-22 09:34
閱讀 3821·2021-09-22 15:42
閱讀 1327·2021-09-03 10:28
閱讀 1072·2021-08-26 14:13
閱讀 1901·2019-08-29 15:41
閱讀 1423·2019-08-29 14:12
閱讀 3364·2019-08-26 18:36
閱讀 3307·2019-08-26 13:47