Spring Quartz 持久化解決方案

時間 2019-11-20

原文原文鏈接

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

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

既然Spring不支持持久化，那麼持久化任務仍是本身編寫實現吧，不然每次都須要打包發佈，麻煩，本身編寫的類與Quartz徹底兼容.

注意:爲何Spring不支持外配置任務，可能也是考慮到這方面問題因此纔不提供這些任務的執行化支持.[配置文件配置與數據庫配置重複]

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

經過配置實現的是不該該初始化到數據庫，不然直接在數據庫中配置了。不過也是能夠配置的，經過改寫JobDetailBean.代碼以下:
java

Java代碼

package org.frame.auth.service;
import java.util.Map;
import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.springframework.beans.factory.BeanNameAware;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.scheduling.quartz.DelegatingJob;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
public class PersistentJobDetailBean extends JobDetail
implements BeanNameAware, InitializingBean {
private static final long serialVersionUID = -4389885435844732405L;
private Class actualJobClass;
private String beanName;
/**
* Overridden to support any job class, to allow a custom JobFactory
* to adapt the given job class to the Quartz Job interface.
* @see SchedulerFactoryBean#setJobFactory
*/
public void setJobClass(Class jobClass) {
if (jobClass != null && !Job.class.isAssignableFrom(jobClass)) {
super.setJobClass(DelegatingJob.class);
this.actualJobClass = jobClass;
}
else {
super.setJobClass(jobClass);
}
}
/**
* Overridden to support any job class, to allow a custom JobFactory
* to adapt the given job class to the Quartz Job interface.
*/
public Class getJobClass() {
return (this.actualJobClass != null ? this.actualJobClass : super.getJobClass());
}
/**
* Register objects in the JobDataMap via a given Map.
* <p>These objects will be available to this Job only,
* in contrast to objects in the SchedulerContext.
* <p>Note: When using persistent Jobs whose JobDetail will be kept in the
* database, do not put Spring-managed beans or an ApplicationContext
* reference into the JobDataMap but rather into the SchedulerContext.
* @param jobDataAsMap Map with String keys and any objects as values
* (for example Spring-managed beans)
* @see SchedulerFactoryBean#setSchedulerContextAsMap
*/
public void setJobDataAsMap(Map jobDataAsMap) {
getJobDataMap().putAll(jobDataAsMap);
}
/**
* Set a list of JobListener names for this job, referring to
* non-global JobListeners registered with the Scheduler.
* <p>A JobListener name always refers to the name returned
* by the JobListener implementation.
* @see SchedulerFactoryBean#setJobListeners
* @see org.quartz.JobListener#getName
*/
public void setJobListenerNames(String[] names) {
for (int i = 0; i < names.length; i++) {
addJobListener(names[i]);
}
}
public void setBeanName(String beanName) {
this.beanName = beanName;
}
public void afterPropertiesSet() {
if (getName() == null) {
setName(this.beanName);
}
if (getGroup() == null) {
setGroup(Scheduler.DEFAULT_GROUP);
}
}
}

這裏把Spring的ApplicationContext去掉了，由於這個屬性沒有實現序列化接口。其餘配置與原告一致: mysql

Java代碼

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" " http://www.springframework.org/dtd/spring-beans.dtd ">
<beans default-autowire="byName">
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource" destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" >
<value><![CDATA[jdbc:mysql://localhost:3306/txl?connectTimeout=1000&useUnicode=true&characterEncoding=utf-8]]></value>
</property>
<property name="username" value="root"/>
<property name="password" value=""/>
</bean>
<bean id="jobDetail" class = "org.frame.auth.service.PersistentJobDetailBean">
<property name="jobClass" value="org.frame.auth.service.PersistentJob"></property>
</bean>
<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean" >
<property name="jobDetail" ref="jobDetail"/>
<property name="cronExpression">
<value>0/10 * * * * ?</value>
</property>
</bean>
<bean id="schedulerFactory" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="dataSource" ref="dataSource"></property>
<property name="applicationContextSchedulerContextKey" value="applicationContextKey" />
<property name="configLocation" value="classpath:quartz.properties"/>
</bean>
</beans>

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

Java代碼

package org.frame.auth.service;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class PersistentJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("spring quartz!");
}
}

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

Java代碼

package org.frame.auth.service;
import java.util.Map;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.StatefulJob;
public class PersistentJob implements StatefulJob {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// TODO Auto-generated method stub
Map map = context.getJobDetail().getJobDataMap();
System.out.println("["+context.getJobDetail().getName()+"]"+map.get("message"));
map.put("message", "updated Message");
}
}