Quartz定时调度

Bertha 。 2021-10-08 07:32 461阅读 0赞

<table> 
 <tbody> 
 <tr> 
 <td style="border-color:#dddddd;text-align:left;"> org.quartz.Scheduler&nbsp;类层次 <img alt="QuartzFigure4.2.JPG" height="185" src="http://www.blogjava.net/images/blogjava_net/unmi/26601/QuartzFigure%204.2.JPG" width="402"> 作为一个 Quartz 用户，你要与实现了&nbsp;org.quartz.Scheduler&nbsp;接口的类交互。在你调用它的任何 API 之前，你需要知道如何创建一个 Scheduler 的实例。取而代之的是用了某个工厂方法来确保了构造出 Sheduler 实例并正确的得到初始化，Quartz 框架为这一目的提供了&nbsp;org.quartz.SchedulerFactory&nbsp;接口。角色&nbsp;SchedulerFactory&nbsp;就是用来产生 Scheduler 实例的。当 Scheduler 实例被创建之后，就会存到一个仓库中(org.quartz.impl.SchedulerRepository)，这个仓库还提供了通过一个 class loader 查询实例的机制。要使用 Scheduler 实例，客户端必须从工厂（和随同的仓库中）使用不同方法调用来获取到它们。换句话说，要通过工厂创建一个 Scheduler 实例并获取到它需要经由两次方法调用。 &nbsp; 所有的 Scheduler 实例应该由 SchedulerFactory 来创建 <img alt="QuartzFigure4.3.JPG" height="178" src="http://www.blogjava.net/images/blogjava_net/unmi/26601/QuartzFigure4.3.JPG" width="391"> 使用&nbsp;DirectSchedulerFactory&nbsp;构造实例方法代码如下： &nbsp; DirectSchedulerFactory factory=DirectSchedulerFactory.getInstance();&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Initialize the Scheduler Factory with 10 threads&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; factory.createVolatileScheduler(10);&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Get a scheduler from the factory&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Scheduler scheduler = factory.getScheduler(); 方法 createVolatileScheduler() 方法不会返回 scheduler 的实例。createXXX() 方法是告诉工厂如何配置要创建的 Scheduler 实例。你必须调用方法 getScheduler() 获取到在工厂上执行方法 createXXX() 产生的实例。实际上，在调用 getScheduler() 方法之前，你必须调用其中一个 createXXX() 方法；否则，你将有收到一个 SchedulerException 错误，因为根本没有 Scheduler 实例存在。 方法 createVolatileScheduler() 带有单个参数：要创建的线程数量。 &nbsp; 使用 StdSchedulerFactory&nbsp;构造一个调度器实例，具体使用方法如下： &nbsp; StdSchedulerFactory factory = new StdSchedulerFactory();&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Create the properties to configure the factory&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Properties props = new Properties();&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // required to supply threadpool class and num of threads &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; props.put(StdSchedulerFactory.PROP_THREAD_POOL_CLASS,"org.quartz.simpl.SimpleThreadPool");&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; props.put("org.quartz.threadPool.threadCount", "10");&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Initialize the factory with properties&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; factory.initialize(props);&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Scheduler scheduler = factory.getScheduler(); &nbsp; 在这个例子中向工厂传递了两个属性，它们分别是实现了 org.quartz.spi.ThreadPool 接口的类名和 Scheduler 用来处理 Job 的线程的数量。这两个属性是必须的。但是我们也可以这样的得到实例 <h2 style="margin-left:0px;"> StdSchedulerFactory factory = new StdSchedulerFactory();&nbsp; Scheduler scheduler = factory.getScheduler();</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">因为StdSchedulerFactory工厂类会有个方法initialize()自动去加载一些属性配置，假如你使用无参的initialize() 方法，StdSchedulerFactory会取classpath下找到quartz.properties并加载。默认不配置属性时候会自动加载quartz.properties文件的配置。</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">使用静态的&nbsp;getDefaultScheduler()&nbsp;方法创建 Scheduler</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">使用 StdSchedulerFactory 来创建 Scheduler 实例的方式很普遍，因此在 StdSchedulerFactory 直接提供了一个方便的静态方法 getDefaultScheduler()，它就是使用前面列出的几个步骤来初始化工厂的。</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">在静态方法 getDefaultScheduler() 方法中调用了空的构造方法。假如之前未调用过任何一个 initialize() 方法，那么无参的 initialize() 方法会被调用。这会开始去按照前面说的顺序加载文件。默认情况下，quartz.properties 会被定位到，并从中加载属性。</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">Scheduler 的功能</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">Scheduler除了启动外，Scheduler操作包括查询、设置 Scheduler 为 standby 模式、继续、停止。启动Scheduler非常简单，只需要调用&nbsp;start()&nbsp;方法即可。只有在Scheduler 有实例或standby 模式才能调用start() 方法，一旦调用shutdown() 方法之后就不能在调用start() 方法。</h2> <h2 style="margin-left:0px;">&nbsp;</h2> <h2 style="margin-left:0px;">设置 Scheduler 为 standby 模式会导致 Scheduler 暂时停止查找 Job 去执行，public&nbsp;void&nbsp;standby()&nbsp;throws&nbsp;SchedulerException;&nbsp;standby 模式，Scheduler 不再试图去执行 Job，因为那些搜寻要执行的 Job 的线程被暂停了下来。停止则调用无参的&nbsp;shutdown()&nbsp;方法相当于调用&nbsp;shutdown(false).</h2> </td> 
 </tr> 
 </tbody> 
</table>