Quartz可以用來做什麼？

Quartz可以用來做什麼？

Quartz是一個任務調度框架。例如你遇到這樣的問題

• 想每月25號，信用卡自動還款

• 想每年4月1日自己給當年暗戀女神發一封匿名賀卡

• 想每隔1小時，備份一下自己的愛情動作片學習筆記到雲盤

這些問題總結起來就是：在某一個規律的時間點做某件事。而時間的觸發的條件可以非常複雜（例如每月最後一個工作日的17:50），複雜到需要一個專門的框架來幹這個事。 Quartz就是來做這樣的事，你給它一個觸發條件的定義，它負責到了時間點，觸發對應的Job起來工作。

廢話不多說，程式碼槓槓的。 。 。

public static void main(String[] args) {     
try { 
//创建scheduler
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
//定义一个Trigger
Trigger trigger =TriggerBuilder.newTrigger().withIdentity("trigger1", "group1") //定义name/group.startNow()//一旦加入scheduler，立即生效.
withSchedule(SimpleScheduleBuilder.simpleSchedule() //使用SimpleTrigger.withIntervalInSeconds(1) //每隔一秒执行一次.repeatForever()) //一直执行        
.build();
//定义一个JobDetail
JobDetail job =JobBuilder.newJob(HelloQuartz.class) //定义Job类为HelloQuartz类，这是真正的执行逻辑所在.withIdentity("job1", "group1") //定义name/group.usingJobData("name", "quartz") //定义属性        .build();
//加入这个调度    
scheduler.scheduleJob(job, trigger);
//启动之    
scheduler.start();
//运行一段时间后关闭 
Thread.sleep(10000);
      scheduler.shutdown(true);
   } catch (Exception e) {
    e.printStackTrace();
}

}

HelloQuartz类

public class HelloQuartz implements Job {public void execute(JobExecutionContext context) throws JobExecutionException {
        JobDetail detail = context.getJobDetail();
        String name = detail.getJobDataMap().getString("name");
        System.out.println("say hello to " + name + " at " + new Date());
    }
}

jar套件：

這個例子很好的覆蓋了Quartz最重要的3個基本要素：

• Scheduler：調度器。所有的調度都是由它來控制。

• Trigger： 定義觸發的條件。例子中，它的類型是SimpleTrigger，每隔1秒中執行一次（什麼是SimpleTrigger下面會有詳述）。

• JobDetail & Job： JobDetail 定義的是任務數據，而真正的執行邏輯是在Job中，範例中是HelloQuartz。 為什麼要設計成JobDetail + Job，不直接使用Job？這是因為任務是有可能並發執行，如果Scheduler直接使用Job，就會存在對同一個Job實例並發存取的問題。而JobDetail & Job 方式，sheduler每次執行，都會根據JobDetail建立一個新的Job實例，這樣就可以規避並發存取的問題。

Scheduler

Scheduler就是Quartz的大腦，所有任務都是由它來設施。

Schduelr包含一個兩個重要元件: JobStore和ThreadPool。

JobStore是會來儲存執行時間資訊的，包括Trigger,Schduler,JobDetail，業務鎖等。它有多種實作RAMJob(記憶體實作)，JobStoreTX(JDBC，交易由Quartz管理），JobStoreCMT(JDBC，使用容器事務)，ClusteredJobStore(叢集實作)、TerracottaJobStore(什麼是Terractta )。

ThreadPool就是執行緒池，Quartz有自己的執行緒池實作。所有任務的都會由執行緒池執行。

SchedulerFactory

SchdulerFactory，顧名思義就是來用創建Schduler了，有兩個實作：DirectSchedulerFactory和 StdSchdulerFactory。前者可以用來在程式碼裡自訂自己的Schduler參數。後者是直接讀取classpath下的quartz.properties（不存在就都使用預設值）配置來實例化Schduler。通常來講，我們使用StdSchdulerFactory也就夠了。

SchdulerFactory本身是支援創建RMI stub的，可以用來管理遠端的Scheduler，功能與本地一樣，可以遠端提交個Job什麼的。

1.job

實作類別JobDetail

    JobDetail job = JobBuilder.newJob(RemindJob.class)
            .withIdentity("job1", "group1").build();//创建一个任务
     /**
      * 创建触发器
      * 第一种方式  不太好      */SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger", "myTriggerGroup").
    withSchedule(SimpleScheduleBuilder.simpleSchedule().
            withIntervalInSeconds(3).
            repeatForever()).
            startAt(new Date(System.currentTimeMillis()+1000)).build();    
    /**
     * 创建触发器
     * 第二种 方式  非常好
     * 可以 好用  2013年每月的第三个星期五上午10:30触发  0 30 10 ? * 6#3 2013
     * 2016年每月的第一个星期四下午16:17触发   0 17 16 ? * 5#1 2016
     * 每天15点到16点每5分钟运行一次，此外，每天17点到18点每5分钟运行一次  

     *//*CronTrigger trigger=TriggerBuilder.newTrigger() 
            .withIdentity("myTrigger", "myTriggerGroup")
            .withSchedule(CronScheduleBuilder.cronSchedule("0 18 16 ? * 5#1 2016")).build();*/
    SchedulerFactory sf=new StdSchedulerFactory();//创建调度者工厂Scheduler scheduler = sf.getScheduler();//创建一个调度者scheduler.scheduleJob(job,trigger);//注册并进行调度scheduler.start();//启动调度    //Thread.sleep(millis)    //scheduler.shutdown();//关闭调度

RemindJob 类的定义

#

 */public class RemindJob implements Job {private RemindService service=new RemindService();
    @Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {
        service.printPlan("你好！");
        
        Date date=new Date();
        String time = date.toString();
        System.out.println(time+"job is starting");
    }

可以看到，我們傳給scheduler一個JobDetail實例，因為我們在建立JobDetail時，將要執行的job的類別名稱傳給了JobDetail，所以scheduler就知道了要執行何種類型的job；每次當scheduler執行job時，在呼叫其execute(…)方法之前會建立該類別的一個新的實例；執行完畢，對該實例的引用就被丟棄了，實例會被垃圾回收；這種執行策略帶來的一個後果是，job必須有一個無參的建構子（當使用預設的JobFactory）；另一個後果是，在job類別中，不應該定義有狀態的資料屬性，因為在job的多次執行中，這些屬性的值不會保留。

那麼如何為job實例增加屬性或配置呢？如何在job的多次執行中，追蹤job的狀態？答案就是:JobDataMap，JobDetail物件的一部分。

JobDataMap

JobDataMap中可以包含不限量的（序列化的）資料對象，在job實例執行的時候，可以使用其中的資料；JobDataMap是Java Map介面的一個實現，額外增加了一些便於存取基本類型的資料的方法。

將job加入scheduler之前，在建構JobDetail時，可以將資料放入JobDataMap，如下範例：

    JobDetail job=JobBuilder.newJob(RemindJob.class)
            .withIdentity("job1", "group1")
            .usingJobData("hello", "we are family")
            .build();

在job的執行過程中，可以從JobDataMap中取出數據，如下範例：

@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {
        service.printPlan("你好！");
        JobKey key=context.getJobDetail().getKey();
        
        JobDataMap map = context.getJobDetail().getJobDataMap();
        String string = map.getString("hello");
        System.out.println(key+"==========="+string);
        
        Date date=new Date();
        String time = date.toString();
        System.out.println(time+"job is starting");
    }

如果你使用的是持久化的存储机制（本教程的JobStore部分会讲到），在决定JobDataMap中存放什么数据的时候需要小心，因为JobDataMap中存储的对象都会被序列化，因此很可能会导致类的版本不一致的问题；Java的标准类型都很安全，如果你已经有了一个类的序列化后的实例，某个时候，别人修改了该类的定义，此时你需要确保对类的修改没有破坏兼容性；更多细节，参考现实中的序列化问题。另外，你也可以配置JDBC-JobStore和JobDataMap，使得map中仅允许存储基本类型和String类型的数据，这样可以避免后续的序列化问题。

如果你在job类中，为JobDataMap中存储的数据的key增加set方法（如在上面示例中，增加setJobSays(String val)方法），那么Quartz的默认JobFactory实现在job被实例化的时候会自动调用这些set方法，这样你就不需要在execute()方法中显式地从map中取数据了。

在Job执行时，JobExecutionContext中的JobDataMap为我们提供了很多的便利。它是JobDetail中的JobDataMap和Trigger中的JobDataMap的并集，但是如果存在相同的数据，则后者会覆盖前者的值。

下面的示例，在job执行时，从JobExecutionContext中获取合并后的JobDataMap：

@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {
        service.printPlan("你好！");
        JobKey key=context.getJobDetail().getKey();        /*    JobDataMap map = context.getJobDetail().getJobDataMap();
        String string = map.getString("hello");
        System.out.println(key+"==========="+string);*/ JobDataMap map = context.getMergedJobDataMap();
         String string = map.getString("hello");
         System.out.println(key+"---------------------    "+string);

 

以上是Quartz可以用來做什麼？的詳細內容。更多資訊請關注PHP中文網其他相關文章！