2. 程式人生 > >專案ITP(七) javaWeb 整合 Quartz 實現動態排程 而且 持久化 專案ITP(七) javaWeb 整合 Quartz 實現動態排程 而且 持久化

專案ITP(七) javaWeb 整合 Quartz 實現動態排程 而且 持久化 專案ITP(七) javaWeb 整合 Quartz 實現動態排程 而且 持久化

阿新 • • 發佈：2018-12-08

專案ITP(七) javaWeb 整合 Quartz 實現動態排程 而且 持久化

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

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

Written In The Font

須要:WEB-INF/lib/quartz-2.2.1.jar

基本步驟:

 

web.xml註冊監聽器ScheduleStartListener

註冊quartz監聽器,監聽專案是否啟動或者重新啟動.保證專案啟動或重新啟動時,全部任務會被又一次安排到任務排程中.

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;

複製程式碼 
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例項,把觸發器在叢集節點例項命名的組僅僅是為了區分（伐木）從什麼地方定問排程又一次執行此作業，假設它是正在進行時排程下去.

複製程式碼 
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啟動.這邊我的主機時間是:
image

 

然後我們執行:

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

 

看控制檯:

先輸出

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

然後時間到了

添入須要增加任務的詳細操作

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

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

Written In The Font

須要:WEB-INF/lib/quartz-2.2.1.jar

基本步驟:

 

web.xml註冊監聽器ScheduleStartListener

註冊quartz監聽器,監聽專案是否啟動或者重新啟動.保證專案啟動或重新啟動時,全部任務會被又一次安排到任務排程中.

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;

複製程式碼 
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例項,把觸發器在叢集節點例項命名的組僅僅是為了區分（伐木）從什麼地方定問排程又一次執行此作業，假設它是正在進行時排程下去.

複製程式碼 
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啟動.這邊我的主機時間是:
image

 

然後我們執行:

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

 

看控制檯:

先輸出

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

然後時間到了

添入須要增加任務的詳細操作

相關推薦

專案ITP(七) javaWeb 整合 Quartz 實現動態排程 而且 持久化 專案ITP(七) javaWeb 整合 Quartz 實現動態排程 而且 持久化

專案ITP(七) javaWeb 整合 Quartz 實現動態排程 而且 持久化 原創地址:http://www.cnblogs.com/Alandre/(泥沙磚瓦漿木匠),須要轉載的,保留下! 弟子規 聖人訓 首孝弟 次謹信 泛愛眾 而親仁 有餘力 則學文

springboot動態配置定時任務2種方式，整合Quartz多執行緒併發執行多個定時任務配置

我的專案是採用的idea+gradle+springboot專案構建，下面是springboot實現定時任務所需要的jar包 //定時任務使用 compile group: 'org.quartz-scheduler', name: 'quartz', version:

Activiti-5.18.0與springMvc專案整合和activiti-explorer單獨部署Web專案並與業務資料庫關聯方法（AutoEE_V2實現方式）

Activiti-5.18.0與springMvc專案整合和 activiti-explorer單獨部署Web專案並與業務資料庫關聯方法 （AutoEE實現方式） Double_AutoEE 2015-10-15  AutoEE-自動智慧快速開發

JavaWeb網上圖書商城完整項目--day02-12.激活功能各層實現

find java writer 之間 and service() 配置文件 private pop 1、我們來看程序的代碼 數據庫層： 1、通過激活碼查找到對應的用戶 2、設置用戶的激活狀態 2、業務層 1、通過數據庫接口通過驗證碼得到對應的用戶 2、判斷當用戶是否為

TF之RNN：matplotlib動態演示之基於順序的RNN回歸案例實現高效學習逐步逼近余弦曲線—Jason niu

hold batch main 技術分享 1.0 dict asi itl plot import tensorflow as tf import numpy as np import matplotlib.pyplot as plt BATCH_START = 0

Spring中AOP：Proxy動態代理淺解析（被代理對象必須實現接口）

ima throwable light public RR eth 對象 處理 span 小貼士：以下內容純屬個人觀點，如有不當請指出並諒解 import java.lang.reflect.Proxy; Proxy可以動態代理一個對象 寫一個代理工廠類ProxyFac

項目一:第七天 CRM 和bos系統實現定區關聯客戶,關聯快遞員. 通過CXF框架實現

TE tag CA alert ger 快遞員 datagrid png tor 定區關聯客戶 需求：為了快遞方便客戶下訂單（發快遞），派快遞員上門取件。 所以說需要讓定區關聯客戶（知道客戶屬於哪個定區），定區跟快遞員關系：多對多。知道讓哪個快遞員上門取件。

【Unity】用Shader實現圖片的區域遮罩，支援半透明，實現地圖動態上色功能

一個專案，做世界地圖時，希望未開啟的地塊是線稿，新地塊開啟時，做一個上色處理。 想到的方案就是：上了色的彩圖蓋線上稿上，然後用mask 控制彩圖的區域性顯隱。 網上找了一個，可以半透明遮罩的shader：https://www.jianshu.com/p/1d9d439c28fa 要控制不同區塊

