SpringBean中Aop的使用方法

本篇內(nèi)容主要講解“SpringBean中Aop的使用方法”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“SpringBean中Aop的使用方法”吧!

SpringAOP

什么是Aop編程

Aop面向切面編程，在方法之前和之后實(shí)現(xiàn)處理 應(yīng)用場景在于：日志打印、事務(wù)實(shí)現(xiàn)、安全等。

因?yàn)锳OP可以解決我們程序上的代碼冗余問題

Spring的AOP

前置通知

后置通知

環(huán)繞通知

運(yùn)行通知

異常通知

Aop編程底層的原理

動(dòng)態(tài)代理技術(shù)

• 基于Jdk實(shí)現(xiàn)InvocationHandler 底層使用反射技術(shù)

• 基于CGLIB實(shí)現(xiàn) 字節(jié)碼技術(shù)

基于注解方式啟動(dòng)Aop

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.0.5.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.aspectj</groupId>
        <artifactId>aspectjweaver</artifactId>
        <version>1.8.13</version>
    </dependency>
</dependencies>

日志AOP

@Aspect//定義切面類@Component//注入spring容器@EnableAspectJAutoProxy//開啟AOPpublic class LogAop {
    //定義切入點(diǎn),表示開始攔截的入口
    @Pointcut("execution (* com.xuyu.service..*.*(..))")
    public void logAop(){

    }
    @Before("logAop()")
    public void doBefor(){
        System.out.println("前置通知....在調(diào)用方法之前攔截");
    }
    @After("logAop()")
    public void doAfter(){
        System.out.println("后置通知....在調(diào)用方法之后攔截");
    }
}

Config

@Configuration@ComponentScan(basePackages = {"com.xuyu.service","com.xuyu.aop"})
public class MyConfig {
}

service

@Component
public class OrderService {

    public void addOrder(){
        System.out.println("執(zhí)行目標(biāo)方法....");
    }
}

啟動(dòng)類

public class App {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(MyConfig.class);
        OrderService orderService = applicationContext.getBean("orderService", OrderService.class);
        orderService.addOrder();
    }
}

執(zhí)行結(jié)果

前置通知....在調(diào)用方法之前攔截
執(zhí)行目標(biāo)方法....
后置通知....在調(diào)用方法之后攔截

我們開始分析下源碼

所以我們可以直接使用@Import注解把AspectJAutoProxyRegistrar這個(gè)類注入IOC容器中

@Import(AspectJAutoProxyRegistrar.class)

等價(jià)于這個(gè)注解

@EnableAspectJAutoProxy//開啟AOP

完整的五個(gè)通知

@Aspect//定義切面類
@Component//注入spring容器
@EnableAspectJAutoProxy//開啟AOP
public class LogAop {    //定義切入點(diǎn),表示開始攔截的入口@Pointcut("execution (* com.xuyu.service..*.*(..))")
    public void logAop(){

    }
    @Before("logAop()")
    public void doBefore(){
        System.out.println("前置通知....在調(diào)用方法之前攔截");
    }
    @After("logAop()")
    public void doAfter(){
        System.out.println("后置通知....在調(diào)用方法之后攔截");
    }
    @AfterReturning("logAop()")
    public void  around(JoinPoint joinpoint) throws Throwable {
        String name = joinpoint.getSignature().getName();
        System.out.println("返回通知...."+name);
    }
    @AfterThrowing("logAop()")
    public void afterThrowing(JoinPoint joinPoint) {
        System.out.println("異常通知....");
    }
    @Around("logAop()")
    public void doAround(ProceedingJoinPoint joinPoint) throws Throwable {
        System.out.println("環(huán)繞通知，在目標(biāo)方法之前處理....");
        joinPoint.proceed();//執(zhí)行目標(biāo)方法
        System.out.println("環(huán)繞通知，在目標(biāo)方法之后處理....");
    }
}

打印結(jié)果

環(huán)繞通知，在目標(biāo)方法之前處理....
前置通知....在調(diào)用方法之前攔截
目標(biāo)方法執(zhí)行....
環(huán)繞通知，在目標(biāo)方法之后處理....
后置通知....在調(diào)用方法之后攔截
返回通知....addOrder

