碼上快樂

相關內容    簡體    繁體

Spring Quartz 持久化解決方案

本文轉載自   查看原文   2014-01-06 11:46   6847    Java開發


Quartz是實現了序列化接口的，包括接口，所以可以使用標准方式序列化到數據庫。
而Spring2.5.6在集成Quartz時卻未能考慮持久化問題。


Spring對JobDetail進行了封裝，卻未實現序列化接口，所以持久化的時候會產生NotSerializable問題，這也是網上一直在那邊叫囂為什么不能持久化到數據庫問題，哥今天看了下Spring源碼，發現Spring對Quartz持久化的問題.
1. 不知道Spring未來會不會對持久化的支持，不過我們可以有如下解決方案，比如改寫
Spring的代碼，實現序列化接口.
2. 不使用Spring的Fatory,自己實現任務的初始化.

既然Spring不支持持久化，那么持久化任務還是自己編寫實現吧，否則每次都需要打包發布，麻煩，自己編寫的類與Quartz完全兼容.

注意:為什么Spring不支持外配置任務，可能也是考慮到這方面問題所以才不提供這些任務的執行化支持.[配置文件配置與數據庫配置重復]

直接使用Quartz是支持序列化功能，比如直接使用頁面配置Quartz界面，設置任務執行時間等屬性。

通過配置實現的是不應該初始化到數據庫，否則直接在數據庫中配置了。不過也是可以配置的，通過改寫JobDetailBean.代碼如下:

Java代碼   收藏代碼
  1. package org.frame.auth.service;  
  2.   
  3. import java.util.Map;  
  4.   
  5. import org.quartz.Job;  
  6. import org.quartz.JobDetail;  
  7. import org.quartz.Scheduler;  
  8. import org.springframework.beans.factory.BeanNameAware;  
  9. import org.springframework.beans.factory.InitializingBean;  
  10. import org.springframework.scheduling.quartz.DelegatingJob;  
  11. import org.springframework.scheduling.quartz.SchedulerFactoryBean;  
  12.   
  13. public class PersistentJobDetailBean extends JobDetail  
  14. implements BeanNameAware, InitializingBean {  
  15.   
  16.     private static final long serialVersionUID = -4389885435844732405L;  
  17.   
  18.     private Class actualJobClass;  
  19.   
  20.     private String beanName;  
  21.   
  22.     /** 
  23.      * Overridden to support any job class, to allow a custom JobFactory 
  24.      * to adapt the given job class to the Quartz Job interface. 
  25.      * @see SchedulerFactoryBean#setJobFactory 
  26.      */  
  27.     public void setJobClass(Class jobClass) {  
  28.         if (jobClass != null && !Job.class.isAssignableFrom(jobClass)) {  
  29.             super.setJobClass(DelegatingJob.class);  
  30.             this.actualJobClass = jobClass;  
  31.         }  
  32.         else {  
  33.             super.setJobClass(jobClass);  
  34.         }  
  35.     }  
  36.   
  37.     /** 
  38.      * Overridden to support any job class, to allow a custom JobFactory 
  39.      * to adapt the given job class to the Quartz Job interface. 
  40.      */  
  41.     public Class getJobClass() {  
  42.         return (this.actualJobClass != null ? this.actualJobClass : super.getJobClass());  
  43.     }  
  44.   
  45.     /** 
  46.      * Register objects in the JobDataMap via a given Map. 
  47.      * <p>These objects will be available to this Job only, 
  48.      * in contrast to objects in the SchedulerContext. 
  49.      * <p>Note: When using persistent Jobs whose JobDetail will be kept in the 
  50.      * database, do not put Spring-managed beans or an ApplicationContext 
  51.      * reference into the JobDataMap but rather into the SchedulerContext. 
  52.      * @param jobDataAsMap Map with String keys and any objects as values 
  53.      * (for example Spring-managed beans) 
  54.      * @see SchedulerFactoryBean#setSchedulerContextAsMap 
  55.      */  
  56.     public void setJobDataAsMap(Map jobDataAsMap) {  
  57.         getJobDataMap().putAll(jobDataAsMap);  
  58.     }  
  59.   
  60.     /** 
  61.      * Set a list of JobListener names for this job, referring to 
  62.      * non-global JobListeners registered with the Scheduler. 
  63.      * <p>A JobListener name always refers to the name returned 
  64.      * by the JobListener implementation. 
  65.      * @see SchedulerFactoryBean#setJobListeners 
  66.      * @see org.quartz.JobListener#getName 
  67.      */  
  68.     public void setJobListenerNames(String[] names) {  
  69.         for (int i = 0; i < names.length; i++) {  
  70.             addJobListener(names[i]);  
  71.         }  
  72.     }  
  73.   
  74.     public void setBeanName(String beanName) {  
  75.         this.beanName = beanName;  
  76.     }  
  77.   
  78.   
  79.   
  80.     public void afterPropertiesSet() {  
  81.         if (getName() == null) {  
  82.             setName(this.beanName);  
  83.         }  
  84.         if (getGroup() == null) {  
  85.             setGroup(Scheduler.DEFAULT_GROUP);  
  86.         }  
  87.     }  
  88.   
  89.   
  90. }  


