[AOP攔截 ]SpringBoot+Quartz Aop攔截Job類中的方法

​ 最近在工作使用boot+quartz整合,開發定時調度平台，遇到需要對Quartz的Job進行異常后將異常記錄到日志表的操作，第一反應就想到了使用Spring的AOP，利用AfterThrowing來完成這個操作。

話不多說，直接上代碼：

 

<!--整合Quartz-->
<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

1.正常的一個job類：

2. 創建JobBeanFactory類，重寫 SpringBeanJobFactory 的方法。

import org.quartz.SchedulerContext;
import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.BeanWrapper;
import org.springframework.beans.MutablePropertyValues;
import org.springframework.beans.PropertyAccessorFactory;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.lang.Nullable;
import org.springframework.scheduling.quartz.SpringBeanJobFactory;

/**
 * @Author: Hujh
 * @Date: 2019/7/5 9:38
 * @Description:  配置job工廠
 */
public class JobBeanFactory extends SpringBeanJobFactory{

    @Nullable
    private String[] ignoredUnknownProperties;

    @Nullable
    private SchedulerContext schedulerContext;


    private final BeanFactory beanFactory;


    JobBeanFactory(BeanFactory beanFactory){
        this.beanFactory = beanFactory;
    }


    public void setIgnoredUnknownProperties(String... ignoredUnknownProperties) {
        this.ignoredUnknownProperties = ignoredUnknownProperties;
    }

    @Override
    public void setSchedulerContext(SchedulerContext schedulerContext) {
        this.schedulerContext = schedulerContext;
    }


    /**
     * @Title: createJobInstance
     * @Author : Hujh
     * @Date: 2019/7/5 10:19
     * @Description : 創建調度工作接口
     * @param : bundle
     * @Return : java.lang.Object
     */
    @Override
    protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
        Class<?> jobClass = bundle.getJobDetail().getJobClass();
        Object job = beanFactory.getBean(jobClass);
        if (isEligibleForPropertyPopulation(job)) {
            BeanWrapper bw = PropertyAccessorFactory.forBeanPropertyAccess(job);
            MutablePropertyValues pvs = new MutablePropertyValues();
            if (this.schedulerContext != null) {
                pvs.addPropertyValues(this.schedulerContext);
            }
            pvs.addPropertyValues(bundle.getJobDetail().getJobDataMap());
            pvs.addPropertyValues(bundle.getTrigger().getJobDataMap());
            if (this.ignoredUnknownProperties != null) {
                for (String propName : this.ignoredUnknownProperties) {
                    if (pvs.contains(propName) && !bw.isWritableProperty(propName)) {
                        pvs.removePropertyValue(propName);
                    }
                }
                bw.setPropertyValues(pvs);
            }
            else {
                bw.setPropertyValues(pvs, true);
            }
        }
        return job;
    }
}

3.創建 QuartzConfig類，交給spring容器進行管理

import org.springframework.beans.BeansException;
import org.springframework.boot.autoconfigure.quartz.SchedulerFactoryBeanCustomizer;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author: Hujh
 * @Date: 2019/7/5 9:39
 * @Description: Quartz相關配置類
 */
@Configuration
public class QuartzConfig implements ApplicationContextAware {

    private ApplicationContext applicationContext;

    @Bean
    public SchedulerFactoryBeanCustomizer schedulerFactoryBeanCustomizer() {
        // Spring 項目整合 Quartz  主要依靠添加 SchedulerFactoryBean 這個 FactoryBean
        return schedulerFactoryBean -> schedulerFactoryBean.setJobFactory(new JobBeanFactory(applicationContext));
    }

    /**
     * 初始化加載applicationContext
     */
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
}

4. 創建AOP攔截：JobLogAop

 <!-- aop依賴 -->
 <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-aop</artifactId>
 </dependency>

 

 2 
import org.aspectj.lang.annotation.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

/**
 * @Author: Hujh
 * @Date: 2019/7/4 17:12
 * @Description: 工作調度任務攔截 (日志記錄)
 */
@Component
@Aspect
public class JobLogAop {

    private Logger logger = LoggerFactory.getLogger(JobLogAop.class);

    /**
     * 只對於execute切入
     */
    @Pointcut("execution(public void com.ylsp.jobs..*.execute(..))")
    public void pointJobLog(){}

    /**
     * 切點通知(方法執行后)
     */
    @AfterReturning("pointJobLog()")
    public void handlerControllerMethod() {
        logger.info("execute方法執行后..---->> 開始寫入日志");
    }


}

 

  注：直接創建一個Job,可以看到Aop已經生效。