欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Quartz中的Job與JobDetail解析

 更新時間:2023年11月13日 10:00:59   作者:mumuwei_l  
這篇文章主要介紹了Quartz中的Job與JobDetail解析,你定義了一個實現(xiàn)Job接口的類,這個類僅僅表明該job需要完成什么類型的任務,除此之外,Quartz還需要知道該Job實例所包含的屬性;這將由JobDetail類來完成,需要的朋友可以參考下

前言

你定義了一個實現(xiàn)Job接口的類,這個類僅僅表明該job需要完成什么類型的任務

除此之外,Quartz還需要知道該Job實例所包含的屬性;這將由JobDetail類來完成。

Job

讓我們先看看Job的特征(nature)以及Job實例的生命期。不妨先回頭看看第1課中的代碼片段:

  // define the job and tie it to our HelloJob class
  JobDetail job = newJob(HelloJob.class)
      .withIdentity("myJob", "group1") // name "myJob", group "group1"
      .build();

  // Trigger the job to run now, and then every 40 seconds
  Trigger trigger = newTrigger()
      .withIdentity("myTrigger", "group1")
      .startNow()
      .withSchedule(simpleSchedule()
          .withIntervalInSeconds(40)
          .repeatForever())            
      .build();

  // Tell quartz to schedule the job using our trigger
  sched.scheduleJob(job, trigger);

現(xiàn)在考慮這樣定義的作業(yè)類“HelloJob”:

  public class HelloJob implements Job {

    public HelloJob() {
    }

    public void execute(JobExecutionContext context)
      throws JobExecutionException
    {
      System.err.println("Hello!  HelloJob is executing.");
    }
  }

可以看到,我們傳給scheduler一個JobDetail實例,因為我們在創(chuàng)建JobDetail時,將要執(zhí)行的job的類名傳給了JobDetail,所以scheduler就知道了要執(zhí)行何種類型的job;每次當scheduler執(zhí)行job時,在調(diào)用其execute(…)方法之前會創(chuàng)建該類的一個新的實例;執(zhí)行完畢,對該實例的引用就被丟棄了,實例會被垃圾回收;這種執(zhí)行策略帶來的一個后果是,job必須有一個無參的構造函數(shù)(當使用默認的JobFactory時);另一個后果是,在job類中,不應該定義有狀態(tài)的數(shù)據(jù)屬性,因為在job的多次執(zhí)行中,這些屬性的值不會保留。

那么如何給job實例增加屬性或配置呢?如何在job的多次執(zhí)行中,跟蹤job的狀態(tài)呢?答案就是:JobDataMap,JobDetail對象的一部分。

JobDataMap

JobDataMap中可以包含不限量的(序列化的)數(shù)據(jù)對象,在job實例執(zhí)行的時候,可以使用其中的數(shù)據(jù);JobDataMap是Java Map接口的一個實現(xiàn),額外增加了一些便于存取基本類型的數(shù)據(jù)的方法。

將job加入到scheduler之前,在構建JobDetail時,可以將數(shù)據(jù)放入JobDataMap,如下示例:

  // define the job and tie it to our DumbJob class
  JobDetail job = newJob(DumbJob.class)
      .withIdentity("myJob", "group1") // name "myJob", group "group1"
      .usingJobData("jobSays", "Hello World!")
      .usingJobData("myFloatValue", 3.141f)
      .build();

在job的執(zhí)行過程中,可以從JobDataMap中取出數(shù)據(jù),如下示例:

public class DumbJob implements Job {

    public DumbJob() {
    }

    public void execute(JobExecutionContext context)
      throws JobExecutionException
    {
      JobKey key = context.getJobDetail().getKey();

      JobDataMap dataMap = context.getJobDetail().getJobDataMap();

      String jobSays = dataMap.getString("jobSays");
      float myFloatValue = dataMap.getFloat("myFloatValue");

      System.err.println("Instance " + key + " of DumbJob says: " + jobSays + ", and val is: " + myFloatValue);
    }
  }

如果你在job類中,為JobDataMap中存儲的數(shù)據(jù)的key增加set方法(如在上面示例中,增加setJobSays(String val)方法),那么Quartz的默認JobFactory實現(xiàn)在job被實例化的時候會自動調(diào)用這些set方法,這樣你就不需要在execute()方法中顯式地從map中取數(shù)據(jù)了。

在Job執(zhí)行時,JobExecutionContext中的JobDataMap為我們提供了很多的便利。它是JobDetail中的JobDataMap和Trigger中的JobDataMap的并集,但是如果存在相同的數(shù)據(jù),則后者會覆蓋前者的值。

