摘要:前情提要由于項目需要,需要一個定時任務(wù)集群,故此有了這個集群的實踐。數(shù)據(jù)庫表前綴在被認(rèn)為失火之前,調(diào)度程序?qū)⑷萑桃粋€將其下一個啟動時間通過的毫秒數(shù)。設(shè)置此實例檢入與群集的其他實例的頻率以毫秒為單位。影響檢測失敗實例的速度。
【前情提要】由于項目需要,需要一個定時任務(wù)集群,故此有了這個spring-boot-starter-quartz集群的實踐。springboot的版本為:2.1.6.RELEASE;quartz的版本為:2.3.1.假如這里一共有兩個定時任務(wù)的節(jié)點,它們的代碼完全一樣。
壹.jar包依賴1.8 org.springframework.boot spring-boot-starter org.springframework.boot spring-boot-starter-quartz mysql mysql-connector-java runtime org.springframework.boot spring-boot-starter-jdbc org.projectlombok lombok true org.springframework.boot spring-boot-starter-test test
這里選擇將定時任務(wù)的數(shù)據(jù)入庫,避免數(shù)據(jù)直接存在內(nèi)存中,因應(yīng)用重啟造成的數(shù)據(jù)丟失和做集群控制。
貳、項目配置spring: server: port: 8080 servlet: context-path: /lovin datasource: url: jdbc:mysql://127.0.0.1:3306/training?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true username: root password: root driver-class-name: com.mysql.cj.jdbc.Driver quartz: job-store-type: jdbc #數(shù)據(jù)庫方式 jdbc: initialize-schema: never #不初始化表結(jié)構(gòu) properties: org: quartz: scheduler: instanceId: AUTO #默認(rèn)主機名和時間戳生成實例ID,可以是任何字符串,但對于所有調(diào)度程序來說,必須是唯一的 對應(yīng)qrtz_scheduler_state INSTANCE_NAME字段 #instanceName: clusteredScheduler #quartzScheduler jobStore: class: org.quartz.impl.jdbcjobstore.JobStoreTX #持久化配置 driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate #我們僅為數(shù)據(jù)庫制作了特定于數(shù)據(jù)庫的代理 useProperties: false #以指示JDBCJobStore將JobDataMaps中的所有值都作為字符串,因此可以作為名稱 - 值對存儲而不是在BLOB列中以其序列化形式存儲更多復(fù)雜的對象。從長遠(yuǎn)來看,這是更安全的,因為您避免了將非String類序列化為BLOB的類版本問題。 tablePrefix: qrtz_ #數(shù)據(jù)庫表前綴 misfireThreshold: 60000 #在被認(rèn)為“失火”之前,調(diào)度程序?qū)ⅰ叭萑獭币粋€Triggers將其下一個啟動時間通過的毫秒數(shù)。默認(rèn)值(如果您在配置中未輸入此屬性)為60000(60秒)。 clusterCheckinInterval: 5000 #設(shè)置此實例“檢入”*與群集的其他實例的頻率(以毫秒為單位)。影響檢測失敗實例的速度。 isClustered: true #打開群集功能 threadPool: #連接池 class: org.quartz.simpl.SimpleThreadPool threadCount: 10 threadPriority: 5 threadsInheritContextClassLoaderOfInitializingThread: true
這里需要注意的是兩個節(jié)點的端口號應(yīng)該不一致,避免沖突
叁、實現(xiàn)一個Job@Slf4j public class Job extends QuartzJobBean { @Override protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException { // 獲取參數(shù) JobDataMap jobDataMap = jobExecutionContext.getJobDetail().getJobDataMap(); // 業(yè)務(wù)邏輯 ... log.info("------springbootquartzonejob執(zhí)行"+jobDataMap.get("name").toString()+"###############"+jobExecutionContext.getTrigger()); }
其中的日志輸出是為了便于觀察任務(wù)執(zhí)行情況
肆、封裝定時任務(wù)操作@Service public class QuartzService { @Autowired private Scheduler scheduler; @PostConstruct public void startScheduler() { try { scheduler.start(); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 增加一個job * * @param jobClass * 任務(wù)實現(xiàn)類 * @param jobName * 任務(wù)名稱 * @param jobGroupName * 任務(wù)組名 * @param jobTime * 時間表達(dá)式 (這是每隔多少秒為一次任務(wù)) * @param jobTimes * 運行的次數(shù) (<0:表示不限次數(shù)) * @param jobData * 參數(shù) */ public void addJob(Class extends QuartzJobBean> jobClass, String jobName, String jobGroupName, int jobTime, int jobTimes, Map jobData) { try { // 任務(wù)名稱和組構(gòu)成任務(wù)key JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName) .build(); // 設(shè)置job參數(shù) if(jobData!= null && jobData.size()>0){ jobDetail.getJobDataMap().putAll(jobData); } // 使用simpleTrigger規(guī)則 Trigger trigger = null; if (jobTimes < 0) { trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName) .withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(1).withIntervalInSeconds(jobTime)) .startNow().build(); } else { trigger = TriggerBuilder .newTrigger().withIdentity(jobName, jobGroupName).withSchedule(SimpleScheduleBuilder .repeatSecondlyForever(1).withIntervalInSeconds(jobTime).withRepeatCount(jobTimes)) .startNow().build(); } scheduler.scheduleJob(jobDetail, trigger); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 增加一個job * * @param jobClass * 任務(wù)實現(xiàn)類 * @param jobName * 任務(wù)名稱(建議唯一) * @param jobGroupName * 任務(wù)組名 * @param jobTime * 時間表達(dá)式 (如:0/5 * * * * ? ) * @param jobData * 參數(shù) */ public void addJob(Class extends QuartzJobBean> jobClass, String jobName, String jobGroupName, String jobTime, Map jobData) { try { // 創(chuàng)建jobDetail實例,綁定Job實現(xiàn)類 // 指明job的名稱,所在組的名稱,以及綁定job類 // 任務(wù)名稱和組構(gòu)成任務(wù)key JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName) .build(); // 設(shè)置job參數(shù) if(jobData!= null && jobData.size()>0){ jobDetail.getJobDataMap().putAll(jobData); } // 定義調(diào)度觸發(fā)規(guī)則 // 使用cornTrigger規(guī)則 // 觸發(fā)器key Trigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName) .startAt(DateBuilder.futureDate(1, IntervalUnit.SECOND)) .withSchedule(CronScheduleBuilder.cronSchedule(jobTime)).startNow().build(); // 把作業(yè)和觸發(fā)器注冊到任務(wù)調(diào)度中 scheduler.scheduleJob(jobDetail, trigger); } catch (Exception e) { e.printStackTrace(); } } /** * 修改 一個job的 時間表達(dá)式 * * @param jobName * @param jobGroupName * @param jobTime */ public void updateJob(String jobName, String jobGroupName, String jobTime) { try { TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); trigger = trigger.getTriggerBuilder().withIdentity(triggerKey) .withSchedule(CronScheduleBuilder.cronSchedule(jobTime)).build(); // 重啟觸發(fā)器 scheduler.rescheduleJob(triggerKey, trigger); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 刪除任務(wù)一個job * * @param jobName * 任務(wù)名稱 * @param jobGroupName * 任務(wù)組名 */ public void deleteJob(String jobName, String jobGroupName) { try { scheduler.deleteJob(new JobKey(jobName, jobGroupName)); } catch (Exception e) { e.printStackTrace(); } } /** * 暫停一個job * * @param jobName * @param jobGroupName */ public void pauseJob(String jobName, String jobGroupName) { try { JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); scheduler.pauseJob(jobKey); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 恢復(fù)一個job * * @param jobName * @param jobGroupName */ public void resumeJob(String jobName, String jobGroupName) { try { JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); scheduler.resumeJob(jobKey); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 立即執(zhí)行一個job * * @param jobName * @param jobGroupName */ public void runAJobNow(String jobName, String jobGroupName) { try { JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); scheduler.triggerJob(jobKey); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 獲取所有計劃中的任務(wù)列表 * * @return */ public List陸、初始化任務(wù)
這里不準(zhǔn)備給用戶用web界面來配置定時任務(wù),故此采用CommandLineRunner來子啊應(yīng)用初始化的時候來初始化任務(wù)。只需要實現(xiàn)CommandLineRunner的run()方法即可。
@Override public void run(String... args) throws Exception { HashMap柒、測試驗證map = new HashMap<>(); map.put("name",1); quartzService.deleteJob("job", "test"); quartzService.addJob(Job.class, "job", "test", "0 * * * * ?", map); map.put("name",2); quartzService.deleteJob("job2", "test"); quartzService.addJob(Job.class, "job2", "test", "10 * * * * ?", map); map.put("name",3); quartzService.deleteJob("job3", "test2"); quartzService.addJob(Job.class, "job3", "test2", "15 * * * * ?", map); }
分別夏侯啟動兩個應(yīng)用,然后觀察任務(wù)執(zhí)行,以及在運行過程中殺死某個服務(wù),來觀察定時任務(wù)的執(zhí)行。
【寫在后面的話】下面給出的是所需要腳本的連接地址:腳本下載地址,另外這邊又一個自己實現(xiàn)的demo
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://specialneedsforspecialkids.com/yun/76058.html
摘要:下列類型的將自動被拾取并與關(guān)聯(lián)定義一個特定的工作,實例可以使用構(gòu)建。定義何時觸發(fā)特定工作。可以使用配置屬性定制配置和,它允許編程進(jìn)行定制化。特別是,不與相關(guān)聯(lián),因為提供了一種通過配置的方法,如果需要自定義任務(wù)執(zhí)行程序,請考慮實現(xiàn)。 39. Quartz Scheduler Spring Boot為使用Quartz Scheduler提供了一些方便,引入spring-boot-start...
摘要:當(dāng)然此時的局限性較大,比如沒有副本和負(fù)載均衡的概念,這導(dǎo)致服務(wù)無法高可用當(dāng)然也更不存在什么服務(wù)網(wǎng)絡(luò)管理和跨節(jié)點數(shù)據(jù)存儲這些東西沒有服務(wù)模型集群中服務(wù)間關(guān)系和啟動順序編排也很復(fù)雜于是就有了下面的的誕生。 showImg(https://segmentfault.com/img/remote/1460000015317037?w=1885&h=1153); 概述 在我的《Docker S...
摘要:京東云集群最佳實踐容器是的基石,它們之間的關(guān)系不言而喻。因此我們今天的文章將會和大家分享關(guān)于京東云集群的部分最佳實踐。京東云集群采用管理節(jié)點全托管的方式,為用戶提供簡單易用高可靠功能強大的容器管理服務(wù)。 京東云Kubernetes集群最佳實踐 容器是Cloud Native的基石,它們之間的關(guān)系不言而喻。了解容器對于學(xué)習(xí)Cloud Native也是十分重要的。近期,京東云Cloud N...
摘要:京東云集群最佳實踐容器是的基石,它們之間的關(guān)系不言而喻。因此我們今天的文章將會和大家分享關(guān)于京東云集群的部分最佳實踐。京東云集群采用管理節(jié)點全托管的方式,為用戶提供簡單易用高可靠功能強大的容器管理服務(wù)。 京東云Kubernetes集群最佳實踐 容器是Cloud Native的基石,它們之間的關(guān)系不言而喻。了解容器對于學(xué)習(xí)Cloud Native也是十分重要的。近期,京東云Cloud N...
閱讀 2234·2021-11-16 11:44
閱讀 641·2019-08-30 15:55
閱讀 3271·2019-08-30 15:52
閱讀 3595·2019-08-30 15:43
閱讀 2196·2019-08-30 11:21
閱讀 435·2019-08-29 12:18
閱讀 1945·2019-08-26 18:15
閱讀 468·2019-08-26 10:32