使用quartz.jar 、quartz-jobs.jar 實現定時任務 。實現 定時采集 接口數據

  前言

　　定時任務管理，在java中有很多種的方式 ，有java自帶的注解方式@Scheduled  等 ，現在我要說的是一種也是使用比較廣泛的一種quartz管理
　　使用此類 需要的加jar包有 quartz.jar 、quartz-jobs.jar （我這里用的版本是2.2.1），log4j-1.2.17.jar，slf4j-api-1.7.21.jar，slf4j-log4j12-1.7.21.jar (都是必須要的包)

       

 　　也可以通過maven管理，只需引入一個quartz包即可 ，如下：
　　tip:在使用log4j版本時 使用此版本   org.slf4j.Logger;     org.slf4j.LoggerFactory;

　　<!-- quartz定時器 -->
　　<dependency>
　　<groupId>org.quartz-scheduler</groupId>
　　<artifactId>quartz</artifactId>
　　<version>2.2.1</version>
　　</dependency>

 

  首先-創建一個quartz管理類 ，這個類中添加各種情況下 可使用的那些調用方法

　　

public class QuartzManager {  
    private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();  //創建一個SchedulerFactory工廠實例
    private static String JOB_GROUP_NAME = "FH_JOBGROUP_NAME";                      //任務組
    private static String TRIGGER_GROUP_NAME = "FH_TRIGGERGROUP_NAME";              //觸發器組
  
    /**添加一個定時任務，使用默認的任務組名，觸發器名，觸發器組名  
     * @param jobName 任務名
     * @param cls 任務
     * @param time 時間設置，參考quartz說明文檔
     */
    public static void addJob(String jobName, Class<? extends Job> cls, String time) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();                                          //通過SchedulerFactory構建Scheduler對象
            JobDetail jobDetail= JobBuilder.newJob(cls).withIdentity(jobName,JOB_GROUP_NAME).build();    //用於描敘Job實現類及其他的一些靜態信息，構建一個作業實例
            CronTrigger trigger = (CronTrigger) TriggerBuilder
                    .newTrigger()                                                                         //創建一個新的TriggerBuilder來規范一個觸發器
                    .withIdentity(jobName, TRIGGER_GROUP_NAME)                                            //給觸發器起一個名字和組名
                    .withSchedule(CronScheduleBuilder.cronSchedule(time))
                    .build();
            sched.scheduleJob(jobDetail, trigger);  
            if (!sched.isShutdown()) {  
                sched.start();        // 啟動  
            }  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
    
    /**添加一個定時任務，使用默認的任務組名，觸發器名，觸發器組名  （帶參數）
     * @param jobName 任務名
     * @param cls 任務
     * @param time 時間設置，參考quartz說明文檔
     */
    public static void addJob(String jobName, Class<? extends Job> cls, String time, Map<String,Object> parameter) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();                                          //通過SchedulerFactory構建Scheduler對象
            JobDetail jobDetail= JobBuilder.newJob(cls).withIdentity(jobName,JOB_GROUP_NAME).build();    //用於描敘Job實現類及其他的一些靜態信息，構建一個作業實例
            jobDetail.getJobDataMap().put("parameterList", parameter);                                //傳參數
            CronTrigger trigger = (CronTrigger) TriggerBuilder
                    .newTrigger()                                                                         //創建一個新的TriggerBuilder來規范一個觸發器
                    .withIdentity(jobName, TRIGGER_GROUP_NAME)                                            //給觸發器起一個名字和組名
                    .withSchedule(CronScheduleBuilder.cronSchedule(time))
                    .build();
            sched.scheduleJob(jobDetail, trigger);  
            if (!sched.isShutdown()) {  
                sched.start();        // 啟動  
            }  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
  
