項目ITP(七) javaWeb 整合 Quartz 實現動態調度而且持久化

時間 2019-11-21

標籤項目 itp javaweb 整合 quartz 實現動態調度而且持久欄目 Java 简体版

原文原文鏈接

原創地址:http://www.cnblogs.com/Alandre/(泥沙磚瓦漿木匠),須要轉載的,保留下!java

弟子規聖人訓首孝弟次謹信泛愛衆而親仁有餘力則學文

Written In The Font

須要:mysql

導入WEB-INF/lib/quartz-2.2.1.jar
而後數據庫建相關表格,能夠去quartz-2.2.1\docs\dbTables目錄下找到對應的數據庫表格.(我這邊Mysql , 導入 tables_mysql.sql 便可)

配置quartz.properties

#============================================================================
# Configure Main Scheduler Properties  
#============================================================================
org.quartz.scheduler.instanceName: wmuitpScheduler
org.quartz.scheduler.instanceId: AUTO

org.quartz.scheduler.skipUpdateCheck: true


#============================================================================
# Configure ThreadPool  
#============================================================================
org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount: 10
org.quartz.threadPool.threadPriority: 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true  

#============================================================================
# Configure JobStore  
#============================================================================

org.quartz.jobStore.misfireThreshold: 60000

org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties=false
org.quartz.jobStore.dataSource=myDS
org.quartz.jobStore.tablePrefix=qrtz_
org.quartz.jobStore.isClustered=true


#============================================================================
# Configure Datasources  
#============================================================================

org.quartz.dataSource.myDS.driver: com.mysql.jdbc.Driver
org.quartz.dataSource.myDS.URL: jdbc:mysql://localhost:3307/itp
org.quartz.dataSource.myDS.user: root
org.quartz.dataSource.myDS.password: 123456
org.quartz.dataSource.myDS.maxConnections: 5
org.quartz.dataSource.myDS.validationQuery: select 0

View Code

基本步驟:web

web.xml註冊監聽器ScheduleStartListener

註冊quartz監聽器,監聽項目是否啓動或者重啓.保證項目啓動或重啓時,全部任務會被從新安排到任務調度中.sql

web.xml添加一個Listener:數據庫

<!-- quartz監聽器 -->  
<listener>
    <listener-class>sedion.jeffli.wmuitp.listener.ScheduleStartListener</listener-class>
</listener>

監聽器類sedion.jeffli.wmuitp.listener.ScheduleStartListener實現

監聽器類主要是實現recovery各個任務,從新恢復在triggerGroups組中全部的觸發器,按新的trigger從新設置job執行.順便說下,這個異常自定義(不須要刪除便可): sedion.jeffli.wmuitp.exception.QuartzException; tomcat

package sedion.jeffli.wmuitp.listener;

import java.util.List;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;

import sedion.jeffli.wmuitp.exception.QuartzException;

public class ScheduleStartListener implements ServletContextListener
{

    public void contextDestroyed(ServletContextEvent sce) 
    {
        
    }

    public void contextInitialized(ServletContextEvent sce) 
    {
        try 
        {
            recovery();
        } 
        catch (Exception e)
        {
            throw new QuartzException(" ScheduleStartListener contextInitialized ERROR!!",e);
        }
    }
    

    public void recovery() 
    {
        
        Scheduler scheduler = null;
        
        try {
            
            SchedulerFactory schedulerFactory = new StdSchedulerFactory();
            scheduler = schedulerFactory.getScheduler();//能夠經過SchedulerFactory建立一個Scheduler實例
            List<String> triggerGroups = scheduler.getTriggerGroupNames();//獲取調度器中全部的觸發器組
            System.out.println("調度器中全部的觸發器組 size():"+triggerGroups.size());
            
            if(triggerGroups != null && triggerGroups.size() != 0)//從新恢復在triggerGroups組中全部的觸發器
            {
                for (int i = 0; i < triggerGroups.size(); i++) 
                {
                        TriggerKey triggerKey = TriggerKey.triggerKey(triggerGroups.get(i), triggerGroups.get(i));
                        System.out.println("triggerKey:"+triggerKey);
                        
                        Trigger tg = scheduler.getTrigger(triggerKey);//獲取trigger
                        System.out.println(triggerKey+" -> 執行時間 :"+tg.getNextFireTime());
                        
                        scheduler.rescheduleJob(triggerKey, tg);//按新的trigger從新設置job執行
                }
            }
            
            scheduler.start();
            
        } 
        catch (Exception e) 
        {
            throw new QuartzException("ScheduleStartListener  recovery() Error!", e);
        }
    }
}

