Quartz Job Scheduling Framework［翻译］第十三章. Quartz 和 Web 应用 (第三部分)

 1public void init(ServletConfig cfg) throws ServletException {
 2 super.init(cfg);
 3
 4 log("Quartz Initializer Servlet loaded, initializing Scheduler...");
 5
 6 StdSchedulerFactory factory;
 7 try {
 8
 9   String configFile = cfg.getInitParameter("config-file");
10   String shutdownPref = cfg.getInitParameter("shutdown-on-unload");
11
12   if (shutdownPref != null)
13
14     performShutdown = Boolean.valueOf(shutdownPref).booleanValue();
15
16   // get Properties
17   if (configFile != null) {
18     factory = new StdSchedulerFactory(configFile);
19   } else {
20     factory = new StdSchedulerFactory();
21   }
22
23   // Should the Scheduler being started now or later
24   String startOnLoad =
25     cfg.getInitParameter("start-scheduler-on-load");
26
27   /*
28    * If the "start-scheduler-on-load" init-parameter is not specified,
29    * the
30    * scheduler will be started. This is to maintain backwards
31    * compatability.
32    */
33
34    if (startOnLoad == null ||
35     (Boolean.valueOf(startOnLoad).booleanValue())) {
36     // Start now
37     scheduler = factory.getScheduler();
38     scheduler.start();
39     log("Scheduler has been started...");
40   } else {
41     log("Scheduler has not been started. Use scheduler.start()");
42   }
43
44   log(
45    "Storing the Quartz Scheduler Factory in the servlet context at key: " +
46 QUARTZ_FACTORY_KEY);
47   cfg.getServletContext().setAttribute(QUARTZ_FACTORY_KEY, factory);
48
49 } catch (Exception e) {
50   log("Quartz Scheduler failed to initialize: " +
51e.toString());
52   throw new ServletException(e);
53 }
54}

 1<web-app>
 2<servlet>
 3 <servlet-name>QuartzInitializer</servlet-name>
 4 <display-name>Quartz Initializer Servlet</display-name>
 5
 6 <servlet-class>
 7   org.quartz.ee.servlet.QuartzInitializerServlet
 8 </servlet-class>
 9
10 <load-on-startup>1</load-on-startup>
11
12 <init-param>
13   <param-name>config-file</param-name>
14   <param-value>/some/path/my_quartz.properties</param-value>
15 </init-param>
16
17 <init-param>
18   <param-name>shutdown-on-unload</param-name>
19   <param-value>true</param-value>
20 </init-param>
21
22 <init-param>
23   <param-name>start-scheduler-on-load</param-name>
24   <param-value>true</param-value>
25 </init-param>
26
27</servlet>
28
29<! other web.xml items here >
30
31</web-app>

1<init-param>
2 <param-name>config-file</param-name>
3  <param-value>/my_quartz.properties</param-value>
4</init-param>

 1import javax.servlet.ServletContext;
 2import javax.servlet.http.HttpServletRequest;
 3import javax.servlet.http.HttpServletResponse;
 4
 5import org.apache.struts.action.Action;
 6import org.apache.struts.action.ActionForm;
 7import org.apache.struts.action.ActionForward;
 8import org.apache.struts.action.ActionMapping;
 9import org.cavaness.jobconsole.web.QuartzFactoryServlet;
10import org.cavaness.jobconsole.web.WebConstants;
11import org.quartz.Scheduler;
12import org.quartz.impl.StdSchedulerFactory;
13
14public class StartSchedulerAction extends Action {
15    public ActionForward execute(ActionMapping mapping,
16    ActionForm form, HttpServletRequest request,
17    HttpServletResponse response) throws Exception {
18
19         // Retrieve the ServletContext
20         ServletContext ctx =
21              request.getSession().getServletContext();
22
23         // Retrieve the factory from the ServletContext
24         StdSchedulerFactory factory =
25               (StdSchedulerFactory)
26              ctx.getAttribute(
27                 QuartzFactoryServlet.QUARTZ_FACTORY_KEY);
28
29         // Retrieve the scheduler from the factory
30         Scheduler scheduler = factory.getScheduler();
31
32         // Start the scheduler
33         scheduler.start();
34
35         // Forward to success page
36         return mapping.findForward(WebConstants.SUCCESS);
37    }
38}

 1import javax.servlet.ServletContext;
 2import javax.servlet.http.HttpServletRequest;
 3
 4import org.quartz.Scheduler;
 5import org.quartz.SchedulerException;
 6import org.quartz.impl.StdSchedulerFactory;
 7
 8public class ActionUtil {
 9
10    public static Scheduler getScheduler(HttpServletRequest request)
11         throws SchedulerException {
12
13         ServletContext ctx =
14              request.getSession().getServletContext();
15
16         StdSchedulerFactory factory =
17               (StdSchedulerFactory) ctx.getAttribute(
18               QuartzFactoryServlet.QUARTZ_FACTORY_KEY);
19
20         return factory.getScheduler();
21    }
22}

 1public class StartSchedulerAction extends Action {
 2    public ActionForward execute(ActionMapping mapping,
 3    ActionForm form, HttpServletRequest request,
 4    HttpServletResponse response) throws Exception {
 5
 6         // Retrieve the scheduler from the factory
 7         Scheduler scheduler = ActionUtil.getScheduler();
 8
 9         // Start the scheduler
10         scheduler.start();
11
12         // Forward to success page
13         return mapping.findForward(WebConstants.SUCCESS);
14
15    }
16}