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。 每次触发作业时,将选择其中一个节点来运行作业。 还有一些初始设置工作要做,而且你需要一个数据库,但它非常易于管理: http : //www.quartz-scheduler.org/documentation/quartz-2.x/configuration/ConfigJDBCJobStoreClustering.html Yes. Simply enable Quartz in clustered mode on all three nodes. ...
  • 将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 is to ...
  • 您可以通过这种方式配置它而不使用属性文件; 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 without ...
  • 问题似乎是sqlite jdbc驱动程序不支持方法ResultSet.getBlob() 。 但是quartz使用此方法来检索分配给Job的JobDataMap 。 如果您仍然想使用带有sqlite的quartz,您可以扩展StdJDBCDelegate并检索/设置blobs,如本答案中所建议的那样 。 乍一看,您似乎只能覆盖这些方法 StdJDBCDelegate.getObjectFromBlob()和 StdJDBCDelegate.getJobDataFromBlob() 由于我不确定以后会出现更多 ...
  • 文档中的示例使用yaml格式,但是,当您使用纯属性格式时,不应将值包装在引号中。 所以在你的情况下,由于引号,它确实找不到类"org.quartz.simpl.SimpleThreadPool" 。 我建议使用主dropwizard配置(yaml)进行石英配置(如库doc建议)只是为了将所有配置保存在一个地方。 Example in documentation use yaml format, but, as you using pure properties format, you shouldn't w ...
  • 我同意NinjaNye。 您必须使用API提交作业,因为它需要在运行时绑定类的命名空间。 这个过程非常简单 : // construct job info JobDetail jobDetail = new JobDetail("myJob", null, typeof(HelloJob)); // fire every hour Trigger trigger = TriggerUtils.MakeHourlyTrigger(); // start on the next even hour trigge ...
  • 您正在JBoss上运行Quartz,因此请考虑使用HASingleton来控制主节点 - 然后您不需要使用Quartz提供的集群,Quartz使用数据库并导致问题。 HASingleton自JBoss 4或5开始提供。如果您使用的是版本7,那么您可以查看这篇文章 ,了解有关其实现的详细信息 I think I have found the solution! I disabled job file's auto scanning by doing this: org.quartz.plugin.jobIni ...
  • 我用过石英。 以下是石英的一些优点 如果你使用基于操作系统的cron,jvm会上下移动,任何状态都会丢失。 它是可移植的(可以在没有cron的Win OS上运行) 您可以在quartz中安排多个线程 我们在tomcat中运行调度程序,因此我们可以通过管理员网页管理和查看应用程序的状态。 在我们的应用程序中,我们使用jamon来监控我们的流程状态。 它可以回答诸如......目前正在运行哪些进程? 他们什么时候上次跑? 他们花了多长时间? 等cron不允许这样做。 您的代码将更加便携。 调度在不同的OS中以不 ...
  • 在使用XmlSerialization的应用程序中,当应用程序查找缓存的序列化程序集时,您可以在外部代码中获得第一次机会异常。 您可以在此问题中找到更多信息。 In applications that use XmlSerialization, you can get a first-chance exception in outside code when the application looks for a cached serialization assembly. You can find mor ...