码迷，mamicode.com
首页 > 其他好文 > 详细

Quartz集群配置

时间：2015-01-13 01:17:49      阅读：210      评论：0      收藏：0      [点我收藏+]

标签：

Quartz集群配置（100%成功）

先看看quartz的持久化基本介绍： 
引用

1 大家都清楚quartz最基本的概念就是job，在job内调用具体service完成具体功能，quartz需要把每个job存储起来，方便调度，quartz存储job方式就分三种，我们最常用的也是quartz默认的是RAMJobStore，RAMJobStore顾名思义就是把job的相关信息存储在内存里，如果用spring配置quartz的job信息的话，所有信息是配置在xml里，当spirng context启动的时候就把xml里的job信息装入内存。这一性质就决定了一旦JVM挂掉或者容器挂掉，内存中的job信息就随之消失，无法持久化。另外两种方式是JobStoreTX和JobStoreCMT，暂时不讨论这两者的区别，使用这两种JobStore，quartz就会通过jdbc直连或者应用服务器jndi连接数据库，读取配置在数据库里的job初始化信息，并且把job通过java序列化到数据库里，这样就使得每个job信息得到了持久化，即使在jvm或者容器挂掉的情况下，也能通过数据库感知到其他job的状态和信息。 
    2 quartz集群各节点之间是通过同一个数据库实例(准确的说是同一个数据库实例的同一套表)来感知彼此的。 


由上可见，我们需要创建quartz要用的数据库表，此sql文件在：quartz-1.8.6\docs\dbTables。此文件夹下有各个数据库的sql文件，mysql选择tables_mysql.sql。创建相应表。 

接下来新建quartz.properties来覆盖jar包中的此文件，新的properties文件放在src的根目录下即可。下面是文件内容： 
Java代码  技术分享
  1. #==============================================================    
  2. #Configure Main Scheduler Properties    
  3. #==============================================================     
  4. org.quartz.scheduler.instanceName = quartzScheduler  
  5. org.quartz.scheduler.instanceId = AUTO  
  6.   
  7. #==============================================================    
  8. #Configure JobStore    
  9. #==============================================================   
  10. org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX  
  11. org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate  
  12. org.quartz.jobStore.tablePrefix = QRTZ_  
  13. org.quartz.jobStore.isClustered = true  
  14. org.quartz.jobStore.clusterCheckinInterval = 20000    
  15. org.quartz.jobStore.dataSource = myDS  
  16.    
  17. #==============================================================    
  18. #Configure DataSource    
  19. #==============================================================   
  20. org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver  
  21. org.quartz.dataSource.myDS.URL = jdbc:mysql://192.168.20.195:3306/database?useUnicode=true&characterEncoding=UTF-8  
  22. org.quartz.dataSource.myDS.user = root  
  23. org.quartz.dataSource.myDS.password = 123456  
  24. org.quartz.dataSource.myDS.maxConnections = 30  
  25.   
  26. #==============================================================    
  27. #Configure ThreadPool    
  28. #==============================================================   
  29. org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool  
  30. org.quartz.threadPool.threadCount = 10  
  31. org.quartz.threadPool.threadPriority = 5  
  32. org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true  


可以看到除了数据源、线程池等配置外，我们指定了一个scheduler实例，实例ID为自动分配。 
Java代码  技术分享
  1. #==============================================================    
  2. #Configure Main Scheduler Properties    
  3. #==============================================================     
  4. org.quartz.scheduler.instanceName = quartzScheduler  
  5. org.quartz.scheduler.instanceId = AUTO  


此外，指定了集群相应配置，检查间隔为20s： 
Java代码  技术分享
  1. org.quartz.jobStore.isClustered = true  
  2. org.quartz.jobStore.clusterCheckinInterval = 20000    


最后配置applicant-context.xml文件。这里特别要注意一点： 
引用
MethodInvokingJobDetailFactoryBean 类中的 methodInvoking 方法，是不支持序列化的，因此在把 QUARTZ 的 TASK 序列化进入数据库时就会抛错。

