1. package org.quartz;  
2.   
3.   public interface Job {  
4.   
5.     public void execute(JobExecutionContext context)  
6.       throws JobExecutionException;  
7.   }  

1. import org.quartz.Job;  
2. import org.quartz.JobExecutionContext;  
3. import org.quartz.JobExecutionException;  
4.   
5. import java.util.Date;  
6.   
7. public class HelloJob implements Job {  
8.   
9.     /** 
10.      * 需要一個(gè)無參的public構(gòu)造以便scheduler在它需要的時(shí)候可以實(shí)例化這個(gè)class. 
11.      */  
12.     public HelloJob() {  
13.     }  
14.   
15.   
16.     /** 
17.      * 要執(zhí)行的代碼 
18.      * 
19.      * @param context JobExecutionContext 
20.      * @throws JobExecutionException 
21.      */  
22.     public void execute(JobExecutionContext context) throws JobExecutionException {  
23.         System.out.println("Hello World! - " + new Date());  
24.     }  
25. }  

1. import org.quartz.DateBuilder;  
2. import org.quartz.JobBuilder;  
3. import org.quartz.JobDetail;  
4. import org.quartz.Scheduler;  
5. import org.quartz.SchedulerFactory;  
6. import org.quartz.Trigger;  
7. import org.quartz.TriggerBuilder;  
8. import org.quartz.impl.StdSchedulerFactory;  
9.   
10. import java.util.Date;  
11.   
12. public class SimpleExample {  
13.   
14.     public void run() throws Exception {  
15.   
16.         System.out.println("------- 初始化 ----------------------");  
17.   
18.         // 首先要實(shí)例化scheduler  
19.         SchedulerFactory schedulerFactory = new StdSchedulerFactory();  
20.         Scheduler scheduler = schedulerFactory.getScheduler();  
21.   
22.         System.out.println("------- 初始化完成 -----------");  
23.   
24.         // 獲取給定時(shí)間的下一個(gè)完整分鐘的時(shí)間，例如給定時(shí)間 08:13:54 則會(huì)反回 08:14:00  
25.         Date runTime = DateBuilder.evenMinuteDate(new Date());  
26.   
27.         System.out.println("------- Job安排 -------------------");  
28.   
29.         // 獲取job實(shí)例  
30.         JobDetail job = JobBuilder.newJob(HelloJob.class).withIdentity("job1", "group1").build();  
31.   
32.         // 在下一輪分鐘觸發(fā)運(yùn)行  
33.         Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1").startAt(runTime).build();  
34.   
35.         // 告訴quartz使用某個(gè)trigger執(zhí)行某個(gè)job  
36.         scheduler.scheduleJob(job, trigger);  
37.         System.out.println(job.getKey() + " 將會(huì)運(yùn)行于: " + runTime);  
38.   
39.         // 啟動(dòng)scheduler  
40.         scheduler.start();  
41.   
42.         System.out.println("------- 開始安排 -----------------");  
43.   
44.         System.out.println("------- 等待65秒 -------------");  
45.         Thread.sleep(65L * 1000L);  
46.   
47.         // 關(guān)閉scheduler  
48.         System.out.println("------- 關(guān)閉 ---------------------");  
49.         scheduler.shutdown(true);  
50.         System.out.println("------- 關(guān)閉完成 -----------------");  
51.     }  
52.   
53.     public static void main(String[] args) throws Exception {  
54.         SimpleExample example = new SimpleExample();  
55.         example.run();  
56.     }  
57. }  

1. JobDetail job = newJob(DumbJob.class)  
2.     .withIdentity("myJob", "group1") // name "myJob", group "group1"  
3.     .usingJobData("jobSays", "Hello World!")  
4.     .usingJobData("myFloatValue", 3.141f)  
5.     .build();  

1. public class DumbJob implements Job {  
2.   
3.     public DumbJob() {  
4.     }  
5.   
6.     public void execute(JobExecutionContext context)  
7.       throws JobExecutionException  
8.     {  
9.       JobKey key = context.getJobDetail().getKey();  
10.   
11.       JobDataMap dataMap = context.getJobDetail().getJobDataMap();  
12.   
13.       String jobSays = dataMap.getString("jobSays");  
14.       float myFloatValue = dataMap.getFloat("myFloatValue");  
15.   
16.       System.err.println("Instance " + key + " of DumbJob says: " + jobSays + ", and val is: " + myFloatValue);  
17.     }  
18.   }  

