spring-boot-starter-quartz集群實(shí)踐

kycool 發(fā)布于2019-08-19 10:27 / 3285人閱讀

摘要：前情提要由于項(xiàng)目需要，需要一個(gè)定時(shí)任務(wù)集群，故此有了這個(gè)集群的實(shí)踐。數(shù)據(jù)庫表前綴在被認(rèn)為失火之前，調(diào)度程序?qū)⑷萑桃粋€(gè)將其下一個(gè)啟動(dòng)時(shí)間通過的毫秒數(shù)。設(shè)置此實(shí)例檢入與群集的其他實(shí)例的頻率以毫秒為單位。影響檢測失敗實(shí)例的速度。

【前情提要】由于項(xiàng)目需要，需要一個(gè)定時(shí)任務(wù)集群，故此有了這個(gè)spring-boot-starter-quartz集群的實(shí)踐。springboot的版本為：2.1.6.RELEASE；quartz的版本為：2.3.1.假如這里一共有兩個(gè)定時(shí)任務(wù)的節(jié)點(diǎn)，它們的代碼完全一樣。

壹.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

這里選擇將定時(shí)任務(wù)的數(shù)據(jù)入庫，避免數(shù)據(jù)直接存在內(nèi)存中，因應(yīng)用重啟造成的數(shù)據(jù)丟失和做集群控制。

貳、項(xiàng)目配置

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)主機(jī)名和時(shí)間戳生成實(shí)例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中的所有值都作為字符串，因此可以作為名稱 - 值對存儲(chǔ)而不是在BLOB列中以其序列化形式存儲(chǔ)更多復(fù)雜的對象。從長遠(yuǎn)來看，這是更安全的，因?yàn)槟苊饬藢⒎荢tring類序列化為BLOB的類版本問題。
            tablePrefix: qrtz_  #數(shù)據(jù)庫表前綴
            misfireThreshold: 60000 #在被認(rèn)為“失火”之前，調(diào)度程序?qū)ⅰ叭萑獭币粋€(gè)Triggers將其下一個(gè)啟動(dòng)時(shí)間通過的毫秒數(shù)。默認(rèn)值（如果您在配置中未輸入此屬性）為60000（60秒）。
            clusterCheckinInterval: 5000 #設(shè)置此實(shí)例“檢入”*與群集的其他實(shí)例的頻率（以毫秒為單位）。影響檢測失敗實(shí)例的速度。
            isClustered: true #打開群集功能
          threadPool: #連接池
            class: org.quartz.simpl.SimpleThreadPool
            threadCount: 10
            threadPriority: 5
            threadsInheritContextClassLoaderOfInitializingThread: true

這里需要注意的是兩個(gè)節(jié)點(diǎn)的端口號應(yīng)該不一致，避免沖突

叁、實(shí)現(xiàn)一個(gè)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í)行情況

肆、封裝定時(shí)任務(wù)操作

@Service
public class QuartzService {
    @Autowired
    private Scheduler scheduler;

    @PostConstruct
    public void startScheduler() {
        try {
            scheduler.start();
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }

    /**
     * 增加一個(gè)job
     *
     * @param jobClass
     *            任務(wù)實(shí)現(xiàn)類
     * @param jobName
     *            任務(wù)名稱
     * @param jobGroupName
     *            任務(wù)組名
     * @param jobTime
     *            時(shí)間表達(dá)式 (這是每隔多少秒為一次任務(wù))
     * @param jobTimes
     *            運(yùn)行的次數(shù) （<0:表示不限次數(shù)）
     * @param jobData
     *            參數(shù)
     */
    public void addJob(Class 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();
        }
    }

    /**
     * 增加一個(gè)job
     *
     * @param jobClass
     *            任務(wù)實(shí)現(xiàn)類
     * @param jobName
     *            任務(wù)名稱(建議唯一)
     * @param jobGroupName
     *            任務(wù)組名
     * @param jobTime
     *            時(shí)間表達(dá)式 （如：0/5 * * * * ? ）
     * @param jobData
     *            參數(shù)
     */
    public void addJob(Class jobClass, String jobName, String jobGroupName, String jobTime, Map jobData) {
        try {
            // 創(chuàng)建jobDetail實(shí)例，綁定Job實(shí)現(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();
        }
    }

