您的位置: 首页  >  IT文章  >  Quartz任务监控治理

Quartz任务监控治理

分类: IT文章 • 2024-01-09 22:56:12
Quartz任务监控管理

Quartz任务监控管理，类似Windows任务管理器，可以获得运行时的实时监控，查看任务运行状态，动态增加任务，暂停、恢复、移除任务等。对于动 态增加任务，可以参加我的前一篇文章《Quartz如何在Spring动态配置时间》，本文在前文的基础上扩展，增加暂停、恢复、移除任务等功能，实现 Quartz任务监控管理。


先看一下最终实现实现效果，只有两个页面 ，如下
Quartz任务监控治理
在这个页面查看任务实时运行状态，可以暂停、恢复、移除任务等

Quartz任务监控治理
在这个页面可以动态配置调度任务。


实现任务监控，必须能将数据持久化，这里采用数据库方式，Quartz对任务的数据库持久化有着非常好的支持。我在这里采用quartz 1.6.5，在Quartz发行包的docs\dbTables目录包含有各种数据库对应脚本，我用的是MySql 5.0，所以选用tables_mysql_innodb.sql建表。

建表完成后，配置数据库连接池，分两步：
1、配置jdbc.properties文件

Java代码 Quartz任务监控治理  Quartz任务监控治理
  1. jdbc.driverClassName=com.mysql.jdbc.Driver   
  2. jdbc.url=jdbc:mysql: //localhost:3306/quartz?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true   
  3. jdbc.username=root   
  4. jdbc.password=kfs  
view plain
  1. jdbc.driverClassName=com.mysql.jdbc.Driver  
  2. jdbc.url=jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true   
  3. jdbc.username=root  
  4. jdbc.password=kfs  


2.配置applicationContext.xml文件

Java代码 Quartz任务监控治理  Quartz任务监控治理
  1. <bean id= "propertyConfigurer"   class = "org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" >   
  2.     <property name= "locations" >   
  3.             <list>   
  4.                 <value>classpath:jdbc.properties</value>   
  5.             </list>   
  6.         </property>   
  7. </bean>   
  8.        
  9.     <!-- 数据源定义,使用c3p0 连接池 -->   
  10. <bean id= "dataSource"   class = "com.mchange.v2.c3p0.ComboPooledDataSource"  destroy-method= "close" >   
  11.     <property name= "driverClass"  value= "${jdbc.driverClassName}"  />      
  12.     <property name= "jdbcUrl"  value= "${jdbc.url}"  />      
  13.     <property name= "user"  value= "${jdbc.username}"  />    
  14.     <property name= "password"  value= "${jdbc.password}"  />        
  15.     <property name= "initialPoolSize"  value= "${cpool.minPoolSize}" />      
  16.     <property name= "minPoolSize"  value= "${cpool.minPoolSize}"  />     
  17.     <property name= "maxPoolSize"  value= "${cpool.maxPoolSize}"  />     
  18.     <property name= "acquireIncrement"  value= "${cpool.acquireIncrement}"  />    
  19.     <property name= "maxIdleTime"  value= "${cpool.maxIdleTime}" />      
  20. </bean>  
view plain
  1. <bean id= "propertyConfigurer"   class = "org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" >  
  2.     <property name="locations" >  
  3.             <list>  
  4.                 <value>classpath:jdbc.properties</value>  
  5.             </list>  
  6.         </property>  
  7. </bean>  
  8.       
  9.     <!-- 数据源定义,使用c3p0 连接池 -->  
  10. <bean id="dataSource"   class = "com.mchange.v2.c3p0.ComboPooledDataSource"  destroy-method= "close" >  
  11.     <property name="driverClass"  value= "${jdbc.driverClassName}"  />     
  12.     <property name="jdbcUrl"  value= "${jdbc.url}"  />     
  13.     <property name="user"  value= "${jdbc.username}"  />   
  14.     <property name="password"  value= "${jdbc.password}"  />       
  15.     <property name="initialPoolSize"  value= "${cpool.minPoolSize}" />     
  16.     <property name="minPoolSize"  value= "${cpool.minPoolSize}"  />    
  17.     <property name="maxPoolSize"  value= "${cpool.maxPoolSize}"  />    
  18.     <property name="acquireIncrement"  value= "${cpool.acquireIncrement}"  />   
  19.     <property name="maxIdleTime"  value= "${cpool.maxIdleTime}" />     
  20. </bean>  


配置Quartz，也分两步
1、配置quartz. properties

Java代码 Quartz任务监控治理  Quartz任务监控治理
  1. …   
  2. org.quartz.jobStore.misfireThreshold =  60000   
  3. #org.quartz.jobStore. class  = org.quartz.simpl.RAMJobStore   
  4. org.quartz.jobStore. class  = org.quartz.impl.jdbcjobstore.JobStoreTX   
  5. org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate   
  6. #org.quartz.jobStore.useProperties =  true   
  7. org.quartz.jobStore.tablePrefix = QRTZ_     
  8. org.quartz.jobStore.isClustered =  false   org.quartz.jobStore.maxMisfiresToHandleAtATime= 1   
view plain
  1. …  
  2. org.quartz.jobStore.misfireThreshold = 60000   
  3. #org.quartz.jobStore.class  = org.quartz.simpl.RAMJobStore  
  4. org.quartz.jobStore.class  = org.quartz.impl.jdbcjobstore.JobStoreTX  
  5. org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate  
  6. #org.quartz.jobStore.useProperties = true   
  7. org.quartz.jobStore.tablePrefix = QRTZ_    
  8. org.quartz.jobStore.isClustered = false   org.quartz.jobStore.maxMisfiresToHandleAtATime= 1   


在这里采用JobStoreTX，将任务持久化到数据中，而不再是简单的内存方式：RAMJobStore

