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

資訊專欄INFORMATION COLUMN

Spring4+Springmvc+quartz實(shí)現(xiàn)多線程動(dòng)態(tài)定時(shí)調(diào)度

xiao7cn / 2676人閱讀

摘要:定時(shí)調(diào)度系統(tǒng)是大多行業(yè)項(xiàng)目都需要的,傳統(tǒng)的模式,個(gè)人感覺已經(jīng)了,因?yàn)榇嬖诤芏嗟膯栴},特別是定時(shí)調(diào)度的追加修改刪除等,需要修改,的配置生效無非是熱部署灰度發(fā)布方案或者直接停止重啟服務(wù)器,完全不能做到自動(dòng)啟動(dòng)修復(fù)方式。

scheduler定時(shí)調(diào)度系統(tǒng)是大多行業(yè)項(xiàng)目都需要的,傳統(tǒng)的spring-job模式,個(gè)人感覺已經(jīng)out了,因?yàn)榇嬖诤芏嗟膯栴},特別是定時(shí)調(diào)度的追加、修改、刪除等,需要修改xml,xml的配置生效無非是熱部署灰度發(fā)布方案或者直接停止、重啟服務(wù)器,完全不能做到自動(dòng)啟動(dòng)、修復(fù)方式。

提醒:可以對(duì)應(yīng)用進(jìn)行集群部署,在對(duì)定時(shí)調(diào)度配置時(shí)可以使用集群方式或者單邊配置應(yīng)用方式,今天講解的是使用spring4+scheduler實(shí)現(xiàn)定時(shí)調(diào)度,閑話少說,直接把步驟記錄下來:

在項(xiàng)目的pom.xml文件中引入quartz的jar包,如下:

            
           
  org.quartz-scheduler           
  quartz           
  1.8.5           

定義quartz的配置文件spring-context-quartz.xml:

  
  
      
       
             
          
        
      
      
      
xml
   

3.  在項(xiàng)目的web.xml文件中引入spring-context-quartz.xml配置文件 

