通过spring实现对所有定时任务进行AOP拦截，和实现每个定时任务执行的时间从数据库动态获得_陈超超

http://blog.sina.com.cn/u/1649030444

首页博文目录关于我

个人资料

微博

加好友发纸条

写留言加关注

博客等级：
博客积分：

博客访问：
关注人气：
获赠金笔：0支
赠出金笔：0支
荣誉徽章：

正文字体大小：大中小

通过spring实现对所有定时任务进行AOP拦截，和实现每个定时任务执行的时间从数据库动态获得

(2013-01-24 13:57:49)

标签：

方式

spring

定时任务

动态获得

aop

分类：我的职业--SSH

通过spring实现对所有定时任务进行AOP拦截，和实现每个定时任务执行的时间从数据库动态获得，这样可以保证不需要重启容器就可以修改某个定时任务的执行时间

1.spring.xml配置AOP切面

</bean>

<aop:config proxy-target-class="true">

<aop:advisor id="methodTimeLog" advice-ref="methodTimeAdvice" pointcut="execution(* cn.abc.timertask.biz.*.*.*Task.work(..))

or execution(* cn.abc.timertask.biz.*.*.*Servlet.work(..))"/>

</aop:config>

</bean>

<bean id="huPaymentTask_schedulerJobDetail"

class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

</bean>

<bean id="huPaymentTask_cronTrigger"

class="cn.abc.timertask.core.common.taskManager.InitializingCronTrigger">

</bean>

</bean>

</bean>

</bean>

<bean id="schedulerFactoryTask_schedulerJobDetail"

class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

</bean>

<bean id="schedulerFactoryTask_cronTrigger"

class="cn.abc.timertask.core.common.taskManager.InitializingCronTrigger">

</bean>

<bean id="schedulerFactory" lazy-init="false"

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

<list>

</list>

</property>

</bean>

2.HuPaymentTask.java 一个定时任务类,WeatherTask.java与这个类似，就不写了

package cn.abc.timertask.biz.fight.huPayment;