這里把Spring的ApplicationContext去掉了，因為這個屬性沒有實現序列化接口。其他配置與原告一致:

Java代碼   收藏代碼
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" " http://www.springframework.org/dtd/spring-beans.dtd ">  
  3. <beans default-autowire="byName">  
  4.   
  5.   
  6.    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource" destroy-method="close">  
  7.         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>  
  8.   
  9.         <property name="url" >  
  10.             <value><![CDATA[jdbc:mysql://localhost:3306/txl?connectTimeout=1000&useUnicode=true&characterEncoding=utf-8]]></value>  
  11.         </property>  
  12.         <property name="username" value="root"/>  
  13.         <property name="password" value=""/>  
  14.     </bean>  
  15.   
  16.     <bean id="jobDetail" class = "org.frame.auth.service.PersistentJobDetailBean">  
  17.             <property name="jobClass" value="org.frame.auth.service.PersistentJob"></property>  
  18.     </bean>  
  19.   
  20. <!-- <bean id="trigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean" >-->  
  21. <!--         <property name="jobDetail" ref="jobDetail"></property>-->  
  22. <!--         <property name="startDelay" value="1000"></property>-->  
  23. <!--         <property name="repeatInterval" value="3000"></property>-->  
  24. <!--         <property name="jobDataAsMap">-->  
  25. <!--             <map>-->  
  26. <!--                 <entry key="message" value="this is trigger"></entry>-->  
  27. <!--             </map>-->  
  28. <!--         </property>-->  
  29. <!-- </bean>-->  
  30.   
  31.     <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean" >  
  32.          <property name="jobDetail" ref="jobDetail"/>  
  33.          <property name="cronExpression">  
  34.              <value>0/10 * * * * ?</value>  
  35.          </property>  
  36.     </bean>  
  37.   
  38.     <bean id="schedulerFactory" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  
  39.             <property name="dataSource" ref="dataSource"></property>  
  40.             <property name="applicationContextSchedulerContextKey"  value="applicationContextKey" />  
  41.             <property name="configLocation" value="classpath:quartz.properties"/>  
  42.     </bean>  
  43.   
  44. </beans>  



org.frame.auth.service.PersistentJob這個類很簡單，如下:

Java代碼   收藏代碼
  1. package org.frame.auth.service;  
  2.   
  3. import org.quartz.Job;  
  4. import org.quartz.JobExecutionContext;  
  5. import org.quartz.JobExecutionException;  
  6.   
  7. public class PersistentJob implements Job  {  
  8.   
  9.   
  10.     @Override  
  11.     public void execute(JobExecutionContext context) throws JobExecutionException {  
  12.         System.out.println("spring quartz!");  
  13.     }  
  14.   
  15. }  



有人可能會說，你這種任務調度持久化就沒有意義了，是的，一般持久化到數據庫的代碼如下:

Java代碼   收藏代碼
  1. package org.frame.auth.service;  
  2.   
  3. import java.util.Map;  
  4.   
  5. import org.quartz.JobExecutionContext;  
  6. import org.quartz.JobExecutionException;  
  7. import org.quartz.StatefulJob;  
  8.   
  9. public class PersistentJob implements StatefulJob  {  
  10.   
  11.   
  12.     @Override  
  13.     public void execute(JobExecutionContext context) throws JobExecutionException {  
  14.         // TODO Auto-generated method stub  
  15.         Map map = context.getJobDetail().getJobDataMap();  
  16.         System.out.println("["+context.getJobDetail().getName()+"]"+map.get("message"));  
  17.         map.put("message", "updated Message");  
  18.     }  
  19.   
  20. }  


這樣的話，信息message就會持久化到數據庫中了.可以建立系統的連鎖調度，這根據你的業務需求了.

在Spring中配置的任務通過我這種修改是可以運行，不過每次運行都需要把原先的任務刪除，否則會提示任務已經存在，Quartz的優勢是就算服務器停止，下次重啟能夠恢復原先的任務並繼續執行.


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 Ionic國際化解決方案 網頁靜態化解決方案Freemarker Sql 優化解決方案 系統數據查詢耗時優化解決方案 企業級虛擬化解決方案——proxmox 三維組態可視化解決方案 華為虛擬化解決方案---Fusionsphere、FusionCompute 簡述組件化解決方案CTMediator與MGJRouter的主要思想 針對LocalDateTime日期格式化解決方案
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM