java Quartz定时器任务与Spring 的实现

2022-02-26 09:04:33

1.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"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">

<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

       <property name="quartzProperties">
           <props>
               <prop key="org.quartz.scheduler.instanceName">CRMscheduler</prop>
               <prop key="org.quartz.scheduler.instanceId">AUTO</prop>
               
               <prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop>
               <prop key="org.quartz.threadPool.threadCount">3</prop>
               <prop key="org.quartz.threadPool.threadPriority">5</prop>
               
               <prop key="org.quartz.jobStore.class">org.quartz.impl.jdbcjobstore.JobStoreTX</prop>
               
               <prop key="org.quartz.jobStore.isClustered">true</prop>
               <prop key="org.quartz.jobStore.clusterCheckinInterval">15000</prop>
               <prop key="org.quartz.jobStore.maxMisfiresToHandleAtATime">1</prop>
               
               <prop key="org.quartz.jobStore.dataSource">myDS</prop>
               <prop key="org.quartz.dataSource.myDS.driver">${db.driverClassName}</prop>
               <prop key="org.quartz.dataSource.myDS.URL">${db.quartz_park.url}</prop>
               <prop key="org.quartz.dataSource.myDS.user">${db.username}</prop>
               <prop key="org.quartz.dataSource.myDS.password">${db.password}</prop>
               <prop key="org.quartz.dataSource.myDS.maxConnections">10</prop>
               <prop key="org.quartz.jobStore.misfireThreshold">120000</prop>
           </props>
       </property>

2.作业类1

package com.ivchat.common.bean.quartz;

import org.springframework.scheduling.quartz.JobDetailBean;

/**
* JOB明细对象
* @author 居里智能
*
*/
public class CommJobDetailBean extends JobDetailBean {
private boolean concurrent = false;

@Override
   public void afterPropertiesSet() {
       try{
           if (concurrent){
               this.setJobClass(CommDetailQuartzJobBean.class);
           }else{
               this.setJobClass(StatefulMethodInvokingJob.class);
           }
       }catch(Exception ex){
           ex.printStackTrace();
       }

       // TODO Auto-generated method stub
       super.afterPropertiesSet();
   }

public boolean isConcurrent() {
return concurrent;
}

public void setConcurrent(boolean concurrent) {
       this.concurrent = concurrent;
   }

   public boolean getConcurrent() {
       return concurrent;
   }
}
3.作业类2

package com.ivchat.common.bean.quartz;

import java.lang.reflect.Method;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.scheduling.quartz.QuartzJobBean;

import com.ivchat.common.util.SpringUtil;

/**
* JOB类，到时间即时执行，有可能多个JOB并发执行
* @author 居里智能
*
*/
public class CommDetailQuartzJobBean extends QuartzJobBean implements ApplicationContextAware{

private String targetObject;
   private String targetMethod;
   private ApplicationContext applicationContext;
   @Override
   public void executeInternal(JobExecutionContext context)
           throws JobExecutionException {
       Object otargetObject = null;
       Method m = null;

       try {
           otargetObject = applicationContext.getBean(targetObject);

           m = otargetObject.getClass().getMethod(targetMethod,
                   new Class[] {});
           m.invoke(otargetObject, new Object[] {});
       } catch (Exception e) {
           throw new JobExecutionException(e);
       }
   }

public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = applicationContext;
}

public ApplicationContext getApplicationContext() {
return applicationContext;
}

public String getTargetObject() {
return targetObject;
}

public void setTargetObject(String targetObject) {
this.targetObject = targetObject;
}

public String getTargetMethod() {
return targetMethod;
}

public void setTargetMethod(String targetMethod) {
this.targetMethod = targetMethod;
}

}

码农公寓

相关文章