public class HuPaymentTask {

public void work() {

System.out.println("这里写这个定时任务需要执行的操作代码");

}

3.MethodTimeAdvice.java 切面类，其中加入了将拦截的内容加入到数据库的代码，如果不需要可以相应删掉

package cn.abc.timertask.core.common.taskManager;

import java.text.SimpleDateFormat;

import java.util.Date;

import org.aopalliance.intercept.MethodInterceptor;

import org.aopalliance.intercept.MethodInvocation;

import org.apache.commons.lang.StringUtils;

import org.apache.commons.lang.time.StopWatch;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.aop.ThrowsAdvice;

import cn.abc.timertask.core.common.taskManager.po.TaskDetail;

public class MethodTimeAdvice implements MethodInterceptor {

protected final Log log = LogFactory.getLog(MethodTimeAdvice.class);

public Object invoke(MethodInvocation invocation) {

Object[] object = invocation.getArguments();

ScheduleInfoManager scheduleInfoManager = new ScheduleInfoManager();//这个类封装了对数据库的增删改查操作

TaskDetail taskDetail = new TaskDetail();//这是一个实体

// 用 commons-lang 提供的 StopWatch 计时，Spring 也提供了一个 StopWatch

StopWatch clock = new StopWatch();

clock.start(); // 计时开始

String beforeTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS").format(new Date());

System.out.println("启动时间："+ beforeTime);

taskDetail.setTask_detail_startdate(beforeTime);

Object result = null;

try {

result = invocation.proceed();

System.out.println(result);

taskDetail.setTask_detail_isexception("0");

} catch (Exception e) {

// TODO: handle exception

System.out.println("捕获的异常："+e.getMessage());

String exceptionTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS").format(new Date());

taskDetail.setTask_detail_isexception("1");

taskDetail.setTask_detail_exceptiondesc(e.getMessage());

taskDetail.setTask_detail_executedate(exceptionTime);

}finally{

clock.stop(); // 切面结束

String endTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS").format(new Date());

System.out.println("结束时间："+ endTime);

taskDetail.setTask_detail_enddate(endTime);

// 方法参数类型，转换成简单类型

Class[] params = invocation.getMethod().getParameterTypes();

String[] simpleParams = new String[params.length];

for (int i = 0; i < params.length; i++) {

simpleParams[i] = params[i].getSimpleName();

}

System.out.println("结束时间：" + clock.getTime() + " ms");

taskDetail.setTask_detail_executedate(clock.getTime() + " ms");

System.out.println("每次执行时间:" + clock.getTime() + " ms");

System.out.println("操作类（包名+类名+方法名+（参数））： ["

+ invocation.getThis().getClass().getName() + "."

+ invocation.getMethod().getName() + "("

+ StringUtils.join(simpleParams, ",") + ")] ");

System.out.println(result);

//这里将拦截的数据插入的数据库

scheduleInfoManager.insertTaskDetail(taskDetail);

return result;

}

4.InitializingCronTrigger.java//每个定时器调用的初始化时间类

package cn.abc.timertask.core.common.taskManager;

import java.io.Serializable;

import java.text.ParseException;

import org.springframework.scheduling.quartz.CronTriggerBean;

import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;

public class InitializingCronTrigger extends CronTriggerBean implements Serializable {

private ScheduleInfoManager scheduleInfoManager;

private String taskid;

public void setTaskid(String taskid) {

this.taskid = taskid;

}

public ScheduleInfoManager getScheduleInfoManager() {

return scheduleInfoManager;

}

public String getTaskid() {

return taskid;

}

// 设值注入，通过setter方法传入被调用者的实例scheduleInfoManager

public void setScheduleInfoManager(ScheduleInfoManager scheduleInfoManager){

System.out.println("----------------初始化"+taskid+"定时任务时间-----------------");

this.scheduleInfoManager = scheduleInfoManager;

String cronExpression = "0 0 0 */1 * ?";//所有定时任务的执行时间都初始化为一天执行一次

try {

setCronexpression_r(cronExpression);

if(taskid.equals("schedulerFactoryTask")){//如果调用的是总定时器

setCronexpression_r("0/10 * * * * ?");//设置总定时器每个10分钟更新一次所有的定时器的时间

}

} catch (ParseException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} // ②

}

5.SchedulerFactoryTask.java 为所有定时器更新相应的执行时间

package cn.abc.timertask.core.common.taskManager;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.text.ParseException;

import java.util.ArrayList;

import java.util.List;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import org.springframework.scheduling.quartz.CronTriggerBean;

public class SchedulerFactoryTask {

private Scheduler schedulerFactory;

private ScheduleInfoManager scheduleInfoManager;

// 设值注入，通过setter方法传入被调用者的实例scheduler

public void setSchedulerFactory(Scheduler schedulerFactory) {

this.schedulerFactory = schedulerFactory;

}

public ScheduleInfoManager getScheduleInfoManager() {

return scheduleInfoManager;

}

public void setScheduleInfoManager(ScheduleInfoManager scheduleInfoManager) {

this.scheduleInfoManager = scheduleInfoManager;

}

public void work(){

try {

ApplicationContext context = new ClassPathXmlApplicationContext("spring-triggers.xml");//spring-triggers.xml如下，其中是一个所有定时器名字的集合

List quartzList = (ArrayList)context.getBean("quartzList");

for(int i = 0;i

CronTriggerBean trigger = (CronTriggerBean) schedulerFactory.getTrigger(quartzList.get(i), Scheduler.DEFAULT_GROUP);

String dbCronExpression = "" ;

dbCronExpression = scheduleInfoManager.getCronExpressionFromDB(quartzList.get(i).split("_")[0]);

//System.out.println(trigger+"+++++");

String originConExpression = trigger.getCronexpression_r();

//System.out.println(trigger+"===="+originConExpression);

// 判断从DB中取得的任务时间(dbCronExpression)和现在的quartz线程中的任务时间(originConExpression)是否相等

// 如果相等，则表示用户并没有重新设定数据库中的任务时间，这种情况不需要重新rescheduleJob

if(!originConExpression.equalsIgnoreCase(dbCronExpression)){

trigger.setCronexpression_r(dbCronExpression);

schedulerFactory.rescheduleJob(quartzList.get(i), Scheduler.DEFAULT_GROUP, trigger);

}

} catch (SchedulerException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (ParseException e) {

// TODO: handle exception

e.printStackTrace();

}

6.spring-triggers.xml 这是一个所有定时任务名字的LIST，当然你也可以从数据库获得或其他方式定义

<?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:context="http://www.springframework.org/schema/context"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context-3.0.xsd">

<constructor-arg>

<list>

<value>huPaymentTask_cronTrigger</value>

<value>weatherTask_cronTrigger</value>

</list>

</constructor-arg>

</bean>

</beans>

阅读┊ 收藏 ┊ 喜欢 ▼ ┊打印┊举报/Report

前一篇：使用axis和jaxb将wsdl转化为java类和将xsd文件转化为java类的两个工具

后一篇：我的博客今天3岁269天了，我领取了精英博主徽章

新浪BLOG意见反馈留言板　欢迎批评指正