所以我们要自己实现MethodInvokingJobDetailFactoryBean 的功能，这里用MyDetailQuartzJobBean 替换。 

Java代码  技术分享
  1. import java.lang.reflect.Method;  
  2.   
  3. import org.apache.commons.logging.Log;  
  4. import org.apache.commons.logging.LogFactory;  
  5. import org.quartz.JobExecutionContext;  
  6. import org.quartz.JobExecutionException;  
  7. import org.springframework.context.ApplicationContext;  
  8. import org.springframework.scheduling.quartz.QuartzJobBean;  
  9.   
  10. public class MyDetailQuartzJobBean extends QuartzJobBean {  
  11.     protected final Log logger = LogFactory.getLog(getClass());  
  12.     private String targetObject;  
  13.     private String targetMethod;  
  14.     private ApplicationContext ctx;  
  15.   
  16.     @Override  
  17.     protected void executeInternal(JobExecutionContext context)  
  18.             throws JobExecutionException {  
  19.         try {  
  20.             logger.info("execute [" + targetObject + "] at once>>>>>>");  
  21.             Object otargetObject = ctx.getBean(targetObject);  
  22.             Method m = null;  
  23.   
  24.             try {  
  25.                 m = otargetObject.getClass().getMethod(targetMethod, new Class[] {JobExecutionContext.class});  
  26.                 m.invoke(otargetObject, new Object[] {context});  
  27.             } catch (SecurityException e) {  
  28.                 logger.error(e);  
  29.             } catch (NoSuchMethodException e) {  
  30.                 logger.error(e);  
  31.             }  
  32.         } catch (Exception e) {  
  33.             throw new JobExecutionException(e);  
  34.         }  
  35.     }  
  36.   
  37.     public void setApplicationContext(ApplicationContext applicationContext) {  
  38.         this.ctx = applicationContext;  
  39.     }  
  40.   
  41.     public void setTargetObject(String targetObject) {  
  42.         this.targetObject = targetObject;  
  43.     }  
  44.   
  45.     public void setTargetMethod(String targetMethod) {  
  46.         this.targetMethod = targetMethod;  
  47.     }  


终于到配置spring文件这步了 
Java代码  技术分享
  1. <bean id="mapScheduler" lazy-init="false" autowire="no"  
  2.         class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  
  3.         <property name="triggers">  
  4.             <list>  
  5.                 <ref bean="dailyTrigger" />  
  6.                 <ref bean="billCountTrigger" />  
  7.                 <ref bean="userAcctTrigger" />  
  8.             </list>  
  9.         </property>  
  10.         <property name="applicationContextSchedulerContextKey" value="applicationContext" />  
  11.         <property name="configLocation" value="classpath:quartz.properties" />  
  12.     </bean>  
  13.   
  14.   
  15.     <bean id="dailyBillJob" class="com.***.job.DailyBillJob" />  
  16.   
  17.     <bean id="dailyBillJobDetail" class="org.springframework.scheduling.quartz.JobDetailBean">  
  18.         <property name="jobClass">  
  19.             <value>com.autelan.auteview.lib.util.MyDetailQuartzJobBean  
  20.             </value>  
  21.         </property>  
  22.         <property name="jobDataAsMap">  
  23.             <map>  
  24.                 <entry key="targetObject" value="dailyBillJob" />  
  25.                 <entry key="targetMethod" value="execute" />  
  26.             </map>  
  27.         </property>  
  28.     </bean>  
  29.   
  30.     <bean id="dailyTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">  
  31.         <property name="jobDetail">  
  32.             <ref bean="dailyBillJobDetail" />  
  33.         </property>  
  34.         <property name="cronExpression">  
  35.             <value>11 11 11 * * ?</value>  
  36.         </property>  
  37.     </bean>  
  38. // 转载请注明出处http://forhope.iteye.com/blog/1398990  


大功告成！

Quartz集群配置

标签：

原文地址：http://www.cnblogs.com/Rozdy/p/4220188.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！