Quartz任務監控管理 (1)

Quartz任務監控管理，相似Windows任務管理器，能夠得到運行時的實時監控，查看任務運行狀態，動態增長任務，暫停、恢復、移除任務等。對於動態增長任務，能夠參加個人前一篇文章《Quartz如何在Spring動態配置時間》，本文在前文的基礎上擴展，增長暫停、恢復、移除任務等功能，實現Quartz任務監控管理。 


先看一下最終實現實現效果，只有兩個頁面 ，以下 
 
在這個頁面查看任務實時運行狀態，能夠暫停、恢復、移除任務等 

 
在這個頁面能夠動態配置調度任務。 


實現任務監控，必須能將數據持久化，這裏採用數據庫方式，Quartz對任務的數據庫持久化有着很是好的支持。我在這裏採用quartz 1.6.5，在Quartz發行包的docs\dbTables目錄包含有各類數據庫對應腳本，我用的是MySql 5.0，因此選用tables_mysql_innodb.sql建表。 

建表完成後，配置數據庫鏈接池，分兩步： 
一、配置jdbc.properties文件 

jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true
jdbc.username=root
jdbc.password=kfs

2.配置applicationContext.xml文件 

<bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    <property name="locations">
            <list>
                <value>classpath:jdbc.properties</value>
            </list>
        </property>
</bean>

    <!-- 數據源定義,使用c3p0 鏈接池 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close">
    <property name="driverClass" value="${jdbc.driverClassName}" />
    <property name="jdbcUrl" value="${jdbc.url}" />
    <property name="user" value="${jdbc.username}" />
    <property name="password" value="${jdbc.password}" />
    <property name="initialPoolSize" value="${cpool.minPoolSize}"/>
    <property name="minPoolSize" value="${cpool.minPoolSize}" />
    <property name="maxPoolSize" value="${cpool.maxPoolSize}" />
    <property name="acquireIncrement" value="${cpool.acquireIncrement}" />
    <property name="maxIdleTime" value="${cpool.maxIdleTime}"/>
</bean>

配置Quartz，也分兩步 
一、配置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 

二、配置applicationContext-quartz.xml 

<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.JobDetailBean">
        <property name="jobClass">
            <value>
                com.sundoctor.example.service.MyQuartzJobBean
            </value>
        </property>
        <property name="jobDataAsMap">
            <map>
                <entry key="simpleService">
                    <ref bean="simpleService"/>
                </entry>
            </map>
        </property>
</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類中 

暫停任務 

public void pauseTrigger(String triggerName,String group){
        try {
            scheduler.pauseTrigger(triggerName, group);//中止觸發器
        } catch (SchedulerException e) {
            throw new RuntimeException(e);
        }
}

恢復任務 

public void resumeTrigger(String triggerName,String group){
        try {
            scheduler.resumeTrigger(triggerName, group);//重啓觸發器
        } catch (SchedulerException e) {
            throw new RuntimeException(e);
        }
    }

移除任務 

public boolean removeTrigdger(String triggerName,String group){
        try {
            scheduler.pauseTrigger(triggerName, group);//中止觸發器
            return scheduler.unscheduleJob(triggerName, group);//移除觸發器
        } catch (SchedulerException e) {
            throw new RuntimeException(e);
        }
    }

其它類的實現請參加《Quartz如何在Spring動態配置時間》，那裏有具體說明。  到此，基本簡單實現了Quartz任務監控管理。其實面這裏只是實現了Trigger任務的監控管理，沒有實現Job任務的監控管理，實現Job任務的監控管理跟Trigger差很少。用Quartz能夠很方便實現多樣化的任務監控管理，Trigger任務和Job任務均可進行分組管理。  Quartz很強大，也很簡單，只有想不到的，沒有作不到的，人有多大膽，地有多高產。