1. package com.sundoctor.quartz.service;   
2.   
3. import java.util.Date;   
4.   
5. import org.quartz.CronExpression;   
6.   
7. public interface SchedulerService {   
8.       
9.     void schedule(String cronExpression);   
10.        
11.       
12.     void schedule(String name,String cronExpression);   
13.        
14.       
15.     void schedule(CronExpression cronExpression);   
16.        
17.       
18.     void schedule(String name,CronExpression cronExpression);   
19.        
20.       
21.     void schedule(Date startTime);     
22.        
23.       
24.     void schedule(String name,Date startTime);   
25.        
26.       
27.     void schedule(Date startTime,Date endTime);    
28.        
29.       
30.     void schedule(String name,Date startTime,Date endTime);   
31.        
32.       
33.     void schedule(Date startTime,Date endTime,int repeatCount);    
34.        
35.       
36.     void schedule(String name,Date startTime,Date endTime,int repeatCount);   
37.        
38.       
39.     void schedule(Date startTime,Date endTime,int repeatCount,long repeatInterval) ;   
40.        
41.       
42.     void schedule(String name,Date startTime,Date endTime,int repeatCount,long repeatInterval);   
43. }  

1. package com.sundoctor.quartz.service;   
2.   
3. import java.text.ParseException;   
4. import java.util.Date;   
5. import java.util.UUID;   
6.   
7. import org.quartz.CronExpression;   
8. import org.quartz.CronTrigger;   
9. import org.quartz.JobDetail;   
10. import org.quartz.Scheduler;   
11. import org.quartz.SchedulerException;   
12. import org.quartz.SimpleTrigger;   
13. import org.springframework.beans.factory.annotation.Autowired;   
14. import org.springframework.beans.factory.annotation.Qualifier;   
15. import org.springframework.stereotype.Service;   
16.   
17. @Service("schedulerService")   
18. public class SchedulerServiceImpl implements SchedulerService {   
19.   
20.     private Scheduler scheduler;   
21.     private JobDetail jobDetail;   
22.   
23.     @Autowired  
24.     public void setJobDetail(@Qualifier("jobDetail") JobDetail jobDetail) {   
25.         this.jobDetail = jobDetail;   
26.     }   
27.   
28.     @Autowired  
29.     public void setScheduler(@Qualifier("quartzScheduler") Scheduler scheduler) {   
30.         this.scheduler = scheduler;   
31.     }   
32.   
33.     @Override  
34.     public void schedule(String cronExpression) {   
35.         schedule(null, cronExpression);   
36.     }   
37.   
38.     @Override  
39.     public void schedule(String name, String cronExpression) {   
40.         try {   
41.             schedule(name, new Cronexpression_r(cronExpression));   
42.         } catch (ParseException e) {   
43.             throw new RuntimeException(e);   
44.         }   
45.     }   
46.   
47.     @Override  
48.     public void schedule(CronExpression cronExpression) {   
49.         schedule(null, cronExpression);   
50.     }   
51.   
52.     @Override  
53.     public void schedule(String name, CronExpression cronExpression) {   
54.         if (name == null || name.trim().equals("")) {   
55.             name = UUID.randomUUID().toString();   
56.         }   
57.   
58.         try {   
59.             scheduler.addJob(jobDetail, true);   
60.   
61.             CronTrigger cronTrigger = new CronTrigger(name, Scheduler.DEFAULT_GROUP, jobDetail.getName(),   
62.                     Scheduler.DEFAULT_GROUP);   
63.             cronTrigger.setCronexpression_r(cronExpression);   
64.             scheduler.scheduleJob(cronTrigger);   
65.             scheduler.rescheduleJob(name, Scheduler.DEFAULT_GROUP, cronTrigger);   
66.         } catch (SchedulerException e) {   
67.             throw new RuntimeException(e);   
68.         }   
69.     }   
70.   
71.     @Override  
72.     public void schedule(Date startTime) {   
73.         schedule(startTime, null);   
74.     }   
75.   
76.     @Override  
77.     public void schedule(String name, Date startTime) {   
78.         schedule(name, startTime, null);   
79.     }   
80.   
81.     @Override  
82.     public void schedule(Date startTime, Date endTime) {   
83.         schedule(startTime, endTime, 0);   
84.     }   
85.   
86.     @Override  
87.     public void schedule(String name, Date startTime, Date endTime) {   
88.         schedule(name, startTime, endTime, 0);   
89.     }   
90.   
91.     @Override  
92.     public void schedule(Date startTime, Date endTime, int repeatCount) {   
93.         schedule(null, startTime, endTime, 0);   
94.     }   
95.   
96.     @Override  
97.     public void schedule(String name, Date startTime, Date endTime, int repeatCount) {   
98.         schedule(name, startTime, endTime, 0, 0L);   
99.     }   
100.   
101.     @Override  
102.     public void schedule(Date startTime, Date endTime, int repeatCount, long repeatInterval) {   
103.         schedule(null, startTime, endTime, repeatCount, repeatInterval);   
104.     }   
105.   
106.     @Override  
107.     public void schedule(String name, Date startTime, Date endTime, int repeatCount, long repeatInterval) {   
108.         if (name == null || name.trim().equals("")) {   
109.             name = UUID.randomUUID().toString();   
110.         }   
111.   
112.         try {   
113.             scheduler.addJob(jobDetail, true);   
114.   
115.             SimpleTrigger SimpleTrigger = new SimpleTrigger(name, Scheduler.DEFAULT_GROUP, jobDetail.getName(),   
116.                     Scheduler.DEFAULT_GROUP, startTime, endTime, repeatCount, repeatInterval);   
117.             scheduler.scheduleJob(SimpleTrigger);   
118.             scheduler.rescheduleJob(name, Scheduler.DEFAULT_GROUP, SimpleTrigger);   
119.   
120.         } catch (SchedulerException e) {   
121.             throw new RuntimeException(e);   
122.         }   
123.     }   
124. }  