springBoot手動(dòng)事務(wù)實(shí)現(xiàn)方式

手動(dòng)begin commit rollback

@Component
public class TransactionalUtils {
    //TransactionAspectSupport currentTransactionStatus().setRollbackOnly();
    /**
     * 獲取當(dāng)前事務(wù)管理器
     */
    @Autowired
    private DataSourceTransactionManager dataSourceTransactionManager;

    public TransactionStatus begin() {
        TransactionStatus transaction = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
        System.out.println("獲取當(dāng)前的事務(wù)>>>>>");
        return transaction;
    }
    /**
     * 提交事務(wù)
     */
    public void commit(TransactionStatus transactionStatus) {
        System.out.println("提交當(dāng)前的事務(wù)>>>>>");
        dataSourceTransactionManager.commit(transactionStatus);
    }
    public void rollback(TransactionStatus transactionStatus) {
        System.out.println("回滾當(dāng)前的事務(wù)>>>>>");
        dataSourceTransactionManager.rollback(transactionStatus);
    }
}

@Service
public class OrderService {
    @Autowired
    private OrderInfoMapper orderInfoMapper;
    @Autowired
    private TransactionalUtils transactionalUtils;


        public int addOrderInfo(int j) {
        TransactionStatus begin = transactionalUtils.begin();
        try {
            int i = orderInfoMapper.addOrderInfo();
            int result = 1 / j;
            transactionalUtils.commit(begin);
        } catch (Exception e) {
            e.printStackTrace();
            transactionalUtils.rollback(begin);
        }
        return 1;
    }

手動(dòng)begin commit rollback代碼會(huì)冗余，所以我們使用AOP重構(gòu)下手動(dòng)事務(wù)

使用SpringAop實(shí)現(xiàn)重構(gòu)實(shí)現(xiàn)聲明式事務(wù)

@Aspect
@Component
@Scope("prototype")//單例會(huì)有問題，這里設(shè)置為多例
public class TransactionalAop {
    //Aspect 定義切點(diǎn)類
    @Autowired
    private TransactionalUtils transactionalUtils;
    /**
     * @Pointcut 定義切入點(diǎn)
     */
    @Pointcut("execution (* com.mayikt.service..*.*(..))")
    public void transactionalAop() {
    }
    @Around("transactionalAop()")
    public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
        // 獲取方法名稱
        String methodName = joinPoint.getSignature().getName();
        // 獲取目標(biāo)對象
        Class<?> classTarget = joinPoint.getTarget().getClass();
        // 獲取目標(biāo)對象類型
        Class<?>[] par = ((MethodSignature) joinPoint.getSignature()).getParameterTypes();
        // 獲取目標(biāo)對象方法
        Method objMethod = classTarget.getMethod(methodName, par);
        // 判斷該目標(biāo)方法上是否有加上自定義事務(wù)注解
        ExtTransactional extTransactional = objMethod.getDeclaredAnnotation(ExtTransactional.class);
        if (extTransactional == null) {
            return joinPoint.proceed();// 執(zhí)行目標(biāo)方法
        }
        TransactionStatus begin = transactionalUtils.begin();
        try {
            System.out.println(">>>>環(huán)繞通知之前執(zhí)行...>>>>>>");
            Object proceed = joinPoint.proceed();// 執(zhí)行目標(biāo)方案
            System.out.println(">>>>環(huán)繞通知之后執(zhí)行...>>>>>>");
            transactionalUtils.commit(begin);
            return proceed;
        } catch (Exception e) {
            // 目標(biāo)方法拋出異常的情況下 回滾當(dāng)前事務(wù)
            transactionalUtils.rollback(begin);
            return 0;
        }
    }
}

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface  ExtTransactional {
}

@ExtTransactional
public int addOrderInfo(int j) {
    int i = orderInfoMapper.addOrderInfo();
    return i;
}

注意的問題 如果在service 層 拋出異常的情況下 最好使用  TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

到此，相信大家對“SpringBean中Aop的使用方法”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！