下面的示例,在job執(zhí)行時,從JobExecutionContext中獲取合并后的JobDataMap:

    public class DumbJob implements Job {

        public DumbJob() {
        }

        public void execute(JobExecutionContext context)
          throws JobExecutionException
        {
            JobKey key = context.getJobDetail().getKey();

            JobDataMap dataMap = context.getMergedJobDataMap();  // Note the difference from the previous example

            String jobSays = dataMap.getString("jobSays");
            float myFloatValue = dataMap.getFloat("myFloatValue");
            ArrayList state = (ArrayList)dataMap.get("myStateData");
            state.add(new Date());

            System.err.println("Instance " + key + " of DumbJob says: " + jobSays + ", and val is: " + myFloatValue);
        }
    }

如果你希望使用JobFactory實現(xiàn)數(shù)據(jù)的自動“注入”,則示例代碼為:

  public class DumbJob implements Job {


    String jobSays;
    float myFloatValue;
    ArrayList state;

    public DumbJob() {
    }

    public void execute(JobExecutionContext context)
      throws JobExecutionException
    {
      JobKey key = context.getJobDetail().getKey();

      JobDataMap dataMap = context.getMergedJobDataMap();  // Note the difference from the previous example

      state.add(new Date());

      System.err.println("Instance " + key + " of DumbJob says: " + jobSays + ", and val is: " + myFloatValue);
    }

    public void setJobSays(String jobSays) {
      this.jobSays = jobSays;
    }

    public void setMyFloatValue(float myFloatValue) {
      myFloatValue = myFloatValue;
    }

    public void setState(ArrayList state) {
      state = state;
    }

  }

Job實例

你可以只創(chuàng)建一個job類,然后創(chuàng)建多個與該job關聯(lián)的JobDetail實例,每一個實例都有自己的屬性集和JobDataMap,最后,將所有的實例都加到scheduler中。

比如,你創(chuàng)建了一個實現(xiàn)Job接口的類“SalesReportJob”。該job需要一個參數(shù)(通過JobdataMap傳入),表示負責該銷售報告的銷售員的名字。因此,你可以創(chuàng)建該job的多個實例(JobDetail),比如“SalesReportForJoe”、“SalesReportForMike”,將“joe”和“mike”作為JobDataMap的數(shù)據(jù)傳給對應的job實例。

當一個trigger被觸發(fā)時,與之關聯(lián)的JobDetail實例會被加載,JobDetail引用的job類通過配置在Scheduler上的JobFactory進行初始化。默認的JobFactory實現(xiàn),僅僅是調(diào)用job類的newInstance()方法,然后嘗試調(diào)用JobDataMap中的key的setter方法。你也可以創(chuàng)建自己的JobFactory實現(xiàn),比如讓你的IOC或DI容器可以創(chuàng)建/初始化job實例。

在Quartz的描述語言中,我們將保存后的JobDetail稱為“job定義”或者“JobDetail實例”,將一個正在執(zhí)行的job稱為“job實例”或者“job定義的實例”。當我們使用“job”時,一般指代的是job定義,或者JobDetail;當我們提到實現(xiàn)Job接口的類時,通常使用“job類”。

Job狀態(tài)與并發(fā)

關于job的狀態(tài)數(shù)據(jù)(即JobDataMap)和并發(fā)性,還有一些地方需要注意。在job類上可以加入一些注解,這些注解會影響job的狀態(tài)和并發(fā)性。

@DisallowConcurrentExecution:將該注解加到job類上,告訴Quartz不要并發(fā)地執(zhí)行同一個job定義(這里指特定的job類)的多個實例。請注意這里的用詞。拿前一小節(jié)的例子來說,如果“SalesReportJob”類上有該注解,則同一時刻僅允許執(zhí)行一個“SalesReportForJoe”實例,但可以并發(fā)地執(zhí)行“SalesReportForMike”類的一個實例。所以該限制是針對JobDetail的,而不是job類的。但是我們認為(在設計Quartz的時候)應該將該注解放在job類上,因為job類的改變經(jīng)常會導致其行為發(fā)生變化。

@PersistJobDataAfterExecution:將該注解加在job類上,告訴Quartz在成功執(zhí)行了job類的execute方法后(沒有發(fā)生任何異常),更新JobDetail中JobDataMap的數(shù)據(jù),使得該job(即JobDetail)在下一次執(zhí)行的時候,JobDataMap中是更新后的數(shù)據(jù),而不是更新前的舊數(shù)據(jù)。和 @DisallowConcurrentExecution注解一樣,盡管注解是加在job類上的,但其限制作用是針對job實例的,而不是job類的。由job類來承載注解,是因為job類的內(nèi)容經(jīng)常會影響其行為狀態(tài)(比如,job類的execute方法需要顯式地“理解”其”狀態(tài)“)。

