2.4 Java Web應(yīng)用中的任務(wù)調(diào)度
為何需要任務(wù)調(diào)度?
在web應(yīng)用中,大多數(shù)任務(wù)是以一種"防止用戶長時間等待"的方式完成的。在Google搜索這樣的例子中,減少等待時間對用戶體驗來說至關(guān)重要。異步任務(wù)的一種解決方案是在用戶提交后生成一個線程(來處理異步任務(wù)),但這也不能解決那些需要以一定時間間隔重復運行任務(wù)、或在每天的指定時間運行任務(wù)的情況。
讓我們從一個數(shù)據(jù)庫報表的例子來看看任務(wù)調(diào)度能如何幫助改善系統(tǒng)設(shè)計。報表可能是錯綜復雜的,這取決于用戶所需數(shù)據(jù)的種類,以及是否需要從一個或多個數(shù)據(jù)庫收集大量數(shù)據(jù)。用戶可能需要很長時間來運行這樣的"按需"報表。因此,我們向這個報表示例中添加任務(wù)調(diào)度機制,以便用戶可以安排在任何他們需要的時間生成報表,并以PDF或其他格式在email中發(fā)送。用戶可以讓報表在每天的凌晨2:22,系統(tǒng)正處于低負荷時運行;也可以選擇只在特定時間運行一次。通過在報表應(yīng)用中加入任務(wù)調(diào)度,我們可以為產(chǎn)品添加一項有用的功能,并改善用戶體驗。
幸運的是,有一個強大的開源解決方案可以讓我們以標準的方式在web應(yīng)用(或任何Java應(yīng)用)中實施任務(wù)調(diào)度。以下示例展示了在web應(yīng)用中,如何使用Quartz來創(chuàng)建一個任務(wù)調(diào)度框架。這個示例還使用了Struts Action framework 插件,以便在web應(yīng)用啟動時初始化任務(wù)調(diào)度機制。Struts是最常見的MVC框架,為大多數(shù)開發(fā)人員所熟悉。當然除此之外還有許多框架可以協(xié)助在web應(yīng)用中實現(xiàn)MVC模式。
啟動時初始化任務(wù)調(diào)度器
我們首先要做的是建立一個Struts插件,讓它在容器啟動時創(chuàng)建我們的任務(wù)調(diào)度器。在以下例子中,我們選擇Tomcat作為web應(yīng)用容器,不過這些示例在其他容器中也應(yīng)當可以運行。我們要創(chuàng)建一個Struts插件類,并在struts-config.xml中加入幾行代碼以使之可以工作。
這個插件有兩個可配置的初始化參數(shù):startOnLoad指定是否要在容器啟動時立即啟動任務(wù)調(diào)度器,而 startupDelay指定啟動任務(wù)調(diào)度器之前的等待時間。啟動延時很有用,因為我們可能需要首先執(zhí)行一些更重要的初始化步驟。此外還可以使用listener機制,以更復雜的方式來通知SchedulerPlugIn何時啟動Quartz Scheduler。
我們要創(chuàng)建的是一個實現(xiàn)Struts插件接口org.apache.struts.action.PlugIn的單子類SchedulerPlugIn。Struts會按照配置文件中出現(xiàn)的順序初始化各個插件。要特別注意的是init()方法中的代碼,在此我們初始化了所需的Quartz對象,并得到Scheduler。我們的任務(wù)信息就要提交到此org.quartz.Scheduler對象,后者將在隨后討論。Scheduler對象由Quartz servlet根據(jù)其配置初始化,就像Struts初始化它的ActionServlet類一樣。讓我們來看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尚未啟動,則啟動它
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.
相關(guān)推薦:北京 | 天津 | 上海 | 江蘇 | 山東 |
安徽 | 浙江 | 江西 | 福建 | 深圳 |
廣東 | 河北 | 湖南 | 廣西 | 河南 |
海南 | 湖北 | 四川 | 重慶 | 云南 |
貴州 | 西藏 | 新疆 | 陜西 | 山西 |
寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
黑龍江 | 內(nèi)蒙古 |