1. HolidayCalendar cal = new HolidayCalendar();  
2. cal.addExcludedDate( someDate );  
3. cal.addExcludedDate( someOtherDate );  
4.   
5. sched.addCalendar("myHolidays", cal, false,false);  
6.   
7.   
8. Trigger t = newTrigger()  
9.     .withIdentity("myTrigger")  
10.     .forJob("myJob")  
11.     .withSchedule(dailyAtHourAndMinute(9, 30)) // execute job daily at 9:30  
12.     .modifiedByCalendar("myHolidays") // but not on holidays  
13.     .build();  
14.   
15. // .. schedule job with trigger  
16.   
17. Trigger t2 = newTrigger()  
18.     .withIdentity("myTrigger2")  
19.     .forJob("myJob2")  
20.     .withSchedule(dailyAtHourAndMinute(11, 30)) // execute job daily at 11:30  
21.     .modifiedByCalendar("myHolidays") // but not on holidays  
22.     .build();  
23.   
24. // .. schedule job with trigger2  

CronTrigger

1. import static org.quartz.TriggerBuilder.*;  
2. import static org.quartz.CronScheduleBuilder.*;  
3. import static org.quartz.DateBuilder.*:  

1. trigger = new Trigger()  
2.                    .withIdentity("trigger3", "group1")  
3.                    .withSchedule(cronSchedule("0 42 10 ? * WED"))  
4.                    .inTimeZone(TimeZone.getTimeZone("America/Los_Angeles"))  
5.                    .forJob(myJobKey)  
6.               .build();  

1. trigger = newTrigger()  
2.     .withIdentity("trigger3", "group1")  
3.     .withSchedule(cronSchedule("0 0/2 8-17 * * ?")  
4.         ..withMisfireHandlingInstructionFireAndProceed())  
5.     .forJob("myJob", "group1")  
6.     .build();  

使用TriggerListener和JobListener

TriggerListener和JobListener

1. #============================================================================  
2. # Configure Main Scheduler Properties    
3. #============================================================================  
4.   
5. org.quartz.scheduler.instanceName: TestScheduler  
6. org.quartz.scheduler.instanceId: AUTO  
7.   
8. org.quartz.scheduler.skipUpdateCheck: true  
9.   
10. #============================================================================  
11. # Configure ThreadPool    
12. #============================================================================  
13.   
14. org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool  
15. org.quartz.threadPool.threadCount: 3  
16. org.quartz.threadPool.threadPriority: 5  
17.   
18. #============================================================================  
19. # Configure JobStore    
20. #============================================================================  
21.   
22. org.quartz.jobStore.misfireThreshold: 60000  
23.   
24. org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore  
25.   
26. #org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTX  
27. #org.quartz.jobStore.driverDelegateClass: org.quartz.impl.jdbcjobstore.PostgreSQLDelegate  
28. #org.quartz.jobStore.useProperties: false  
29. #org.quartz.jobStore.dataSource: myDS  
30. #org.quartz.jobStore.tablePrefix: QRTZ_  
31. #org.quartz.jobStore.isClustered: false  
32.   
33. #============================================================================  
34. # Configure Datasources    
35. #============================================================================  
36.   
37. #org.quartz.dataSource.myDS.driver: org.postgresql.Driver  
38. #org.quartz.dataSource.myDS.URL: jdbc:postgresql://localhost/dev  
39. #org.quartz.dataSource.myDS.user: jhouse  
40. #org.quartz.dataSource.myDS.password:   
41. #org.quartz.dataSource.myDS.maxConnections: 5  
42.   
43.   
44.   
45. #============================================================================  
46. # Configure Plugins   
47. #============================================================================  
48.   
49. org.quartz.plugin.triggHistory.class: org.quartz.plugins.history.LoggingJobHistoryPlugin  
50.   
51. org.quartz.plugin.jobInitializer.class: org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin  
52. org.quartz.plugin.jobInitializer.fileNames: quartz_data.xml  
53. org.quartz.plugin.jobInitializer.failOnFileNotFound: true  
54. org.quartz.plugin.jobInitializer.scanInterval: 120  
55. org.quartz.plugin.jobInitializer.wrapInUserTransaction: false