    /**添加一個定時任務 
     * @param jobName    任務名 
     * @param jobGroupName    任務組名 
     * @param triggerName    觸發器名 
     * @param triggerGroupName    觸發器組名 
     * @param jobClass    任務 
     * @param time    時間設置，參考quartz說明文檔 
     */
    public static void addJob(String jobName, String jobGroupName,  
            String triggerName, String triggerGroupName, Class<? extends Job> jobClass,  
            String time) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            JobDetail jobDetail= JobBuilder.newJob(jobClass).withIdentity(jobName,jobGroupName).build();// 任務名，任務組，任務執行類
            CronTrigger trigger = (CronTrigger) TriggerBuilder     // 觸發器  
                    .newTrigger()
                    .withIdentity(triggerName, triggerGroupName)
                    .withSchedule(CronScheduleBuilder.cronSchedule(time))
                    .build();
            sched.scheduleJob(jobDetail, trigger);
            if (!sched.isShutdown()) {  
                sched.start();        // 啟動  
            } 
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
    
    /**添加一個定時任務  （帶參數）
     * @param jobName    任務名 
     * @param jobGroupName    任務組名 
     * @param triggerName    觸發器名 
     * @param triggerGroupName    觸發器組名 
     * @param jobClass    任務 
     * @param time    時間設置，參考quartz說明文檔 
     */
    public static void addJob(String jobName, String jobGroupName,  
            String triggerName, String triggerGroupName, Class<? extends Job> jobClass,  
            String time, Map<String,Object> parameter) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            JobDetail jobDetail= JobBuilder.newJob(jobClass).withIdentity(jobName,jobGroupName).build();// 任務名，任務組，任務執行類
            jobDetail.getJobDataMap().put("parameterList", parameter);                                //傳參數
            CronTrigger trigger = (CronTrigger) TriggerBuilder     // 觸發器  
                    .newTrigger()
                    .withIdentity(triggerName, triggerGroupName)
                    .withSchedule(CronScheduleBuilder.cronSchedule(time))
                    .build();
            sched.scheduleJob(jobDetail, trigger);
            if (!sched.isShutdown()) {  
                sched.start();        // 啟動  
            } 
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    } 
  
    /** 修改一個任務的觸發時間(使用默認的任務組名，觸發器名，觸發器組名) 
     * @param jobName    任務名 
     * @param time    新的時間設置
     */
    public static void modifyJobTime(String jobName, String time) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();                              //通過SchedulerFactory構建Scheduler對象
            TriggerKey triggerKey = TriggerKey.triggerKey(jobName,TRIGGER_GROUP_NAME);         //通過觸發器名和組名獲取TriggerKey
            CronTrigger trigger = (CronTrigger)sched.getTrigger(triggerKey);                //通過TriggerKey獲取CronTrigger
            if (trigger == null) {  
                return;  
            }  
            String oldTime = trigger.getCronExpression();  
            if (!oldTime.equalsIgnoreCase(time)) {  
                JobKey jobKey = JobKey.jobKey(jobName, JOB_GROUP_NAME);                        //通過任務名和組名獲取JobKey
                JobDetail jobDetail = sched.getJobDetail(jobKey); 
                Class<? extends Job> objJobClass = jobDetail.getJobClass();  
                removeJob(jobName);  
                addJob(jobName, objJobClass, time);  
            }  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
    
    /**修改一個任務的觸發時間 
     * @param triggerName    任務名稱
     * @param triggerGroupName    傳過來的任務名稱
     * @param time    更新后的時間規則
     */
    public static void modifyJobTime(String triggerName, String triggerGroupName, String time) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();                              //通過SchedulerFactory構建Scheduler對象
            TriggerKey triggerKey = TriggerKey.triggerKey(triggerName,triggerGroupName);     //通過觸發器名和組名獲取TriggerKey
            CronTrigger trigger = (CronTrigger)sched.getTrigger(triggerKey);                //通過TriggerKey獲取CronTrigger
            if (trigger == null)  return;  
            CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(trigger.getCronExpression());
            String oldTime = trigger.getCronExpression();  
            if (!oldTime.equalsIgnoreCase(time)) {  
                trigger = (CronTrigger)trigger.getTriggerBuilder()        //重新構建trigger
                        .withIdentity(triggerKey)
                        .withSchedule(scheduleBuilder)
                        .withSchedule(CronScheduleBuilder.cronSchedule(time))
                        .build();
                sched.rescheduleJob(triggerKey, trigger);                //按新的trigger重新設置job執行
            }
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
    
    /**移除一個任務(使用默認的任務組名，觸發器名，觸發器組名) 
     * @param jobName    任務名稱
     */
    public static void removeJob(String jobName) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            TriggerKey triggerKey = TriggerKey.triggerKey(jobName,TRIGGER_GROUP_NAME);     //通過觸發器名和組名獲取TriggerKey
            JobKey jobKey = JobKey.jobKey(jobName, JOB_GROUP_NAME);                        //通過任務名和組名獲取JobKey
            sched.pauseTrigger(triggerKey);    // 停止觸發器  
            sched.unscheduleJob(triggerKey);// 移除觸發器  
            sched.deleteJob(jobKey);        // 刪除任務  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
    
    /**移除一個任務
     * @param jobName    任務名
     * @param jobGroupName    任務組名
     * @param triggerName    觸發器名
     * @param triggerGroupName    觸發器組名
     */
    public static void removeJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            TriggerKey triggerKey = TriggerKey.triggerKey(triggerName,triggerGroupName);     //通過觸發器名和組名獲取TriggerKey
            JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);                            //通過任務名和組名獲取JobKey
            sched.pauseTrigger(triggerKey);    // 停止觸發器  
            sched.unscheduleJob(triggerKey);// 移除觸發器  
            sched.deleteJob(jobKey);        // 刪除任務  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    } 
    
    /**
     * 啟動所有定時任務 
     */
    public static void startJobs() {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            sched.start();  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
  
    /**
     * 關閉所有定時任務 
     */
    public static void shutdownJobs() {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            if (!sched.isShutdown()) {  
                sched.shutdown();  
            }  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
}  

其次-創建 具體任務實現類

　　

public class SwapJob implements Job {
    protected Logger logger = Logger.getLogger(this.getClass());

    public void execute(JobExecutionContext context) throws JobExecutionException {
     
　　　　　System.out.println("我現在是每20秒 打印一次哦");
/*
　　　　這下面的方法 是我 用的Httpclient做測試的 后端請求接收接口數據用的 ，可以不用管，直接刪除就好
        String url=null;
        String responseResult=null;
        try {
            //獲取HttpClient對象
            HttpClient client =  new HttpClient();  
            //設置url 
            url = "http://localhost:8080/FrontC/combotree/gover"; 
            //獲取post請求對象
            PostMethod method = new PostMethod(url); 
            //執行請求對象 返回請求狀態碼
            int requestStatus=  client.executeMethod(method);
            //判斷是否請求成功
                    
            if(requestStatus==200){
            //接收響應數據
            responseResult = method.getResponseBodyAsString();     
            }
             //將String數據轉化成json數據   用於之后json轉對象使用
            System.out.println(JSONObject.parse(responseResult));
            }catch (Exception e){
                e.printStackTrace();     
           } finally {
               System.out.println("請求成功執行！");
        }

*/  

} 

}

最后-使用調用QuartzManager中的方法  ，將參數傳入

 public static void main(String[] args) {
　　　　　　　　　　　　　　　　　//任務名稱      //具體需要完成的任務　　//時間間隔 （想要不用的時間，格式在網上就可以找到）
        QuartzManager.addJob("獲取dept數據", SwapJob.class, "0/20 * * * * ?");
    }

結語

　上面是我的可運行的方法  ，需要使用的朋友，直接代碼復制 到自己的 項目中就可以 使用了 ，前提是 記得把包給 導入先  

　有什么問題 希望 可以在評論區 交流 ！

   quartz定時時間生成器：http://cron.qqe2.com/