Spring使用註解的方式實現AOP的開發——Spring AOP（七）

上一章我們已經學過使用XML的方式實現AOP： https://blog.csdn.net/qq_34598667/article/details/83502426 本章我們學習一下使用註解的方式實現AOP Spring使用註解的方式實現AOP的開發 本章所需知識點

Java併發（七）：雙重檢驗鎖定DCL Java併發（六）：volatile的實現原理

雙重檢查鎖定（Double Check Lock，DCL） 1、懶漢式單例模式，無法保證執行緒安全： public class Singleton { private static Singleton singleton; private Singleton

linux伺服器中Jenkins整合git、Gradle持續構建Springboot專案

Jenkins是用java編寫的開源持續整合工具，目前被國內外各公司廣泛使用。本章教大家如何在linux伺服器中使用Jenkins自動釋出一個可作為linux服務釋出的Springboot專案。 自動構建需要經過如下步驟：從git倉庫下載程式碼、使用Gradle進行構建、使用SSH推送到另

Spring裡的aop實現方式和原始碼分析 java中代理，靜態代理，動態代理以及spring aop代理方式，實現原理統一彙總

使用"橫切"技術，AOP把軟體系統分為兩個部分：核心關注點和橫切關注點。業務處理的主要流程是核心關注點，與之關係不大的部分是橫切關注點。橫切關注點的一個特點是，他們經常發生在核心關注點的多處，而各處基本相似，比如許可權認證、日誌、事務。AOP的作用在於分離系統中的各種關注點，將核心關注點和橫切關注點分離開來。

Docker實現執行tomcat並部署專案war包

之前寫的有點亂，現在再來整理一下docker的簡單部署執行 借鑑部落格：https://blog.csdn.net/qq_32351227/article/details/78673591 一、docker的安裝，以及配置開機自啟docker服務就不說了，網上一大把，我也做了另一篇部落格筆記 #。

Springboot整合文件開發工具Swagger《SpringBoot學習七》

1. 為什麼要引用Swagger? 我們在之前的開發中大部分都是前後的分離，前端人員不知道要呼叫說明介面，但是後臺人員又不想寫介面文件，介面文件好麻煩，不知道有沒有同學寫過，特別麻煩，反正我不想寫，我在想如果有一個工具能在程式碼開發的時候就生成介面文件該多好，於是Swagger就解決

android形狀屬性、鎖屏密碼、動態模糊、kotlin專案、抖音動畫、記賬app、視訊播放器等原始碼

Android精選原始碼 直觀瞭解Android的“形狀”屬性如何影響Drawable的外觀。 一個靈活的視訊播放器, 可替換播放器核心。 android鎖屏輸入密碼功能原始碼 背景動態模糊方案，元件實現類對bitmap模糊處理的各類算... 簡單天氣，帶

如何整合潤乾報表到spring boot專案

Spring Boot 是由 Pivotal 團隊提供的全新框架，其設計目的是用來簡化新 Spring 應用的初始搭建以及開發過程。該框架使用了特定的方式來進行配置，從而使開發人員不再需要定義樣板化的配置。下面介紹下一個簡單的 springBoot 專案的搭建以及與潤乾 V2018 整合的過程。

基於springboot2 框架整合（1）：spring boot專案初始化

前言 專案中使用了很多現成的框架，都是專案經理、架構師帶來的，從來沒有自己整合過！這次決定自己從零開始整合一次，以學習鞏固。過程中參考很多開源框架的思路，工具類等，若有侵權，請速速聯絡，一定妥善處理   一：建立maven專案 這個不多說，給出pom.xml

jsp+servlet+mysql實現簡單登入的完整專案

一、分析專案之前要了解下properties檔案的使用 在開發專案時，有很多地方會出現重複的程式碼或者日後可能需要修改的程式碼，比如：連線資料庫、設定專案編碼格式、設定檔案上傳儲存目錄等等。重複程式碼或許可以用靜態變數來實現全域性呼叫而不必重複出現，但是畢竟是寫死在程式碼裡的，日後需要修改時

【效能優化】如何實現：c/c++整個專案工程使用一個全域性變數

如果工程中存在malloc/free等頻繁動態分配和釋放記憶體的情況，一般優化思路是： 方法1：加記憶體池 方法2：使用全域性buf 方法1的優點：眾所周知，不詳細說了。 方法2使用場合：整個工程執行過程中，動態分配的記憶體大小有規律性且有最大個數。可以在工程起始

學習mysql資料庫最好的方法，從專案入手，電子資源賬務管理系統(electronic_resources)，理解專案如何實現的

電子資源賬務管理系統mysql資料庫建立語句 電子資源賬務管理系統oracle資料庫建立語句 電子資源賬務管理系統sqlserver資料庫建立語句 電子資源賬務管理系統spring+springMVC+hibernate框架物件(javaBean,pojo)設計