    /**
     * 修改 一個(gè)job的 時(shí)間表達(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ù)一個(gè)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();
        }
    }

    /**
     * 暫停一個(gè)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ù)一個(gè)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í)行一個(gè)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();
        }
    }

    /**
     * 獲取所有計(jì)劃中的任務(wù)列表
     *
     * @return
     */
    public List> queryAllJob() {
        List> jobList = null;
        try {
            GroupMatcher matcher = GroupMatcher.anyJobGroup();
            Set jobKeys = scheduler.getJobKeys(matcher);
            jobList = new ArrayList>();
            for (JobKey jobKey : jobKeys) {
                List triggers = scheduler.getTriggersOfJob(jobKey);
                for (Trigger trigger : triggers) {
                    Map map = new HashMap<>();
                    map.put("jobName", jobKey.getName());
                    map.put("jobGroupName", jobKey.getGroup());
                    map.put("description", "觸發(fā)器:" + trigger.getKey());
                    Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
                    map.put("jobStatus", triggerState.name());
                    if (trigger instanceof CronTrigger) {
                        CronTrigger cronTrigger = (CronTrigger) trigger;
                        String cronExpression = cronTrigger.getCronExpression();
                        map.put("jobTime", cronExpression);
                    }
                    jobList.add(map);
                }
            }
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return jobList;
    }

    /**
     * 獲取所有正在運(yùn)行的job
     *
     * @return
     */
    public List> queryRunJob() {
        List> jobList = null;
        try {
            List executingJobs = scheduler.getCurrentlyExecutingJobs();
            jobList = new ArrayList>(executingJobs.size());
            for (JobExecutionContext executingJob : executingJobs) {
                Map map = new HashMap();
                JobDetail jobDetail = executingJob.getJobDetail();
                JobKey jobKey = jobDetail.getKey();
                Trigger trigger = executingJob.getTrigger();
                map.put("jobName", jobKey.getName());
                map.put("jobGroupName", jobKey.getGroup());
                map.put("description", "觸發(fā)器:" + trigger.getKey());
                Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
                map.put("jobStatus", triggerState.name());
                if (trigger instanceof CronTrigger) {
                    CronTrigger cronTrigger = (CronTrigger) trigger;
                    String cronExpression = cronTrigger.getCronExpression();
                    map.put("jobTime", cronExpression);
                }
                jobList.add(map);
            }
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
        return jobList;
    }

陸、初始化任務(wù)

這里不準(zhǔn)備給用戶用web界面來配置定時(shí)任務(wù)，故此采用CommandLineRunner來子啊應(yīng)用初始化的時(shí)候來初始化任務(wù)。只需要實(shí)現(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àn)證

分別夏侯啟動(dòng)兩個(gè)應(yīng)用，然后觀察任務(wù)執(zhí)行，以及在運(yùn)行過程中殺死某個(gè)服務(wù)，來觀察定時(shí)任務(wù)的執(zhí)行。

【寫在后面的話】下面給出的是所需要腳本的連接地址：腳本下載地址，另外這邊又一個(gè)自己實(shí)現(xiàn)的demo

GPU云服務(wù)器云服務(wù)器學(xué)習(xí)實(shí)踐架構(gòu)實(shí)踐開發(fā)實(shí)踐最佳實(shí)踐

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/76058.html

發(fā)表評論

登陸后可評論

0條評論

kycool

男|高級講師

我要關(guān)注我要私信

TA的文章

MLC測試工具

閱讀 2555·2021-11-16 11:44
基礎(chǔ)知識(shí)：css3核心知識(shí)整理

閱讀 795·2019-08-30 15:55
2017前端性能優(yōu)化清單

閱讀 3416·2019-08-30 15:52
bootstrap，datetimepicker日期時(shí)間選擇器-限制時(shí)間段，以及中文顯示問題

閱讀 3765·2019-08-30 15:43
十分鐘通關(guān)CSS：內(nèi)嵌樣式

閱讀 2353·2019-08-30 11:21
面試前端時(shí)遇到的CSS題目

閱讀 586·2019-08-29 12:18
bootstrap

閱讀 2104·2019-08-26 18:15
如果獲取籃球聯(lián)賽數(shù)據(jù)？

閱讀 613·2019-08-26 10:32

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

spring-boot-starter-quartz集群實(shí)踐

相關(guān)文章

Spring Boot 參考指南（Quartz Scheduler）

Docker Swarm的前世今生

京東云Kubernetes集群最佳實(shí)踐

京東云Kubernetes集群最佳實(shí)踐

發(fā)表評論

0條評論

kycool

男|高級講師

TA的文章

MLC測試工具

基礎(chǔ)知識(shí)：css3核心知識(shí)整理

2017前端性能優(yōu)化清單

bootstrap，datetimepicker日期時(shí)間選擇器-限制時(shí)間段，以及中文顯示問題

十分鐘通關(guān)CSS：內(nèi)嵌樣式

面試前端時(shí)遇到的CSS題目

bootstrap

如果獲取籃球聯(lián)賽數(shù)據(jù)？

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

spring-boot-starter-quartz集群實(shí)踐

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動(dòng)

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！