1.创建一个作业Job类,它必须继承org.quartz.Job接口,这个接口仅有一个方法extcute(),将需要执行的逻辑写在该方法中
package cn.com.quartz.jobs; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class HelloJobs implements Job{ @Override public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("---------------quartz--测试------------"); } }
2.创建一个调度器Quartz Scheduler
package cn.com.quartz.sheduler; import java.util.Date; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.Trigger; import org.quartz.TriggerUtils; import org.quartz.impl.StdSchedulerFactory; import cn.com.quartz.jobs.HelloJobs; public class HelloScheduler { public void scheduler(){ try { //创建一个调度器 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler() ; //Job的详细信息 JobDetail jobDetail = new JobDetail( Job 的名称,逻辑组名,和实现 org.quartz.Job 接口的全限类名称) JobDetail jobDetail = new JobDetail("TestJobs", Scheduler.DEFAULT_GROUP, HelloJobs.class) ; //触发一个job执行,makeSecondlyTrigger(),每多少秒执行一次 Trigger trigger = TriggerUtils.makeSecondlyTrigger(10) ; //trigger的时间 trigger.setStartTime(new Date()); //trigger的名字 trigger.setName("testJobsTrigger"); //通过scheduleJob,将每一个jobDetail注册到Scheduler中 scheduler.scheduleJob(jobDetail, trigger) ; //开始调度器的执行 scheduler.start(); } catch (SchedulerException e) { e.printStackTrace(); } } public static void main(String[] args) { HelloScheduler t = new HelloScheduler() ; t.scheduler(); } }