1. package com.sundoctor.example.service;   
2.   
3. import org.quartz.JobExecutionContext;   
4. import org.quartz.JobExecutionException;   
5. import org.quartz.Trigger;   
6. import org.springframework.scheduling.quartz.QuartzJobBean;   
7.   
8. public class MyQuartzJobBean extends QuartzJobBean {   
9.   
10.     private SimpleService simpleService;   
11.        
12.     public void setSimpleService(SimpleService simpleService) {   
13.         this.simpleService = simpleService;   
14.     }   
15.   
16.     @Override  
17.     protected void executeInternal(JobExecutionContext jobexecutioncontext) throws JobExecutionException {   
18.         Trigger trigger = jobexecutioncontext.getTrigger();   
19.         String triggerName = trigger.getName();        
20.         simpleService.testMethod(triggerName);   
21.     }   
22.   
23. }  

1. package com.sundoctor.example.service;   
2.   
3. import java.io.Serializable;   
4.   
5. import org.slf4j.Logger;   
6. import org.slf4j.LoggerFactory;   
7. import org.springframework.stereotype.Service;   
8.   
9. @Service("simpleService")   
10. public class SimpleService implements Serializable{   
11.        
12.     private static final long serialVersionUID = 122323233244334343L;   
13.     private static final Logger logger = LoggerFactory.getLogger(SimpleService.class);   
14.        
15.     public void testMethod(String triggerName){   
16.         //這里執(zhí)行定時(shí)調(diào)度業(yè)務(wù)   
17.         logger.info(triggerName);   
18.     }   
19.        
20.     public void testMethod2(){   
21.         logger.info("testMethod2");   
22.     }   
23. }  

1. package com.sundoctor.example.test;   
2.   
3. import java.text.ParseException;   
4. import java.text.SimpleDateFormat;   
5. import java.util.Date;   
6.   
7. import org.springframework.context.ApplicationContext;   
8. import org.springframework.context.support.ClassPathXmlApplicationContext;   
9.   
10. import com.sundoctor.quartz.service.SchedulerService;   
11.   
12. public class MainTest {   
13.   
14.       
15.     public static void main(String[] args) {   
16.         ApplicationContext springContext = new ClassPathXmlApplicationContext(new String[]{"classpath:applicationContext.xml","classpath:applicationContext-quartz.xml"});   
17.         SchedulerService schedulerService = (SchedulerService)springContext.getBean("schedulerService");   
18.            
19.         //執(zhí)行業(yè)務(wù)邏輯...   
20.            
21.         //設(shè)置調(diào)度任務(wù)   
22.         //每10秒中執(zhí)行調(diào)試一次   
23.         schedulerService.schedule("0/10 * * ? * * *");    
24.            
25.         Date startTime = parse("2009-06-01 22:16:00");   
26.         Date endTime =  parse("2009-06-01 22:20:00");   
27.            
28.         //2009-06-01 21:50:00開始執(zhí)行調(diào)度   
29.         schedulerService.schedule(startTime);   
30.   
31.         //2009-06-01 21:50:00開始執(zhí)行調(diào)度，2009-06-01 21:55:00結(jié)束執(zhí)行調(diào)試   
32.         //schedulerService.schedule(startTime,endTime);   
33.            
34.         //2009-06-01 21:50:00開始執(zhí)行調(diào)度，執(zhí)行5次結(jié)束   
35.         //schedulerService.schedule(startTime,null,5);   
36.   
37.         //2009-06-01 21:50:00開始執(zhí)行調(diào)度，每隔20秒執(zhí)行一次，執(zhí)行5次結(jié)束   
38.         //schedulerService.schedule(startTime,null,5,20);   
39.            
40.         //等等，查看com.sundoctor.quartz.service.SchedulerService           
41.     }   
42.        
43.     private static Date parse(String dateStr){   
44.         SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");   
45.         try {   
46.             return format.parse(dateStr);   
47.         } catch (ParseException e) {   
48.             throw new RuntimeException(e);   
49.         }   
50.     }   
51.   
52. }  