2、配置applicationContext-quartz.xml

Java代码 Quartz任务监控治理  Quartz任务监控治理
  1. <bean name= "quartzScheduler"   class = "org.springframework.scheduling.quartz.SchedulerFactoryBean" >   
  2.         <property name= "dataSource"  ref = "dataSource"  />          
  3.         <property name= "applicationContextSchedulerContextKey"  value= "applicationContextKey" />   
  4.         <property name= "configLocation"  value= "classpath:quartz.properties" />   
  5.     </bean>   
  6.        
  7. <bean id= "jobDetail"   class = "org.springframework.scheduling.quartz.JobDetailBean" >   
  8.         <property name= "jobClass" >   
  9.             <value>   
  10.                 com.sundoctor.example.service.MyQuartzJobBean   
  11.             </value>   
  12.         </property>   
  13.         <property name= "jobDataAsMap" >   
  14.             <map>   
  15.                 <entry key= "simpleService" >   
  16.                     <ref bean= "simpleService" />   
  17.                 </entry>   
  18.             </map>   
  19.         </property>       
  20. </bean>  
view plain
  1. <bean name= "quartzScheduler"   class = "org.springframework.scheduling.quartz.SchedulerFactoryBean" >  
  2.         <property name="dataSource"  ref = "dataSource"  />         
  3.         <property name="applicationContextSchedulerContextKey"  value= "applicationContextKey" />  
  4.         <property name="configLocation"  value= "classpath:quartz.properties" />  
  5.     </bean>  
  6.       
  7. <bean id="jobDetail"   class = "org.springframework.scheduling.quartz.JobDetailBean" >  
  8.         <property name="jobClass" >  
  9.             <value>  
  10.                 com.sundoctor.example.service.MyQuartzJobBean  
  11.             </value>  
  12.         </property>  
  13.         <property name="jobDataAsMap" >  
  14.             <map>  
  15.                 <entry key="simpleService" >  
  16.                     <ref bean="simpleService" />  
  17.                 </entry>  
  18.             </map>  
  19.         </property>      
  20. </bean>  


到些，相关配置全部完成，对于配置的具体描述，可以参加我的前一篇文章《Quartz如何在Spring动态配置时间》

实现任务动态添加配置

请参考com.sundoctor.quartz.service.SchedulerServiceImpl.java中的各种schedule方法，在《Quartz如何在Spring动态配置时间》有具体描述。在这里说一下：
添加一个Job在表qrtz_job_details插入一条记录
添加一个Simple Trigger在表qrtz_simple_triggers插入一条记录
添加一个Cron Trigger 在表qrtz_cron_triggers插入一条记录
添加Simple Trigger和Cron Trigger都会同进在表qrtz_triggers插入一条记录，开始看的第一个页面调度任务列表数据就是从qrtz_triggers表获取

实现任务实时监控，暂停、恢复、移除任务等
在com.sundoctor.quartz.service.SchedulerServiceImpl.java类中

暂停任务

Java代码 Quartz任务监控治理  Quartz任务监控治理
  1. public   void  pauseTrigger(String triggerName,String group){         
  2.          try  {   
  3.             scheduler.pauseTrigger(triggerName, group); //停止触发器   
  4.         }  catch  (SchedulerException e) {   
  5.              throw   new  RuntimeException(e);   
  6.         }   
  7. }  
view plain
  1. public   void  pauseTrigger(String triggerName,String group){        
  2.         try  {  
  3.             scheduler.pauseTrigger(triggerName, group);//停止触发器   
  4.         } catch  (SchedulerException e) {  
  5.             throw   new  RuntimeException(e);  
  6.         }  
  7. }  


恢复任务

Java代码 Quartz任务监控治理  Quartz任务监控治理
  1. public   void  resumeTrigger(String triggerName,String group){        
  2.          try  {   
  3.             scheduler.resumeTrigger(triggerName, group); //重启触发器   
  4.         }  catch  (SchedulerException e) {   
  5.              throw   new  RuntimeException(e);   
  6.         }   
  7.     }  
view plain
  1. public   void  resumeTrigger(String triggerName,String group){       
  2.         try  {  
  3.             scheduler.resumeTrigger(triggerName, group);//重启触发器   
  4.         } catch  (SchedulerException e) {  
  5.             throw   new  RuntimeException(e);  
  6.         }  
  7.     }  


移除任务

Java代码 Quartz任务监控治理  Quartz任务监控治理
  1. public   boolean  removeTrigdger(String triggerName,String group){        
  2.          try  {   
  3.             scheduler.pauseTrigger(triggerName, group); //停止触发器   
  4.              return  scheduler.unscheduleJob(triggerName, group); //移除触发器   
  5.         }  catch  (SchedulerException e) {   
  6.              throw   new  RuntimeException(e);   
  7.         }   
  8.     }  
view plain
  1. public   boolean  removeTrigdger(String triggerName,String group){       
  2.         try  {  
  3.             scheduler.pauseTrigger(triggerName, group);//停止触发器   
  4.             return  scheduler.unscheduleJob(triggerName, group); //移除触发器   
  5.         } catch  (SchedulerException e) {  
  6.             throw   new  RuntimeException(e);  
  7.         }  
  8.     }  



其它类的实现请参加《Quartz如何在Spring动态配置时间》，那里有具体说明。

到此，基本简单实现了Quartz任务监控管理。其实面这里只是实现了Trigger任务的监控管理，没有实现Job任务的监控管理，实现Job任务的监 控管理跟Trigger差不多。用Quartz可以很方便实现多样化的任务监控管理，Trigger任务和Job任务都可进行分组管理。

Quartz很强大，也很简单，只有想不到的，没有做不到的，人有多大胆，地有多高产。

相关推荐