java spring注解任务调度并实现aop监控任务执行情况-mile米乐体育

本文讲的是通过spring注解的方式实现任务调度。只要引入了spring-context包就能够在项目中使用注解方式的任务调度。

下面看具体配置

需要在spring配置文件中加入task的schema。

xmlns:task="http://www.springframework.org/schema/task" xsi:schemalocation="http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd"

然后在启用注解支持

然后在代码中就可以直接用了，要定时执行的方法必须是void的，并且没有任何参数的。

@override @scheduled(cron="0 0 2 * * ?") @transactional(rollbackfor=exception.class) public void excute() throws dxpexception

cron表达式请自行问百度，下面只列出几个从网上找的例子

cron表达式 含义

“0 0 12 * * ?” 每天中午十二点触发

“0 15 10 ? * *” 每天早上10：15触发

“0 15 10 * * ?” 每天早上10：15触发

“0 15 10 * * ? *” 每天早上10：15触发

“0 15 10 * * ? 2005” 2005年的每天早上10：15触发

“0 * 14 * * ?” 每天从下午2点开始到2点59分每分钟一次触发

“0 0/5 14 * * ?” 每天从下午2点开始到2：55分结束每5分钟一次触发

“0 0/5 14,18 * * ?” 每天的下午2点至2：55和6点至6点55分两个时间段内每5分钟一次触发

“0 0-5 14 * * ?” 每天14:00至14:05每分钟一次触发

“0 10,44 14 ? 3 wed” 三月的每周三的14：10和14：44触发

“0 15 10 ? * mon-fri” 每个周一、周二、周三、周四、周五的10：15触发

通过aop监控方法的执行情况，并保存到数据库中

package com.tiamaes.gjds.dxp.aop;  import java.util.date;  import org.aspectj.lang.proceedingjoinpoint; import org.aspectj.lang.annotation.around; import org.aspectj.lang.annotation.aspect; import org.aspectj.lang.annotation.pointcut; import org.springframework.beans.factory.annotation.autowired;  import com.tiamaes.gjds.dxp.annotation.task; import com.tiamaes.gjds.dxp.bean.tbscheduledexcutelog; import com.tiamaes.gjds.dxp.repository.tbscheduledexcutelogrepository; import com.tiamaes.gjds.dxp.task.dxpscheduled;  /**    * 
类描述：通过aop监控方法的执行情况，并保存到数据库中
  * 
创建人：王成委  
  * 
创建时间：2015年2月28日 上午9:40:18  
  * 
米乐app官网登录的版权说明： © 2015 tiamaes 
  */ @aspect public class scheduledstatisticshandler {      @autowired     private tbscheduledexcutelogrepository tbscheduledexcutelogrepository;      @pointcut("@annotation(org.springframework.scheduling.annotation.scheduled)")       public void proxyaspect() {      }      @around("proxyaspect()")     public object doinvoke(proceedingjoinpoint joinpoint) throws throwable{         date date = new date();         long start = system.currenttimemillis();         object result = joinpoint.proceed();         long end = system.currenttimemillis();         object target = joinpoint.gettarget();          tbscheduledexcutelog log = new tbscheduledexcutelog();         log.setclassname(joinpoint.gettarget().getclass().getname());         log.setconsum(end-start);         log.setexcutedate(date);         log.setexcutetime(date);         log.setiserror(false);         if (target instanceof dxpscheduled) {             dxpscheduled scheduled = (dxpscheduled) target;             task task = scheduled.getclass().getannotation(task.class);             log.setcontentname(task.value());             log.setremark(scheduled.gettaskexcuteinfo());             log.setgetreccount(scheduled.getremotecount());             log.setsyncreccount(scheduled.getsynccount());         }          this.tbscheduledexcutelogrepository.save(log);          return result;     } }

通过aop记录执行时发生异常的任务

package com.tiamaes.gjds.dxp.aop;  import java.util.date;  import org.aspectj.lang.joinpoint; import org.aspectj.lang.annotation.afterthrowing; import org.aspectj.lang.annotation.aspect; import org.aspectj.lang.annotation.pointcut; import org.springframework.beans.factory.annotation.autowired;  import com.tiamaes.gjds.dxp.annotation.task; import com.tiamaes.gjds.dxp.bean.tbscheduledexcutelog; import com.tiamaes.gjds.dxp.dao.tbscheduledexcutelogdao; import com.tiamaes.gjds.dxp.exception.dxpexception; import com.tiamaes.gjds.dxp.task.dxpscheduled; import com.tiamaes.gjds.util.exceptiontools;  /**    * 
类描述： 处理任务执行时法伤的异常 
  * 
创建人：王成委  
  * 
创建时间：2015年2月28日 下午4:24:54  
  * 
米乐app官网登录的版权说明： © 2015 tiamaes 
  */ @aspect public class scheduleexceptionhandler {      @autowired     private tbscheduledexcutelogdao tbscheduledexcutelogdao;      @pointcut("@annotation(org.springframework.scheduling.annotation.scheduled)")       public void proxyaspect() {      }      @afterthrowing(pointcut="proxyaspect()",throwing="ex")     public void doexception(joinpoint joinpoint,exception ex){         object target = joinpoint.gettarget();         this.saveexception(target, ex);     }      public void saveexception(object target,exception ex){         try {             date date = new date();             tbscheduledexcutelog log = new tbscheduledexcutelog();             log.setclassname(target.getclass().getname());             log.setexcutedate(date);             log.setexcutetime(date);             log.setiserror(true);             log.seterrorinfo(exceptiontools.getexceptiondetails(ex).tostring());             if (target instanceof dxpscheduled) {                 dxpscheduled scheduled = (dxpscheduled) target;                 task task = scheduled.getclass().getannotation(task.class);                 log.setcontentname(task.value());             }             this.tbscheduledexcutelogdao.saveandcommit(log);         } catch (dxpexception e) {             e.printstacktrace();         }     } }

其中task注解为标注任务的名称，方便在数据库中保存。