亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Job與JobDetail在Quartz中的區別有哪些

發布時間:2020-11-24 15:06:26 來源:億速云 閱讀:291 作者:Leah 欄目:編程語言

Job與JobDetail在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包:

Job與JobDetail在Quartz中的區別有哪些

這個例子很好的覆蓋了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

Job與JobDetail在Quartz中的區別有哪些

實現類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();
  @Override
  public 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中取出數據,如下示例:

@Override
  public 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:

@Override
  public 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);

看完上述內容,你們掌握Job與JobDetail在Quartz中的區別有哪些的方法了嗎?如果還想學到更多技能或想了解更多相關內容,歡迎關注億速云行業資訊頻道,感謝各位的閱讀!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

法库县| 集贤县| 梧州市| 尚义县| 通山县| 武夷山市| 黄梅县| 珠海市| 灌云县| 新晃| 井冈山市| 兴安盟| 铜梁县| 井陉县| 瑞丽市| 读书| 望城县| 千阳县| 大庆市| 南澳县| 佛冈县| 南江县| 仁布县| 江口县| 富平县| 贞丰县| 石渠县| 资兴市| 宁波市| 宝应县| 乡宁县| 博客| 隆德县| 徐闻县| 肥西县| 历史| 石阡县| 漠河县| 湄潭县| 梨树县| 渝中区|