如果你使用了@PersistJobDataAfterExecution注解,我們強烈建議你同時使用@DisallowConcurrentExecution注解,因為當同一個job(JobDetail)的兩個實例被并發(fā)執(zhí)行時,由于競爭,JobDataMap中存儲的數(shù)據(jù)很可能是不確定的。

到此這篇關于Quartz中的Job與JobDetail解析的文章就介紹到這了,更多相關Job與JobDetail解析內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!

相關文章

  • java使用jdbc連接數(shù)據(jù)庫工具類和jdbc連接mysql數(shù)據(jù)示例

    java使用jdbc連接數(shù)據(jù)庫工具類和jdbc連接mysql數(shù)據(jù)示例

    這篇文章主要介紹了java使用jdbc連接數(shù)據(jù)庫的工具類和使用jdbc連接mysql數(shù)據(jù)的示例,需要的朋友可以參考下
    2014-03-03
  • 通過Spring AOP實現(xiàn)異常捕捉機制

    通過Spring AOP實現(xiàn)異常捕捉機制

    在開發(fā)過程中,異常處理是一個不可忽視的重要環(huán)節(jié),合理、優(yōu)雅地處理異常不僅能提高代碼的魯棒性,還能提升系統(tǒng)的用戶體驗,本文將介紹如何通過Spring AOP實現(xiàn)一個高效的異常捕捉機制,使得異常處理變得更加優(yōu)雅和統(tǒng)一,需要的朋友可以參考下
    2024-08-08
  • 解決JDK21中用不了TimeUtild問題

    解決JDK21中用不了TimeUtild問題

    在使用TimeUtil時,可能因為IDE版本不兼容導致問題,升級IDEA到2023.2以上版本可解決此問題,詳細步驟可以通過評論區(qū)索取安裝包或直接從官網(wǎng)下載,分享個人經(jīng)驗,希望對大家有幫助
    2024-10-10
  • Java設計模式之責任鏈模式詳解

    Java設計模式之責任鏈模式詳解

    客戶端發(fā)出一個請求,鏈上的對象都有機會來處理這一請求,而客戶端不需要知道誰是具體的處理對象。這樣就實現(xiàn)了請求者和接受者之間的解耦,并且在客戶端可以實現(xiàn)動態(tài)的組合職責鏈。使編程更有靈活性
    2022-07-07
  • Java項目Guava包?HashMultimap使用及注意事項

    Java項目Guava包?HashMultimap使用及注意事項

    guava基本上可以說是java開發(fā)項目中,大概率會引入的包,今天介紹的主角是一個特殊的容器HashMultmap,可以簡單的將它的數(shù)據(jù)結構理解為Map<K,?Set<V>>,今天主要介紹下基礎的知識點?HashMultmap級使用,感興趣的朋友一起看看吧
    2022-05-05
  • SpringMVC 域?qū)ο蠊蚕頂?shù)據(jù)的實現(xiàn)示例

    SpringMVC 域?qū)ο蠊蚕頂?shù)據(jù)的實現(xiàn)示例

    本文主要介紹了SpringMVC 域?qū)ο蠊蚕頂?shù)據(jù)的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-08-08
  • Javaweb使用thymeleaf局部刷新結合Layui插件實現(xiàn)Html分頁

    Javaweb使用thymeleaf局部刷新結合Layui插件實現(xiàn)Html分頁

    本文主要介紹了Javaweb使用thymeleaf局部刷新結合Layui插件實現(xiàn)Html分頁,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-10-10
  • SpringBoot中的Future接口詳解

    SpringBoot中的Future接口詳解

    這篇文章主要介紹了SpringBoot中的Future接口詳解,在異步編程中,我們通常需要處理一些耗時的操作,一種常見的做法是使用 Future 接口來代表一個異步操作的結果,需要的朋友可以參考下
    2023-07-07
  • 淺談sql_@SelectProvider及使用注意說明

    淺談sql_@SelectProvider及使用注意說明

    這篇文章主要介紹了sql_@SelectProvider及使用注意說明,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-08-08
  • Spring使用@Async出現(xiàn)循環(huán)依賴原因及解決方案分析

    Spring使用@Async出現(xiàn)循環(huán)依賴原因及解決方案分析

    在Spring框架中,啟用異步功能需要在應用主類上添加@EnableAsync注解,當項目中存在循環(huán)引用時,如一個異步類MessageService和一個常規(guī)類TaskService相互引用,并且這兩個類位于同一包內(nèi),這種情況下可能會觸發(fā)Spring的循環(huán)依賴異常
    2024-10-10

最新評論