Quartz实现任务调度

蔚落 2021-09-15 00:56 448阅读 0赞

Quartz是java开源的一个定时任务的工具，它本身不仅可以实现固定时间的定时任务计算还可以实现类似Crontab的指定时间点间隔的定时任务计算。这篇文章以代码为主讲述了如何实现Quartz的任务调度。废话不多说，直接上代码~

一、pom.xml文件的配置

<dependency>
          <groupId>org.quartz-scheduler</groupId>
          <artifactId>quartz-jobs</artifactId>
          <version>2.3.0</version>
    	</dependency>
    	
    	<dependency>
          <groupId>org.quartz-scheduler</groupId>
          <artifactId>quartz</artifactId>
          <version>2.3.0</version>
    	</dependency>

二、MyJob.java代码

package com.xzw.quartz;
    
    import org.quartz.Job;
    import org.quartz.JobExecutionContext;
    import org.quartz.JobExecutionException;
    /**
     * 
     * @author xzw
     *
     */
    public class MyJob implements Job{
    
    	@Override
    	public void execute(JobExecutionContext arg0) throws JobExecutionException {
    		// 实现业务逻辑
    		System.out.println("Hello everyone, I am xzw.");
    		
    	}
    
    }

三、TestQuartz.java代码

package com.xzw.quartz;
    
    import java.text.ParseException;
    import java.util.Date;
    
    import org.quartz.JobBuilder;
    import org.quartz.JobDetail;
    import org.quartz.JobKey;
    import org.quartz.Scheduler;
    import org.quartz.SchedulerException;
    import org.quartz.SimpleScheduleBuilder;
    import org.quartz.Trigger;
    import org.quartz.TriggerBuilder;
    import org.quartz.impl.StdSchedulerFactory;
    import org.quartz.impl.triggers.CronTriggerImpl;
    
    /**
     * 
     * @author xzw
     *
     */
    public class TestQuartz {
    	public void testSimple(){
    		try {
    			Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
    			//开始
    			scheduler.start();
    			//唯一标识
    			JobKey jobKey = new JobKey("test_1", "test");
    			JobDetail jobDetail = JobBuilder.newJob(MyJob.class).withIdentity(jobKey).build();
    			Trigger trigger = TriggerBuilder.newTrigger().withIdentity("testTrigger","simpleTrigger")
    					//延迟一秒执行
    					.startAt(new Date(System.currentTimeMillis() + 1000))
    					//每隔一秒执行，并且一直重复
    					.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever())
    					.build();
    			scheduler.scheduleJob(jobDetail, trigger);
    			
    			try {
    				Thread.sleep(5000);
    			} catch (InterruptedException e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    			//删除job
    //			this.shutDown(scheduler, jobKey);
    		} catch (SchedulerException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		
    	}
    	
    	public void testCrontab(){
    		//通过schedule工厂类获得一个Schedule类
    		Scheduler scheduler = null;
    		try {
    			scheduler = StdSchedulerFactory.getDefaultScheduler();
    		} catch (SchedulerException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		//初始化一个JobDetail
    		JobKey jobKey = new JobKey("test_2","test");
    		JobDetail jobDetail = JobBuilder.newJob(MyJob.class).withIdentity(jobKey).build();
    		//初始化一个Crontab触发器，设置触发器名称和触发器所属的组名及优先级
    		CronTriggerImpl cronTrigger = new CronTriggerImpl();
    		try {
    			cronTrigger.setCronExpression("0/5 * * * * ?");
    		} catch (ParseException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		cronTrigger.setName("testCronTrigger");
    		cronTrigger.setGroup("cronTrigger");
    		cronTrigger.setPriority(8);
    		//交给调度器调度运行JobDetail和Trigger
    		try {
    			scheduler.scheduleJob(jobDetail, cronTrigger);
    			//启动调度器
    			scheduler.start();
    		} catch (SchedulerException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    //		this.shutDown(scheduler, jobKey);
    	}
    	
    	/**
    	 * 定义删除job的方法
    	 * @param scheduler
    	 * @param jobKey
    	 */
    	public void shutDown(Scheduler scheduler, JobKey jobKey){
    		try {
    			scheduler.deleteJob(jobKey);
    			scheduler.shutdown();
    		} catch (SchedulerException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    	
    	public static void main(String[] args) {
    		new TestQuartz().testSimple();
    		new TestQuartz().testCrontab();
    	}
    
    }

四、测试结果

![Image 1][]

至此，一个简单的任务调度就实现了，大家可以自己编辑自己的业务逻辑进行进一步的测试~

你们在此过程中还遇到了什么问题，欢迎留言，让我看看你们都遇到了哪些问题。

[Image 1]: