`
sundoctor
  • 浏览: 323790 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Quartz任务监控管理

阅读更多

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


先看一下最终实现实现效果,只有两个页面 ,如下

在这个页面查看任务实时运行状态,可以暂停、恢复、移除任务等


在这个页面可以动态配置调度任务。


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


1.配置applicationContext.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:context="http://www.springframework.org/schema/context"  
    xmlns:jdbc="http://www.springframework.org/schema/jdbc"  
    xsi:schemaLocation="
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
   http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd
    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
    " >
  
   <context:component-scan base-package="com.sundoctor">
   		<context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
	</context:component-scan>

	
	<!-- 使用H2内存数据库并创建quartz数据库表 -->
    <jdbc:embedded-database id="dataSource" type="H2">
        <jdbc:script location="classpath:db/tables_h2.sql"/>       
    </jdbc:embedded-database>	
	
	<!--Hibernate SessionFatory-->
	<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
	    <property name="dataSource" ref="dataSource"/>
		<property name="packagesToScan">
			<list>
				<value>com.sundoctor.example.model</value>				
			</list>
		</property>	
	    <property name="hibernateProperties">
	        <props>
	            <prop key="hibernate.dialect">org.hibernate.dialect.H2Dialect</prop>
	            <prop key="hibernate.show_sql">true</prop>
	            <prop key="hibernate.format_sql">true</prop>				
				<prop key="hibernate.hbm2ddl.auto">update</prop>        
	        </props>
	    </property>
	</bean>	
	
	<!--Hibernate TransactionManager-->
	<bean id="transactionManager"  class="org.springframework.orm.hibernate4.HibernateTransactionManager">
	    <property name="sessionFactory" ref="sessionFactory"/>
	</bean>		

	<!-- 使用annotation定义事务 -->
	<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true" />		

</beans>

 

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

…
org.quartz.jobStore.misfireThreshold = 60000
#org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
#org.quartz.jobStore.useProperties = true
org.quartz.jobStore.tablePrefix = QRTZ_  
org.quartz.jobStore.isClustered = false  org.quartz.jobStore.maxMisfiresToHandleAtATime=1


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

2、配置applicationContext-quartz.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <bean name="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" >
        <property name="dataSource" ref ="dataSource" />       
        <property name="applicationContextSchedulerContextKey" value="applicationContextKey"/>
        <property name="configLocation" value="classpath:quartz.properties"/>			
    </bean>
    
    <bean id="jobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean" >
        <property name="jobClass">
            <value>com.sundoctor.example.service.MyQuartzJobBean</value>
        </property>
       <property name="durability" value="true" />	
    </bean>
	 
</beans>

 

到些,相关配置全部完成,对于配置的具体描述,可以参加我的前一篇文章《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类中

暂停任务

	@Override
	public void pauseTrigger(String triggerName, String group) {
		try {
			scheduler.pauseTrigger(new TriggerKey(triggerName, group));// 停止触发器
		} catch (SchedulerException e) {
			throw new RuntimeException(e);
		}
	}

 

恢复任务

	@Override
	public void resumeTrigger(String triggerName, String group) {
		try {
			scheduler.resumeTrigger(new TriggerKey(triggerName, group));// 重启触发器
		} catch (SchedulerException e) {
			throw new RuntimeException(e);
		}
	}


移除任务

	@Override
	public boolean removeTrigdger(String triggerName, String group) {
		TriggerKey triggerKey = new TriggerKey(triggerName, group);
		try {
			scheduler.pauseTrigger(triggerKey);// 停止触发器
			return scheduler.unscheduleJob(triggerKey);// 移除触发器
		} catch (SchedulerException e) {
			throw new RuntimeException(e);
		}
	}



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

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

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

 

分享到:
评论
76 楼 好奇害死猫 2016-06-29  
好老的博客了。。。。。。。。。。。。。。。。

您好,博主。我想请教个问题:
您是如何获取到job的状态(运行中,暂停中,等待中)的?或者说这些状态信息你是怎么做的?

目前我能想到的解决办法是通过往表(新建一个操作日志表)里插入日志的形式:

运行中:通过JobListener监听器来实现运行时更改表信息

暂停中:调用scheduler.pauseTrigger()方法时,更改表中job信息

等待中:新添加的job默认给其等待中的状态,也是更改表中的job信息

但是上面这种形式的麻烦之处是得频繁的往表里插入数据。
75 楼 zengzhuo86 2014-04-15  
楼主文章写的很不错,对我的帮助很大
74 楼 guan2468 2013-12-05  
按照群主你的Quartz任务监控管理 的配值,如何让任务变成有状态的任务,不能并发,就是加上<property name="concurrent" value="false" />



我已经可以动态加载,但是任务还是并发,把这句代码放在那里,可以让他不并发。



底下是我要完成的要求

在quartz和sping整合中动态执行加载的定时任务,定时任务是有状态的,不能并发。
73 楼 guan2468 2013-12-05  
按照群主你的Quartz任务监控管理 的配值,如何让任务变成有状态的任务,不能并发,就是加上<property name="concurrent" value="false" />



我已经可以动态加载,但是任务还是并发,把这句代码放在那里,可以让他不并发。



底下是我要完成的要求

在quartz和sping整合中动态执行加载的定时任务,定时任务是有状态的,不能并发。
72 楼 HU516146194 2013-09-16  
我用quartz2.2与Spring3.2.2整合,第一次运行时任务是能存储成功,第二次的就抛异常,请问这是什么原因,如何解决?
Exception in thread "main" java.lang.RuntimeException: org.quartz.ObjectAlreadyExistsException: Unable to store Job : 'DEFAULT.jobDetail', because one already exists with this identification.
at test.SchedulerServiceImpl.schedule(SchedulerServiceImpl.java:92)
at test.SchedulerServiceImpl.schedule(SchedulerServiceImpl.java:50)
at test.SchedulerServiceImpl.schedule(SchedulerServiceImpl.java:44)
at test.CornTest.main(CornTest.java:13)
Caused by: org.quartz.ObjectAlreadyExistsException: Unable to store Job : 'DEFAULT.jobDetail', because one already exists with this identification.
at org.quartz.impl.jdbcjobstore.JobStoreSupport.storeJob(JobStoreSupport.java:1107)
at org.quartz.impl.jdbcjobstore.JobStoreSupport$2.execute(JobStoreSupport.java:1061)
at org.quartz.impl.jdbcjobstore.JobStoreSupport$45.execute(JobStoreSupport.java:3705)
at org.quartz.impl.jdbcjobstore.JobStoreCMT.executeInLock(JobStoreCMT.java:245)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.executeInLock(JobStoreSupport.java:3701)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.storeJobAndTrigger(JobStoreSupport.java:1057)
at org.quartz.core.QuartzScheduler.scheduleJob(QuartzScheduler.java:916)
at org.quartz.impl.StdScheduler.scheduleJob(StdScheduler.java:249)
at test.SchedulerServiceImpl.schedule(SchedulerServiceImpl.java:87)
... 3 more
71 楼 shakajava 2013-01-15  
还有框架所说的暂停功能,能真正的暂停吗,比如我一个任务是调用一个jar包跑的清洗数据,无法真正停下来的吧
70 楼 shakajava 2013-01-15  
博主,有个疑问,添加调度任务的时候框架自带的表中哪个指定一个jobDetail的具体任务的,比如我有个任务是调用执行某个jar包跑任务,我想做成可以自定义任务的一个触发器,现在增加的都是空任务,代码里写死的打印日志功能,如何灵活点的?我看了一遍SchedulerService接口,没有一个方法能指定具体的任务的
69 楼 zhuyouyong 2012-09-17  
junny9985 写道
楼主是个热心人
我在你的指导下
详细看了你的代码
也封装出了自己需要的任务调度器
灵活度更高,脱离了配置文件
可以脱离配置文件吗 ?
68 楼 zhipingch 2012-09-04  
你这工程如何发布到tomcat下。
67 楼 jdzwhy 2012-08-21  
楼主你好,我看你效果图上的多个任务始终只有一个任务处理运行状态,有什么办法可以让多个任务同处于运行状态
66 楼 sundoctor 2012-08-10  
到官网下载quartz后解决,在docs\dbTables目录下就可以找到建表脚本
65 楼 453871840509495155 2012-08-09  
楼主,能不能把建表语句也贴上来,谢谢了。
64 楼 txin0814 2011-12-26  
学习。。。
63 楼 skynet_java 2011-10-26  
还有就是运行是报错的,
62 楼 skynet_java 2011-10-26  
你的创建表的脚本 不见,oracle创建表的脚本。邮箱地址:luomingfree520@qq.com.谢谢!
61 楼 junjie_07 2011-08-03  
我查过quartz1.8.5是将Data存入Map中,在将Map转换成Long型;那如何反过来操作列?
60 楼 junjie_07 2011-08-03  
博主:
    你好。我最近也在用quartzNet来做个项目。现在遇到一些问题:
    请问任务调度列表中的上下次执行时间是如何转换的,数据库保存的是bigint形式,请问你是如何转换成Data(DataTime)。
59 楼 junny9985 2010-07-24  
楼主是个热心人
我在你的指导下
详细看了你的代码
也封装出了自己需要的任务调度器
灵活度更高,脱离了配置文件
58 楼 godson_2003 2010-06-13  
java.lang.RuntimeException: org.quartz.JobPersistenceException: Couldn't store trigger 'MYTRIGGER&a2631a51-b447-4543-80a4-cda67f207282' for 'jobDetail' job:The job (DEFAULT.jobDetail) referenced by the trigger does not exist. [See nested exception: org.quartz.JobPersistenceException: The job (DEFAULT.jobDetail) referenced by the trigger does not exist.]


这是怎么回事啊?
57 楼 sundoctor 2010-01-29  
手工创建,在Quartz发行包的docs\dbTables目录包含有各种数据库对应脚本

相关推荐

Global site tag (gtag.js) - Google Analytics