其實(shí)很多時(shí)候只需要一個(gè)JobDetail就可以了，也可以達(dá)到多個(gè)JobDetail一樣的效果，一個(gè)JobDetail的時(shí)候可以在Trigger名稱上做擴(kuò)展，可以在調(diào)度任務(wù)時(shí)給Trigger名稱加上不同的前綴或后綴，比如Trigger名稱增加一個(gè)前綴參數(shù)， 

然后在QuartzJobBean中的executeInternal方法取到Trigger名秒，然后根據(jù)其前綴或后綴調(diào)用不同的業(yè)務(wù)邏輯 

在 simpleService里面注入一個(gè)繼承HibernateDaoSupport的類，這個(gè)繼承HibernateDaoSupport的類也必須實(shí) 現(xiàn)序列化接口，simpleService類被序列化保存到數(shù)據(jù)庫(kù)表 qrtz_job_details的job_class_name字段中，quartz在運(yùn)行時(shí)會(huì)讀取qrtz_job_details表中的 job_class_name將其反序列化。這也是為什么simpleService和其中注入各屬性需要實(shí)現(xiàn)Serializable序列化接口的原 因，所以你每次修改simpleService類或者其中的繼承HibernateDaoSupport的類都要?jiǎng)h除 qrtz_job_details表對(duì)應(yīng)的job記錄，否則可能會(huì)出現(xiàn)空指針異常，因?yàn)槟闳绻銢]有刪除qrtz_job_details表中的記錄，你 修改的東東并不會(huì)自動(dòng)更新到qrtz_job_details中，你用的還是原來舊版本的simpleService類。 

在 simpleService里面注入一個(gè)繼承HibernateDaoSupport的類，這個(gè)繼承HibernateDaoSupport的類也必須實(shí) 現(xiàn)序列化接口，simpleService類被序列化保存到數(shù)據(jù)庫(kù)表 qrtz_job_details的job_class_name字段中，quartz在運(yùn)行時(shí)會(huì)讀取qrtz_job_details表中的 job_class_name將其反序列化。這也是為什么simpleService和其中注入各屬性需要實(shí)現(xiàn)Serializable序列化接口的原 因，所以你每次修改simpleService類或者其中的繼承HibernateDaoSupport的類都要?jiǎng)h除 qrtz_job_details表對(duì)應(yīng)的job記錄，否則可能會(huì)出現(xiàn)空指針異常，因?yàn)槟闳绻銢]有刪除qrtz_job_details表中的記錄，你 修改的東東并不會(huì)自動(dòng)更新到qrtz_job_details中，你用的還是原來舊版本的simpleService類。 

你的這個(gè)問題在我另一篇文章《Quartz任務(wù)監(jiān)控管理》有人提到過，你也可以到http://www./topic/441951?page=1看看。 

要 做的并不是簡(jiǎn)單的從數(shù)據(jù)庫(kù)讀取cronExpression，而是能夠通過前端（比如Web頁(yè)面）的修改并且不需要重啟服務(wù)的情況下就可以動(dòng)態(tài)修改配置任 務(wù)調(diào)度時(shí)間，并且對(duì)于quartx的數(shù)據(jù)持久化是透明的，只需在數(shù)據(jù)庫(kù)增加12張表，修改一下quartx.properties文件的配置，其它并不需 要你做些什么額外的斯工作。 

JdbcPlaceholderConfigurer繼承自PropertyPlaceholderConfigurer 
， 將原來配置在一個(gè)properties文件中的內(nèi)容轉(zhuǎn)移到數(shù)據(jù)庫(kù)而己。JdbcPlaceholderConfigurer只是應(yīng)用啟動(dòng)時(shí)簡(jiǎn)單的將 cronExpression從數(shù)據(jù)庫(kù)讀取出來，每次修改完數(shù)據(jù)庫(kù)后就都需要重啟服務(wù)，新的修改才會(huì)生效。其實(shí) JdbcPlaceholderConfigurer還是一種靜態(tài)配置，只是將原來寫在 

中的cronExpression寫到另外一個(gè)地方：數(shù)據(jù)庫(kù)。 

simpleService 和其中注入各屬性需要實(shí)現(xiàn)Serializable序列化接口,你的BakcupDao繼承自HibernateDaoSupport雖然也實(shí)現(xiàn)了序列化 接口，但是HibernateDaoSupport里的HibernateTemplate并沒有實(shí)現(xiàn)序列化接口，所以你取得的 HibernateTemplate永遠(yuǎn)為null。因此獲取HibernateTemplate必須換一種方式，你的BakcupDao不能繼承自 HibernateDaoSupport。HibernateTemplate沒有實(shí)現(xiàn)序列化接口，而SessionFactory是實(shí)現(xiàn)序列化接口的， 在bakcupDao注入SessionFactory，通過SessionFactory獲取HibernateTemplate。 

你的bakcupDao可以這樣寫