Quartz 入门示例程序

2019-04-23 00:16|来源: 网路

Quartz 是一个企业级调度工作的框架,帮助Java应用程序到调度工作/任务在指定的日期和时间运行。

本教程教作为一个入门介绍如何开发使用调度工作(在写本教程时使用的最新Quartz 2.2.1

1. 下载Quartz

可以从官方网站或Maven中央存储库下载Quartz库文件;

File : quartz.properties

org.quartz.scheduler.instanceName = MyScheduler
org.quartz.threadPool.threadCount = 3
org.quartz.jobStore.class =org.quartz.simpl.RAMJobStore

2. Quartz 作业

Quartz作业定义要运行什么?

File : HelloJob

package com656463.common;
 
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
 
public class HelloJob implements Job
{
	public void execute(JobExecutionContext context)
	throws JobExecutionException {
 
		System.out.println("Hello Quartz!");	
 
	}
}


3. Quartz触发器

定义Quartz触发器,当Quartz运行在上面的Quartz作业。

像老版本的Quartz,仍然有两种类型的触发器在Quartz2,但API有些变化:

    SimpleTrigger – 允许设置开始时间,结束时间,重复间隔。

    CronTrigger – 允许UNIX cron表达式来指定日期和时间来运行作业。


SimpleTrigger – 每5秒运行。

    Trigger trigger = TriggerBuilder
	.newTrigger()
	.withIdentity("dummyTriggerName", "group1")
	.withSchedule(
	    SimpleScheduleBuilder.simpleSchedule()
		.withIntervalInSeconds(5).repeatForever())
	.build();


CronTrigger – 每5秒运行。

    Trigger trigger = TriggerBuilder
	.newTrigger()
	.withIdentity("dummyTriggerName", "group1")
	.withSchedule(
		CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
	.build();


4. Scheduler

调度类链接“工作”和“触发器”到一起,并执行它。

Scheduler scheduler = new StdSchedulerFactory().getScheduler();
scheduler.start();
scheduler.scheduleJob(job, trigger);

5. 完整的例子

Quartz2 两个 SimpleTrigger 和 CronTrigger 完整的例子。

SimpleTrigger的例子 - 每间隔5秒运行。

package com656463.quartz;
 
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
 
public class SimpleTriggerExample {
	public static void main(String[] args) throws Exception {
 
		// Quartz 1.6.3
		// JobDetail job = new JobDetail();
		// job.setName("dummyJobName");
		// job.setJobClass(HelloJob.class);
 
		JobDetail job = JobBuilder.newJob(HelloJob.class)
			.withIdentity("dummyJobName", "group1").build();
 
                //Quartz 1.6.3
		// SimpleTrigger trigger = new SimpleTrigger();
		// trigger.setStartTime(new Date(System.currentTimeMillis() + 1000));
		// trigger.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
		// trigger.setRepeatInterval(30000);
 
		// Trigger the job to run on the next round minute
		Trigger trigger = TriggerBuilder
			.newTrigger()
			.withIdentity("dummyTriggerName", "group1")
			.withSchedule(
				SimpleScheduleBuilder.simpleSchedule()
					.withIntervalInSeconds(5).repeatForever())
			.build();
 
		// schedule it
		Scheduler scheduler = new StdSchedulerFactory().getScheduler();
		scheduler.start();
		scheduler.scheduleJob(job, trigger);
 
	}
}


CronTrigger例子 - 同样,在每5秒运行作业。

package com656463.quartz;
 
import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
 
public class CronTriggerExample 
{
    public static void main( String[] args ) throws Exception
    {
    	//Quartz 1.6.3
    	//JobDetail job = new JobDetail();
    	//job.setName("dummyJobName");
    	//job.setJobClass(HelloJob.class);    	
    	JobDetail job = JobBuilder.newJob(HelloJob.class)
		.withIdentity("dummyJobName", "group1").build();
 
	//Quartz 1.6.3
    	//CronTrigger trigger = new CronTrigger();
    	//trigger.setName("dummyTriggerName");
    	//trigger.setCronExpression("0/5 * * * * ?");
 
    	Trigger trigger = TriggerBuilder
		.newTrigger()
		.withIdentity("dummyTriggerName", "group1")
		.withSchedule(
			CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
		.build();
 
    	//schedule it
    	Scheduler scheduler = new StdSchedulerFactory().getScheduler();
    	scheduler.start();
    	scheduler.scheduleJob(job, trigger);
 
    }
}


相关问答

更多

Quartz + Struts(Quartz + Struts)

<bean name="archiveTask" class="com.yourcompany.ArchiveTriggerTask"> </bean> <bean id="archiveJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="archiveTask" ...

Quartz.net调度程序进入待机状态(Quartz.net scheduler going to standby)

将Quartz.net调度程序作为Windows服务运行似乎是最好的方法。 IIS的默认设置是在没有用户连接的情况下关闭任何ASP.net应用程序,这意味着您的调度程序不再运行。 可以更改这些默认值(请参阅是否可以阻止ASP.NET应用程序关闭? ),但更好的方法是将调度程序编写为Windows服务。 Running the Quartz.net scheduler as a windows service seems to be best method. The default for IIS ...

Quartz Scheduler创建没有quartz.properties的schedulerFactoryBean Beans(Quartz Scheduler create schedulerFactoryBean Beans without quartz.properties)

您可以通过这种方式配置它而不使用属性文件; Properties p = new Properties(); p.put("org.quartz.scheduler.instanceName", "Scheduler_test"); p.put("org.quartz.threadPool.threadCount", 2); ... StdSchedulerFactory factory = new StdSchedulerFactory(p); You can configure it wit ...

如何在java中使用quartz scheduler?(How to use quartz scheduler in java?)

看一下quartz API文档 。 编辑: 石英API文档的工作URL Take a look at quartz API documentation. Edit: Working URL for quartz API Documentation

Quartz.NET scheduler.Interrupt(jobKey)中断了所有活动的作业(Quartz.NET scheduler.Interrupt(jobKey) is interrupting all active jobs)

要回答这样的问题,只需查看相关方法的源代码就可以更容易(如果可能的话)。 如果你看中断的源代码,你会看到大约这样的: public virtual bool Interrupt(JobKey jobKey) { var currentlyExecutingJobs = this.CurrentlyExecutingJobs; bool interruptedAny = false; foreach (var executionContext in currentlyExecutingJ ...