亚洲av无码不卡在线播放_ Java Web應用中的任務(wù)調度

任務(wù)調度是大型J2EE web應用中常見(jiàn)的工作。開(kāi)發(fā)者希望以指定的間隔時(shí)間執行各類(lèi)操作，并完成一些無(wú)需用戶(hù)輸入的任務(wù)。Java中可有無(wú)數方法來(lái)做到這一點(diǎn)，但是在web應用中卻并沒(méi)有這方面的統一標準。當許多開(kāi)發(fā)人員參與同一個(gè)項目，并且以各自不同的方式來(lái)實(shí)現任務(wù)調度時(shí)，就可能產(chǎn)生很大問(wèn)題。內存和同步問(wèn)題就是必須首先考慮的兩件事。事實(shí)上，一些開(kāi)發(fā)者試圖調用操作系統層面的任務(wù)調度機制，如Unix平臺上的cron。這種編程實(shí)踐也許并不是太壞，但它將直接導致可移植性被拋到九霄云外。

版權聲明：任何獲得Matrix授權的網(wǎng)站，轉載時(shí)請務(wù)必保留以下作者信息和鏈接
作者:Chris Hardin;Caesar(作者的blog:http://blog.matrix.org.cn/page/Caesar)
原文:http://www.matrix.org.cn/resource/article/44/44357_Quartz+Java.html
關(guān)鍵字:Quartz;scheduling

為何需要任務(wù)調度？

在web應用中，大多數任務(wù)是以一種"防止用戶(hù)長(cháng)時(shí)間等待"的方式完成的。在Google搜索這樣的例子中，減少等待時(shí)間對用戶(hù)體驗來(lái)說(shuō)至關(guān)重要。異步任務(wù)的一種解決方案是在用戶(hù)提交后生成一個(gè)線(xiàn)程（來(lái)處理異步任務(wù)），但這也不能解決那些需要以一定時(shí)間間隔重復運行任務(wù)、或在每天的指定時(shí)間運行任務(wù)的情況。

讓我們從一個(gè)數據庫報表的例子來(lái)看看任務(wù)調度能如何幫助改善系統設計。報表可能是錯綜復雜的，這取決于用戶(hù)所需數據的種類(lèi)，以及是否需要從一個(gè)或多個(gè)數據庫收集大量數據。用戶(hù)可能需要很長(cháng)時(shí)間來(lái)運行這樣的"按需"報表。因此，我們向這個(gè)報表示例中添加任務(wù)調度機制，以便用戶(hù)可以安排在任何他們需要的時(shí)間生成報表，并以PDF或其他格式在email中發(fā)送。用戶(hù)可以讓報表在每天的凌晨2:22，系統正處于低負荷時(shí)運行；也可以選擇只在特定時(shí)間運行一次。通過(guò)在報表應用中加入任務(wù)調度，我們可以為產(chǎn)品添加一項有用的功能，并改善用戶(hù)體驗。

幸運的是，有一個(gè)強大的開(kāi)源解決方案可以讓我們以標準的方式在web應用（或任何Java應用）中實(shí)施任務(wù)調度。以下示例展示了在web應用中，如何使用Quartz來(lái)創(chuàng )建一個(gè)任務(wù)調度框架。這個(gè)示例還使用了Struts Action framework 插件，以便在web應用啟動(dòng)時(shí)初始化任務(wù)調度機制。Struts是最常見(jiàn)的MVC框架，為大多數開(kāi)發(fā)人員所熟悉。當然除此之外還有許多框架可以協(xié)助在web應用中實(shí)現MVC模式。

啟動(dòng)時(shí)初始化任務(wù)調度器

我們首先要做的是建立一個(gè)Struts插件，讓它在容器啟動(dòng)時(shí)創(chuàng )建我們的任務(wù)調度器。在以下例子中，我們選擇Tomcat作為web應用容器，不過(guò)這些示例在其他容器中也應當可以運行。我們要創(chuàng )建一個(gè)Struts插件類(lèi)，并在struts-config.xml中加入幾行代碼以使之可以工作。

這個(gè)插件有兩個(gè)可配置的初始化參數：startOnLoad指定是否要在容器啟動(dòng)時(shí)立即啟動(dòng)任務(wù)調度器，而 startupDelay指定啟動(dòng)任務(wù)調度器之前的等待時(shí)間。啟動(dòng)延時(shí)很有用，因為我們可能需要首先執行一些更重要的初始化步驟。此外還可以使用listener機制，以更復雜的方式來(lái)通知SchedulerPlugIn何時(shí)啟動(dòng)Quartz Scheduler。

  <plug-in className="SchedulerPlugIn">
     <set-property property="startOnLoad" value="false" />
     <set-property property="startupDelay" value="0" />
  </plug-in>

我們要創(chuàng )建的是一個(gè)實(shí)現Struts插件接口org.apache.struts.action.PlugIn的單子類(lèi)SchedulerPlugIn。Struts會(huì )按照配置文件中出現的順序初始化各個(gè)插件。要特別注意的是init()方法中的代碼，在此我們初始化了所需的Quartz對象，并得到Scheduler。我們的任務(wù)信息就要提交到此org.quartz.Scheduler對象，后者將在隨后討論。Scheduler對象由Quartz servlet根據其配置初始化，就像Struts初始化它的ActionServlet類(lèi)一樣。讓我們來(lái)看init()方法：

public void init(ActionServlet actionServlet,
                 ModuleConfig moduleConfig) {

  System.out.println("Initializing Scheduler PlugIn for Jobs!");
  // Retrieve the ServletContext
// 獲取ServletContext
  ServletContext ctx = actionServlet.getServletContext();
  // The Quartz Scheduler
  // Quartz Scheduler對象
  Scheduler scheduler = null;

  // Retrieve the factory from the ServletContext.
  // It will be put there by the Quartz Servlet
  // 從ServletContext取得由Quartz Servlet放置在此的factory對象。
  StdSchedulerFactory factory =  (StdSchedulerFactory) 
      ctx.getAttribute(QuartzInitializerServlet.QUARTZ_FACTORY_KEY);
    
  try{
        // Retrieve the scheduler from the factory
        // 從factory取得scheduler
        scheduler = factory.getScheduler();

        // Start the scheduler in case, it isn‘t started yet
        // 如果scheduler尚未啟動(dòng)，則啟動(dòng)它
        if (m_startOnLoad != null && 
            m_startOnLoad.equals(Boolean.TRUE.toString())){
            System.out.println("Scheduler Will start in " +
            m_startupDelayString + " milliseconds!");
            //wait the specified amount of time before
            // starting the process.
            // 在啟動(dòng)之前等待指定長(cháng)度的時(shí)間
            Thread delayedScheduler =
                new Thread(new DelayedSchedulerStarted (
                                   scheduler, m_startupDelay));
            //give the scheduler a name. All good code needs a name
            //給任務(wù)調度器命名。好的代碼總該有名字！
            delayedScheduler.setName("Delayed_Scheduler");
            //Start out scheduler
            //啟動(dòng)任務(wù)調度器
            delayedScheduler.start();
        }
  } catch (Exception e){
     e.printStackTrace();
  }
    sm_scheduler = scheduler;
}

配置過(guò)程的第二步是在web.xml中加入用來(lái)初始化Quartz servlet（org.quartz.ee.servlet.QuartzInitializerServlet）的內容，因為需要它將SchedulerFactory添加到ServletContext中，以便在我們的Struts插件中可以訪(fǎng)問(wèn)。SchedulerFactory就是我們在Struts插件中獲得Scheduler對象的來(lái)源。除了struts-config.xml 和web.xml之外，還要在web應用的classes目錄下放置一個(gè)quartz.properties文件。此文件的位置也可以在web.xml中作為QuartzInitializerServlet的啟動(dòng)參數來(lái)指定。

  <servlet>

     <servlet-name>QuartzInitializer</servlet-name>
     <display-name>Quartz Initializer Servlet</display-name>

  <servlet-class>
    org.quartz.ee.servlet.QuartzInitializerServlet
  </servlet-class>
  <load-on-startup>1</load-on-startup>
  <init-param>
    <param-name>shutdown-on-unload</param-name>
    <param-value>true</param-value>
  </init-param>

  <init-param>
    <param-name>start-scheduler-on-load</param-name>
    <param-value>false</param-value>
    </init-param>

 </servlet>

這里其實(shí)完全可以不使用Struts和SchedulerPlugIn，但如果將來(lái)決定要以其它的任務(wù)調度框架替換Quartz的話(huà)，額外的抽象層就很有用了。長(cháng)遠看來(lái)，讓一切保持松散耦合總會(huì )使工作變得容易些。如果你使用其它MVC框架，也可以用SchedulerPlugIn.init()方法中的代碼達到同樣的效果。此外，還可以用Servlet 2.3規范中的ServletContextListener來(lái)實(shí)現同樣的初始化過(guò)程。

到此為止web應用已配置完畢，我們可以創(chuàng )建一個(gè).war文件并部署到服務(wù)器上，從控制臺觀(guān)察SchedulerPlugIn的輸出信息。然而在此之前，讓我們先看看如何向任務(wù)調度器提交一項任務(wù)。

我們可以從web應用中的任何類(lèi)訪(fǎng)問(wèn)SchedulerPlugIn的唯一實(shí)例，并調度一些要執行的工作。首先需要一個(gè)Trigger（觸發(fā)器）對象來(lái)告訴任務(wù)何時(shí)運行、每隔多久運行一次。Quartz支持多種觸發(fā)器，在這個(gè)例子中我們使用CronTrigger。

Trigger trigger = new CronTrigger("trigger1", "group1");
trigger.setCronExpression("0 0 15 ? * WED");

以上的觸發(fā)器會(huì )在每周三的下午3點(diǎn)執行指定任務(wù)?，F在我們只要創(chuàng )建一個(gè)JobDetail對象，并把它和上面的觸發(fā)器一起傳遞給SchedulerPlugIn的scheduleWork()方法。

    JobDetail jobDetail =
        new JobDetail("Hello World Job",
                      "Hello World Group",
                      HelloWorld.class,
                      true, true, true);    
//Schedule The work
//調度這項任務(wù)
    SchedulerPlugIn.scheduleWork(scheduledJobDetail, trigger);

實(shí)際工作在何處？

至此我們已決定Trigger，可以開(kāi)始調度工作了?？瓷先ヒ磺卸家淹瓿?，但實(shí)際上我們只是調度了一項任務(wù)，還有最重要的一步有待完成。注意HelloWorld.class作為參數傳遞給了JobDetail的構造函數。這個(gè)類(lèi)就是實(shí)際完成工作的地方。HelloWorld繼承了Quartz的Job類(lèi)，并覆蓋了execute()方法。當任務(wù)管理器決定運行這個(gè)任務(wù)時(shí)，execute()方法將被調用。來(lái)看代碼：

import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;

//extend the proper Quartz class
//繼承適當的Quartz類(lèi)
public class HelloWorld extends Job {

//override the execute method
//覆蓋execute方法
    public void execute(JobExecutionContext context) {

// Every job has it‘s own job detail
//每個(gè)Job都有獨立的JobDetail
    JobDetail jobDetail = context.getJobDetail();
// The name is defined in the job definition
//name在Job定義中指定
    String jobName = jobDetail.getName();
//Every job has a Job Data map for storing extra information
//每個(gè)Job都有一個(gè)Job Data map來(lái)存放額外的信息
    JobDataMap dataMap = jobDetail.getJobDataMap();
       
       System.out.println("Hello World!!!");
   }
 }

出于測試的目的，你可能希望將觸發(fā)器的頻率調的高一點(diǎn)，以便觀(guān)察到HelloWorld的動(dòng)作。畢竟，你不想一直等到凌晨2點(diǎn)才能確定調度的任務(wù)確實(shí)運行了。相反，你可能需要一個(gè)每隔10秒運行的觸發(fā)器：

Trigger trigger = new SimpleTrigger("trigger1", "group1");
trigger.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
trigger.setRepeatInterval(10000L); // milliseconds毫秒

注意，這個(gè)觸發(fā)器沒(méi)有使用類(lèi)cron的語(yǔ)法。Quartz有大量各類(lèi)的選項和配置方法，可適用于任何任務(wù)調度的需要。

其它計時(shí)方式的配置

Quartz提供了多種調度任務(wù)的方式。CronTrigger可能是最復雜的一種，不過(guò)還有其它的選擇。大多數觸發(fā)器可以由Quartz提供的TriggerUtils類(lèi)創(chuàng )建。以下是一些常見(jiàn)的觸發(fā)器的例子。如諺語(yǔ)所言，條條大路通羅馬！
每天凌晨2:22觸發(fā)的觸發(fā)器
// 方法一：使用makeDailyTrigger

Trigger trigger = TriggerUtils.makeDailyTrigger(2, 22);
trigger.setName("trigger1");
trigger.setGroup("group1");

// 方法二：使用CronTrigger

Trigger trigger = new CronTrigger("trigger1", "group1");
trigger.setCronExpression("0 22 2 * * ?");


每5秒執行一次的觸發(fā)器
/*  * 
 * 方法一：makeSecondlyTrigger
 * 注意以下代碼將創(chuàng  )建一個(gè)立即啟動(dòng)的觸發(fā)器。要控制啟動(dòng)時(shí)間，使用
 * trigger.setStartTime(Date)方法。
 */
Trigger trigger = TriggerUtils.makeSecondlyTrigger(5);
trigger.setName("MyFiveSecondTrigger");
trigger.setGroup("MyTriggerGroup");

 /* 
 * 
 * 方法二：設置SimpleTrigger的重復次數和間隔時(shí)間。
 * 注意以下代碼將創(chuàng  )建一個(gè)立即啟動(dòng)的觸發(fā)器。要控制啟動(dòng)時(shí)間，使用
 * trigger.setStartTime(Date)方法。
 */
Trigger trigger = new SimpleTrigger("trigger1", "group1");
trigger.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
trigger.setRepeatInterval(5000L); // milliseconds

按間隔時(shí)間運行任務(wù)

Trigger trigger = new SimpleTrigger("trigger1", "group1");
// 24 hours * 60(minutes per hour) *
// 60(seconds per minute) * 1000(milliseconds per second)
// 24小時(shí) * 60（分鐘每小時(shí)） * 60（秒每分鐘）* 1000（毫秒每秒鐘）
trigger.setRepeatInterval(24L * 60L * 60L * 1000L);

結論
在這個(gè)演示中，我們只接觸了Quartz框架的一些初級功能。記住，Java 5 和J2EE 5也有自己的任務(wù)調度機制，但是它們不像Quartz那樣靈活易用。Quartz是目前唯一的開(kāi)源Java任務(wù)調度框架，它的確為開(kāi)發(fā)者的錦囊中增加了很有用的內容。你可從Open Symphony下載Quartz，并得到一份很好的教程和使用說(shuō)明。

資源
Matrix:http://www.matrix.org.cn
Onjava:http://www.onjava.com
Quartz 教程和使用說(shuō)明
Struts站點(diǎn)

本站僅提供存儲服務(wù)，所有內容均由用戶(hù)發(fā)布，如發(fā)現有害或侵權內容，請點(diǎn)擊舉報。

欧美性猛交XXXX免费看蜜桃,成人网18免费韩国,亚洲国产成人精品区综合,欧美日韩一区二区三区高清不卡,亚洲综合一区二区精品久久