在J2EE环境中使用Quartz企业级计划调度器（1） - 编程入门网

在J2EE环境中使用Quartz企业级计划调度器（1）

Quartz 是来自OpenSymphony的一个开发源代码的企业级工作计划调度器。要了解详情以及下载Quartz请访问http://www.quartzscheduler.org/quartz/。你可以在你的J2EE应用如EJB中使用Quartz来调度工作计划。本文将会介绍在你的J2EE应用中如何使用Quartz来安排工作计划。文章中将会使用Oracle应用服务器10g J2EE容器（OC4J 9.0.4）作为J2EE容器的例子。

Quartz 支持多种类型的工作和触发器，但其中最流行的就是cron级别的触发器。要了解Quartz 工作计划调度的兼容性，请参考Quartz 的文档： http://www.quartzscheduler.org/quartz/docs.html。另外Dejan Bosanac 也写了一篇非常好的文章Job Scheduling in Java 可能会对你有所帮助。

在我们进入细节论题之前，先假设你有一个业务案例，需要让一项工作每30分钟运行一次。在本文中我们将会讨论如何使用Quartz的克龙级触发器功能来做到这一点。

1 定义你的工作为EJB方法

在J2EE应用中使用计划任务的第一步就是创建EJB并将业务逻辑封装为EJB的方法。举个例子，我创建了一个名称为TestEJB的无状态的EJB，其中有一个方法叫做yourMethod我需要定义为计划任务。为了更清楚一点，下面我列举了我的EJB的代码片段和EJB部署描述：

package howto.quartz.ejb; import java.rmi.*; import javax.ejb.*; public class TestEJBBean implements SessionBean { public TestEJBBean() { } // EJB life cycle methods are omitted for brevity ........ public void yourMethod() throws RemoteException { System.out.println("TestEJB Job"); } }

2 从一个通常的Servlet使用Quartz API来定制你的计划任务

Quartz 使用自己的线程池，这些线程并不是容器线程。Servlet API 允许用户线程，并且因为你需要创建一个Servlet并使用Quartz API 来排定计划任务。Quartz 提供了QuartzInitializerServlet 作为其工作计划服务的入口。在本例中我们需要将TestEJB的yourMethod方法提交为工作任务。因此我们将创建一个GenericServlet 名称为howto.quartz.servlet.QuartzServlet，并在init() 方法中将EJB 方法提交为一个克龙触发器。在本例中，我将克龙表达式设置为初始化参数而不是采用在Servlet中硬编码的方式。下面就是Servlet的代码:

public class QuartzServlet extends GenericServlet { public void init(ServletConfig config) throws ServletException { super.init(config); System.out.println("Scheduling Job .."); JobDetail jd = new JobDetail("Test Quartz","My Test Job",EJBInvokerJob.class); jd.getJobDataMap().put("ejb", "java:comp/env/ejb/TestEJB"); jd.getJobDataMap().put("method", "yourMethod"); Object[] jdArgs = new Object[0]; jd.getJobDataMap().put("args", jdArgs); CronTrigger cronTrigger = new CronTrigger("Test Quartz", "Test Quartz"); 　　 try { String cronExpr = null; // Get the cron Expression as an Init parameter cronExpr = getInitParameter("cronExpr"); System.out.println(cronExpr); cronTrigger.setCronExpression(cronExpr); Scheduler sched = StdSchedulerFactory.getDefaultScheduler(); sched.scheduleJob(jd, cronTrigger); System.out.println("Job scheduled now .."); } catch (Exception e) { e.printStackTrace(); } } public void service(ServletRequest arg0, ServletResponse arg1) throws ServletException, IOException { } public String getServletInfo() { return null; } }

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!