?```xml
    classpath*:spring-context-quartz.xml 

定義job實(shí)體對(duì)象

public class Job{  
      
    private static final long serialVersionUID = 1L;  
      
    /** 
     * 任務(wù)執(zhí)行周期cron表達(dá)式 
     */  
    public static int EXECYCLE_CRON = 2;  
    /** 
     * 任務(wù)執(zhí)行周期自定義 
     */  
    public static int EXECYCLE_DEFINE = 1;  
    /** 
     * 執(zhí)行周期-分鐘 
     */  
    public static int EXECYCLE_MINUTE = 1;  
    /** 
     * 執(zhí)行周期-小時(shí) 
     */  
    public static int EXECYCLE_HOUR = 2;  
    /** 
     * 執(zhí)行周期-日 
     */  
    public static int EXECYCLE_DAY = 3;  
    /** 
     * 執(zhí)行周期-月 
     */  
    public static int EXECYCLE_WEEK = 4;  
    /** 
     * 執(zhí)行周期-月 
     */  
    public static int EXECYCLE_MONTH = 5;  
      
  
    private String jobType;     // 任務(wù)類型(1首頁靜態(tài)化、2欄目頁靜態(tài)化、3內(nèi)容頁靜態(tài)化、4采集、5分發(fā))  
    private String jobName;     // 任務(wù)名稱  
    private String jobClass;        // 任務(wù)類  
    private String execycle;        // 執(zhí)行周期分類(1非表達(dá)式 2 cron表達(dá)式)  
    private String dayOfMonth;      // 每月的哪天  
    private String dayOfWeek;       // 周幾  
    private String hour;        // 小時(shí)  
    private String minute;      // 分鐘  
    private String intervalHour;        // 間隔小時(shí)  
    private String intervalMinute;      // 間隔分鐘  
    private String jobIntervalUnit;     // 1分鐘、2小時(shí)、3日、4周、5月  
    private String cronExpression;      // 規(guī)則表達(dá)式  
    private String isEnable;        // 是否啟用  
      
    public Job() {  
        super();  
    }  
  
    public Job(String id){  
        super(id);  
    }  
  
    @Length(min=1, max=1, message="任務(wù)類型(1首頁靜態(tài)化、2欄目頁靜態(tài)化、3內(nèi)容頁靜態(tài)化、4采集、5分發(fā))長度必須介于 1 和 1 之間")  
    public String getJobType() {  
        return jobType;  
    }  
  
    public void setJobType(String jobType) {  
        this.jobType = jobType;  
    }  
      
    @Length(min=1, max=255, message="任務(wù)名稱長度必須介于 1 和 255 之間")  
    public String getJobName() {  
        return jobName;  
    }  
  
    public void setJobName(String jobName) {  
        this.jobName = jobName;  
    }  
      
    @Length(min=1, max=255, message="任務(wù)類長度必須介于 1 和 255 之間")  
    public String getJobClass() {  
        return jobClass;  
    }  
  
    public void setJobClass(String jobClass) {  
        this.jobClass = jobClass;  
    }  
      
    @Length(min=1, max=1, message="執(zhí)行周期分類(1非表達(dá)式 2 cron表達(dá)式)長度必須介于 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="小時(shí)長度必須介于 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="間隔小時(shí)長度必須介于 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小時(shí)、3日、4周、5月長度必須介于 0 和 1 之間")  
    public String getJobIntervalUnit() {  
        return jobIntervalUnit;  
    }  
  
    public void setJobIntervalUnit(String jobIntervalUnit) {  
        this.jobIntervalUnit = jobIntervalUnit;  
    }  
      
    @Length(min=0, max=255, message="規(guī)則表達(dá)式長度必須介于 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;  
  
/** 
 * 定時(shí)調(diào)度任務(wù)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);  
        // 啟用則啟動(dòng)任務(wù)  
        if (StringUtils.equals("1", job.getIsEnable())) {  
            startTask(job, job.getId());  
        }  
    }  
      
    @Transactional(readOnly = false)  
    public void update(Job job) {  
        //結(jié)束定時(shí)調(diào)度  
        endTask(job.getId());  
          
        job.preUpdate();  
        jobDao.update(job);  
          
        // 啟用則啟動(dòng)任務(wù)  
        if (StringUtils.equals("1", job.getIsEnable())) {  
            startTask(job, job.getId());  
        }  
    }  
  
    @Transactional(readOnly = false)  
    public void delete(Job job) {  
        //結(jié)束任務(wù)  
        endTask(job.getId());  
          
        super.delete(job);  
    }  
  
    /** 
     * 系統(tǒng)初始加載任務(wù) 
     */  
    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);  
                // 任務(wù)開啟狀態(tài) 執(zhí)行任務(wù)調(diào)度  
                if (StringUtils.equals("1", job.getIsEnable())) {  
                    try {  
                        JobDetail jobDetail = new JobDetail();  
                        // 設(shè)置任務(wù)名稱  
                        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);  
                        // 設(shè)置任務(wù)執(zhí)行類  
                        jobDetail.setJobClass(getClassByTask(job.getJobClass()));  
                        // 添加任務(wù)參數(shù)  
                        CronTrigger cronTrigger = new CronTrigger("cron_" + i, Scheduler.DEFAULT_GROUP,  
                                jobDetail.getName(), Scheduler.DEFAULT_GROUP);  
  
                        cronTrigger.setCronExpression(getCronExpressionFromDB(job.getId()));  
                        // 調(diào)度任務(wù)  
                        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 
     *            任務(wù)執(zhí)行類名 
     * @return 
     * @throws ClassNotFoundException 
     */  
    @SuppressWarnings("rawtypes")  
    private Class getClassByTask(String taskClassName) throws ClassNotFoundException {  
        return Class.forName(taskClassName);  
    }  
  
    public String getCronExpressionFromDB(String id) throws Exception {  
        // 設(shè)置任務(wù)規(guī)則  
        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;  
  
}  

編寫相關(guān)job的Controller、dao、dao.xml我這邊就不寫了,其實(shí)就是對(duì)數(shù)據(jù)的增刪改查操作

啟動(dòng)項(xiàng)目驗(yàn)證quartz是否成功:

項(xiàng)目啟動(dòng)個(gè)控制臺(tái):

  **任務(wù)列表:**

   **任務(wù)添加和修改界面:**


到此完畢!

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

轉(zhuǎn)載請(qǐng)注明本文地址:http://m.hztianpu.com/yun/75825.html

相關(guān)文章

  • SpringBoot中并發(fā)定時(shí)任務(wù)的實(shí)現(xiàn)動(dòng)態(tài)定時(shí)任務(wù)的實(shí)現(xiàn)(看這一篇就夠了)

    摘要:也是自帶的一個(gè)基于線程池設(shè)計(jì)的定時(shí)任務(wù)類。其每個(gè)調(diào)度任務(wù)都會(huì)分配到線程池中的一個(gè)線程執(zhí)行,所以其任務(wù)是并發(fā)執(zhí)行的,互不影響。 原創(chuàng)不易,如需轉(zhuǎn)載,請(qǐng)注明出處https://www.cnblogs.com/baixianlong/p/10659045.html,否則將追究法律責(zé)任?。?! 一、在JAVA開發(fā)領(lǐng)域,目前可以通過以下幾種方式進(jìn)行定時(shí)任務(wù) 1、單機(jī)部署模式 Timer:jdk中...

    BWrong 評(píng)論0 收藏0
  • 那些年,我們用過的“定時(shí)調(diào)度

    摘要:也是自帶的一個(gè)基于線程池設(shè)計(jì)的定時(shí)任務(wù)類。問題的解決方式,可以通過自定義來修改當(dāng)前的線程池。問題,則可以直接使用類實(shí)現(xiàn)自定義的定時(shí)調(diào)度規(guī)則。 定時(shí)調(diào)度 作為后端開發(fā)人員,我們總會(huì)遇到這樣的業(yè)務(wù)場(chǎng)景:每周同步一批數(shù)據(jù);每半個(gè)小時(shí)檢查一遍服務(wù)器運(yùn)行狀況;每天早上八點(diǎn)給用戶發(fā)送一份包含今日待辦事項(xiàng)的郵件,等等。 這些場(chǎng)景中都離不開定時(shí)器,就像一個(gè)定好時(shí)間規(guī)則的鬧鐘,它會(huì)在指定時(shí)間觸發(fā),執(zhí)行我...

    PrototypeZ 評(píng)論0 收藏0
  • 那些年,我們追過的“定時(shí)調(diào)度

    摘要:類是一個(gè)抽象類,由安排為一次執(zhí)行或重復(fù)執(zhí)行的任務(wù)。也是自帶的一個(gè)基于線程池設(shè)計(jì)的定時(shí)任務(wù)類。問題,則可以直接使用類實(shí)現(xiàn)自定義的定時(shí)調(diào)度規(guī)則。 定時(shí)調(diào)度作為后端開發(fā)人員,我們總會(huì)遇到這樣的業(yè)務(wù)場(chǎng)景:每周同步一批數(shù)據(jù);每半個(gè)小時(shí)檢查一遍服務(wù)器運(yùn)行狀況;每天早上八點(diǎn)給用戶發(fā)送一份包含今日待辦事項(xiàng)的郵件,等等。 這些場(chǎng)景中都離不開定時(shí)器,就像一個(gè)定好時(shí)間規(guī)則的鬧鐘,它會(huì)在指定時(shí)間觸發(fā),執(zhí)行我們...

    The question 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

閱讀需要支付1元查看
<