測試案例第一步: Job 接口實現類JobTest

顧名思義,用於自定義任務,方法的實現.你能夠在其中寫入任意你想要在那個點上乾的事情(操做數據庫,前臺顯示等).在下面那處地方寫入你想要寫的:System.out.println("添入須要加入任務的具體操做"); .順便說下,這個異常自定義(不須要刪除便可):服務器

package test.quartz;


import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;

import sedion.jeffli.wmuitp.exception.QuartzException;


public class JobTest implements Job{
    
    public JobTest() {}    
  
    public void execute(JobExecutionContext context)throws JobExecutionException
    {  
        
        JobDataMap data = context.getJobDetail().getJobDataMap();
        System.out.println("data.testId : "+data.getInt("testId")); //不須要可刪除
        
        try
        {
            System.out.println("添入須要加入任務的具體操做");
        }
        catch (Exception e) 
        {
            throw new QuartzException("JobTest execute() ERROR !!", e);
        }
    }  
    
    public static void removeJob(JobKey jobKey, TriggerKey tiKey)throws SchedulerException
    { 
        
        SchedulerFactory sf     = new StdSchedulerFactory();
        Scheduler          sched     = sf.getScheduler();  
        
        sched.pauseTrigger(tiKey);            //中止觸發器  
        sched.unscheduleJob(tiKey);            //移除觸發器  
        sched.deleteJob(jobKey);            //刪除任務  
        
    } 
}

測試案例第二步:QuartzTest

顧名思義,用於實現,檢驗.能夠經過SchedulerFactory建立一個Scheduler實例,把觸發器在集羣節點實例命名的組只是爲了區分（伐木）從什麼地方定問調度從新執行此做業，若是它是正在進行時調度下去.ide

package test.quartz;

import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

import java.util.Date;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;


public class QuartzTest
{

    public void run(String date, int id)throws Exception 
    {

        
        SchedulerFactory schedulerFactory = new StdSchedulerFactory();
        Scheduler scheduler = schedulerFactory.getScheduler();//能夠經過SchedulerFactory建立一個Scheduler實例
        
        //設置工做詳情
        JobDetail job = newJob(JobTest.class) 
            .withIdentity("job_"+id, "test"+id)         // (String name, String group)把觸發器在集羣節點實例命名的組只是爲了區分（伐木）從什麼地方定問調度從新執行此做業，若是它是正在進行時調度下去...
            .requestRecovery()                             
            .build();
       
        job.getJobDataMap().put("testId", id);        //設置存儲參數(不須要可刪除)
        
       
        Date startDate = FormatDate.stringToDateAll(date);//Date轉String
        //設置觸發器
        SimpleTrigger trigger = (SimpleTrigger) newTrigger()
                .withIdentity("overdue"+id, "overdue"+id)//withIdentity("trigger", "group")
                .startAt(startDate)
                .build();
        
        scheduler.scheduleJob(job, trigger);
        scheduler.start();
        System.out.println("------- Start Scheduler ----------------");
    }
    
    public static void main(String[] args) throws Exception 
    {
        QuartzTest quartzOverdue = new QuartzTest();
        quartzOverdue.run("2014-07-02 00:30:00",666);//666,隨便的吉祥數字
    }
}

這邊,項目tomcat啓動.這邊個人主機時間是:
測試

而後咱們運行:ui

public static void main(String[] args) throws Exception 
    {
        QuartzTest quartzOverdue = new QuartzTest();
        quartzOverdue.run("2014-07-02 00:30:00",666);//666,隨便的吉祥數字
    }

看控制檯:

先輸出

------- Start Scheduler ----------------

而後時間到了

添入須要加入任務的具體操做

而後測試 quartz的持久化.(持久化測試就是先開啓任務,而後中間斷開重啓服務器),之間你會發現控制檯:

今天我重寫了下,:

public static void main(String[] args) throws Exception 
    {
        QuartzTest quartzOverdue = new QuartzTest();
        quartzOverdue.run("2014-07-02 10:00:00",6666);
    }

調度器中全部的觸發器組 size():1
triggerKey:test6666.test6666
test6666.test6666 -> 執行時間 :Wed Jul 02 10:00:00 CST 2014

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。

項目ITP(七) javaWeb 整合 Quartz 實現動態調度 而且 持久化