Spring10_AOP

来源:https://www.cnblogs.com/codeaction/archive/2020/06/04/13047230.html
-Advertisement-
Play Games

本教程源碼請訪問：tutorial_demo 一、AOP概述 1.1、概念 AOP：全稱是Aspect Oriented Programming，即：面向切麵編程。 通過預編譯方式和運行期間動態代理實現程式功能的統一維護的一種技術。AOP是OOP的延續，是軟體開發中的一個熱點，也是Spring框架中 ...


本教程源碼請訪問：tutorial_demo

一、AOP概述

1.1、概念

AOP：全稱是Aspect Oriented Programming，即：面向切麵編程。

通過預編譯方式和運行期間動態代理實現程式功能的統一維護的一種技術。AOP是OOP的延續，是軟體開發中的一個熱點，也是Spring框架中的一個重要內容，是函數式編程的一種衍生範型。利用AOP可以對業務邏輯的各個部分進行隔離，從而使得業務邏輯各部分之間的耦合度降低，提高程式的可重用性，同時提高了開發的效率。

上面是百度百科上的概念，看看就行了。

簡單的說AOP是把我們程式重覆的代碼抽取出來，在需要執行的時候，使用動態代理的技術，在不修改源碼的基礎上，對我們已有的方法進行增強。

AOP用到了動態代理技術，這也是我們之前先學習動態代理的原因。

1.2、AOP相關術語

Joinpoint（連接點）：

連接點是指那些被攔截到的點。在Spring中，這些點指的是方法，因為Spring只支持方法類型的連接點。

Pointcut（切入點）：

切入點是指我們要對哪些Joinpoint進行攔截的定義。

Advice（通知/增強）：

通知是指攔截到Joinpoint之後所要做的事情就是通知 ，通知的類型：前置通知，後置通知，異常通知，最終通知，環繞通知。

Introduction（引介）：

引介是一種特殊的通知在不修改類代碼的前提下, Introduction 可以在運行期為類動態地添加一些方法或Field。

Target（目標對象）：

代理的目標對象。

Weaving（織入）：

是指把增強應用到目標對象來創建新的代理對象的過程。Spring採用動態代理織入，而 AspectJ採用編譯期織入和類裝載期織入。

Proxy（代理）：

一個類被AOP織入增強後，就產生一個結果代理類。

Aspect（切麵）：

切入點和通知（引介）的結合。

這些概念目前不需要全部掌握，只要知道連接點、切入點、通知/增強、目標對象、代理、切麵就可以了。

同時需要知道，在Spring中配置AOP就是配置在哪個切入點（哪個方法）上添加增強（通知），這其實就是配置切麵，不理解沒關係，後面學完案例，就明白了。

1.3、使用AOP需要做的事

  • 編寫核心業務代碼；
  • 將公共的代碼抽取出來，製作成通知；
  • 在配置中（XML或註解）中，聲明切入點與通知之間的關係，即切麵。

二、基於XML的AOP配置

需求：運行Service層方法時，列印日誌信息，使用AOP進行配置。

2.1、創建Maven工程

pom.xml文件配置如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.codeaction</groupId>
    <artifactId>aop</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.2.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.2.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13</version>
            <scope>test</scope>
        </dependency>
        <!-- AOP需要用到的包 -->
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.9.5</version>
        </dependency>
    </dependencies>
</project>

2.2、添加Service介面

package org.codeaction.service;

public interface IAccountService {
    void save();
    void update(int i);
    int delete();
}

註意這裡方法的參數和返回值類型，後面不同類型的方法會有不同的配置。不要在意方法定義是否合理，這隻是一個Demo程式。

2.3、添加Service介面實現類

package org.codeaction.service.impl;

import org.codeaction.service.IAccountService;

public class AccountServiceImpl implements IAccountService {
    @Override
    public void save() {
        System.out.println("save...");
    }

    @Override
    public void update(int i) {
        System.out.println("update...");
    }

    @Override
    public int delete() {
        System.out.println("delete...");
        return 0;
    }
}

不要在意方法定義是否合理，這隻是一個Demo程式。

2.4、添加日誌類

package org.codeaction.utils;

import org.aspectj.lang.ProceedingJoinPoint;

/**
 * 用於記錄日誌的類，這些都是公共代碼
 */
public class Logger {
    /**
     * 用於列印日誌：計劃讓其在切入點方法執行之前執行（切入點方法就是業務層方法）
     */
    public void printLog() {
        System.out.println("printLog....");
    }
}

2.5、添加Spring配置文件

<?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
       https://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        https://www.springframework.org/schema/aop/spring-aop.xsd">
    <!-- 配置srping的Ioc,把service對象配置進來 -->
    <bean id="accountService" class="org.codeaction.service.impl.AccountServiceImpl"></bean>

    <!-- 配置Logger類 -->
    <bean id="logger" class="org.codeaction.utils.Logger"></bean>
    
    <!--配置AOP-->
    <aop:config>
        <!--配置切麵 -->
        <aop:aspect id="logAdvice" ref="logger">
            <!-- 配置通知的類型，並且建立通知方法和切入點方法的關聯-->
            <aop:before
                method="printLog"
                pointcut="execution(public void org.codeaction.service.impl.AccountServiceImpl.save())"></aop:before>
         </aop:aspect>
    </aop:config>
</beans>

beans.xml是這篇教程的重點，在這個文件中對Spring中的AOP進行了配置。

Spring中基於XML的AOP配置步驟：

  1. Spring中除了Service交給Spring管理，通知Bean也要交給Spring來管理；

  2. 使用aop:config標簽開始AOP的配置；

  3. 使用aop:aspect標簽配置切麵。

    id屬性：為切麵提供一個唯一標識；

    ref屬性：指定通知類bean的id；

  4. 在aop:aspect標簽的內部使用對應標簽來配置通知的類型，目前我們希望讓printLog方法在切入點執行之前執行，所以是前置通知。

    aop:before：配置前置通知；

    method：指定哪個方法是前置通知；

    pointcut：指定切入點表達式，該表達式指的是對業務層中哪些方法增強。

  5. 切入點表達式的寫法：

    關鍵字：execution(表達式)；

    表達式：訪問修飾符 返回值 包名.包名.包名...類名.方法名(參數列表)；

    標準的表達式寫法：public void org.codeaction.service.impl.AccountServiceImpl.save()；

    訪問修飾符可以省略：void org.codeaction.service.impl.AccountServiceImpl.save()；

    返回值使用通配符，表示任意返回值：* org.codeaction.service.impl.AccountServiceImpl.save()；

    包名使用通配符，表示任意包。但是有幾級包，就需要寫幾個*：* *.*.*.*.AccountServiceImpl.save()；

    包名使用..表示當前包及其子包：* *..AccountServiceImpl.save()；

    類名和方法名都可以使用*來實現通配：* *..*.*()；

    參數列表：可以直接寫數據類型，基本類型直接寫名稱（int），引用類型寫包名.類名的方式（java.lang.String）。使用通配 符表示任意類型，但是必須有參數。使用..表示有無參數均可，有參數可以是任意類型。

    全通配寫法：* *..*.*(..)

    實際開發中切入點表達式的通常寫法：* org.codeaction.service.impl.*.*(..)。

2.6、添加測試方法

package org.codeaction.test;

import org.codeaction.service.IAccountService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:beans.xml")
public class MyTest {
    @Autowired
    private IAccountService accountService;

    @Test
    public void testSave() {
        accountService.save();
    }
}

運行測試方法testSave，控制台輸出如下：

printLog....
save...

我們看到通過我們的配置，實現了在切入點上添加增強。

我們還可以對切入點表達式進行修改，修改如下：

<aop:before method="printLog" pointcut="execution(* *..*.*(int))"></aop:before>

運行測試方法testSave，控制台輸出如下：

save...

我們看到通過我們的配置，save方法上沒有添加增強，原因是切入點表達式中參數為int類型和save方法不匹配。

三、配置切入點及五種通知

3.1、切入點

如果配置多個通知，並且每個切入點表達式都是相同的，那麼切入點表達式就會冗餘，我們可以通過配置的方式單獨定義切入點。

標簽：aop:pointcut；

作用：用於配置切入點表達式，就是指定對哪些類的哪些方法進行增強。

屬性：

​ expression：用於定義切入點表達式；

​ id：用於給切入點表達式提供一個唯一標識。

<aop:pointcut id="pt1" expression="execution(* org.codeaction.service.impl.*.*(..))"/>

此標簽寫在aop:aspect標簽內部只能當前切麵使用。它還可以寫在aop:aspect外面，此時就變成了所有切麵可用。

3.2、四種常用通知

3.2.1、前置通知

標簽：aop:before

作用：用於配置前置通知，指定增強的方法在切入點方法之前執行。

屬性：

​ method：指定通知類中的增強方法名稱；

​ pointcut-ref：指定切入點表達式的引用；

​ pointcut：指定切入點表達式。

執行時間點：切入點方法執行之前執行 。

3.2.2、後置通知

標簽：aop:after-returning

作用：用於配置後置通知。

屬性：

​ method：指定通知類中的增強方法名稱；

​ pointcut-ref：指定切入點表達式的引用；

​ pointcut：指定切入點表達式。

執行時間點：切入點方法正常執行之後，它和異常通知只能有一個執行 。

3.2.3、異常通知

標簽：after-throwing

作用：用於配置異常通知 。

屬性：

​ method：指定通知類中的增強方法名稱；

​ pointcut-ref：指定切入點表達式的引用；

​ pointcut：指定切入點表達式。

執行時間點：切入點方法執行產生異常後執行，它和後置通知只能執行一個 。

3.2.4、最終通知

標簽：aop:after

作用：用於配置最終通知。

屬性：

​ method：指定通知類中的增強方法名稱；

​ pointcut-ref：指定切入點表達式的引用；

​ pointcut：指定切入點表達式。

執行時間點：無論切入點方法執行時是否有異常，它都會在其後面執行。

3.2.5、案例

本案例在“基於XML的AOP配置”基礎上進行。

3.2.5.1、修改日誌類
package org.codeaction.utils;

import org.aspectj.lang.ProceedingJoinPoint;

/**
 * 用於記錄日誌的類，這些都是公共代碼
 */
public class Logger {
    /**
     * 前置通知
     */
    public void beforePrintLog() {
        System.out.println("beforePrintLog....");
    }

    /**
     * 後置通知
     */
    public void AfterReturningPrintLog() {
        System.out.println("AfterReturningPrintLog....");
    }

    /**
     * 異常通知
     */
    public void AfterThrowingPrintLog() {
        System.out.println("AfterThrowingPrintLog....");
    }

    /**
     * 最終通知
     */
    public void AfterPrintLog() {
        System.out.println("AfterPrintLog....");
    }
}
3.2.5.2、修改Spring的配置文件
<?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
       https://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        https://www.springframework.org/schema/aop/spring-aop.xsd">
    <!-- 配置srping的Ioc,把service對象配置進來 -->
    <bean  id="accountService" class="org.codeaction.service.impl.AccountServiceImpl"></bean>

    <!-- 配置Logger類 -->
    <bean id="logger" class="org.codeaction.utils.Logger"></bean>

    <!--配置AOP-->
    <aop:config>
        <!-- 切入點 -->
        <aop:pointcut id="pt1" expression="execution(* org.codeaction.service.impl.*.*(..))"/>
        <!--配置切麵 -->
        <aop:aspect id="logAdvice" ref="logger">
            <!-- 前置通知 -->
            <aop:before method="beforePrintLog" pointcut-ref="pt1"></aop:before>
            <!-- 後置通知 -->
            <aop:after-returning method="AfterReturningPrintLog" pointcut-ref="pt1"></aop:after-returning>
            <!-- 異常通知 -->
            <aop:after-throwing method="AfterThrowingPrintLog" pointcut-ref="pt1"></aop:after-throwing>
            <!-- 最終通知 -->
            <aop:after method="AfterPrintLog" pointcut-ref="pt1"></aop:after>
         </aop:aspect>
    </aop:config>
</beans>

運行測試方法testSave，控制台輸出如下：

beforePrintLog....
save...
AfterReturningPrintLog....
AfterPrintLog....

前置通知、後置通知、最終通知、業務方法裡面的內容都能夠正常輸出。

3.2.5.3、修改Service實現類中的的save方法
public void save() {
    System.out.println("save...");
    int i = 100 / 0;//人為的製造異常
}

運行測試方法testSave，控制台輸出如下：

beforePrintLog....
save...
AfterThrowingPrintLog....
AfterPrintLog....

java.lang.ArithmeticException: / by zero

前置通知、異常通知、最終通知、業務方法裡面的內容及異常信息都能夠正常輸出。

3.3、環繞通知

標簽：aop:around；

作用：用於配置環繞通知；

屬性：

​ method：指定通知類中的增強方法名稱；

​ pointcut-ref：指定切入點表達式的引用；

​ pointcut：指定切入點表達式。

說明：Spring框架為我們提供的一種可以在代碼中手動控制增強代碼什麼時候執行的方式。

註意：通常情況下，環繞通知都是獨立使用的。

3.3.1、修改日誌類添加環繞通知代碼

/**
 * 環繞通知
 */
public Object AroundPrintLog(ProceedingJoinPoint pjt) {
    Object returnValue = null;
    try {
        System.out.println("前置通知...");
        //獲取參數
        Object[] args = pjt.getArgs();
        //調用業務層代碼
        returnValue = pjt.proceed(args);
        System.out.println("後置通知...");
    } catch (Throwable t) {
        t.printStackTrace();
        System.out.println("異常通知...");
    } finally {
        System.out.println("最終通知...");
    }
    return returnValue;
}

我們在日誌類中添加了環繞通知的代碼。

Spring框架為我們提供了一個介面：ProceedingJoinPoint。該介面有一個方法proceed()，此方法就相當於明確調用切入點方法。該介面可以作為環繞通知的方法參數，在程式執行時，Spring框架會為我們提供該介面的實現類供我們使用。

3.3.2、修改Spring的配置文件

<?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
       https://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        https://www.springframework.org/schema/aop/spring-aop.xsd">
    <!-- 配置srping的Ioc,把service對象配置進來 -->
    <bean  id="accountService" class="org.codeaction.service.impl.AccountServiceImpl"></bean>

    <!-- 配置Logger類 -->
    <bean id="logger" class="org.codeaction.utils.Logger"></bean>

    <!--配置AOP-->
    <aop:config>
        <!-- 切入點 -->
        <aop:pointcut id="pt1" expression="execution(* org.codeaction.service.impl.*.*(..))"/>
        <!--配置切麵 -->
        <aop:aspect id="logAdvice" ref="logger">
            <!-- 前置通知 -->
            <!--<aop:before method="beforePrintLog" pointcut-ref="pt1"></aop:before>-->
            <!-- 後置通知 -->
            <!--<aop:after-returning method="AfterReturningPrintLog" pointcut-ref="pt1"></aop:after-returning>-->
            <!-- 異常通知 -->
            <!--<aop:after-throwing method="AfterThrowingPrintLog" pointcut-ref="pt1"></aop:after-throwing>-->
            <!-- 最終通知 -->
            <!--<aop:after method="AfterPrintLog" pointcut-ref="pt1"></aop:after>-->
            <!-- 環繞通知 -->
            <aop:around method="AroundPrintLog" pointcut-ref="pt1"></aop:around>
         </aop:aspect>
    </aop:config>
</beans>

在Spring的配置文件中，我們添加了環繞通知，註釋掉了其它四種通知，因為環繞通知通常情況下都是獨立使用的。

運行測試方法testSave，控制台輸出如下：

前置通知...
save...
後置通知...
最終通知...

按照3.2.5.3中的方式修改save方法，人為製造異常，控制台輸出如下：

前置通知...
save...
java.lang.ArithmeticException: / by zero
	at org.codeaction.service.impl.AccountServiceImpl.save(AccountServiceImpl.java:9)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:344)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:198)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
	at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:100)
	at org.codeaction.utils.Logger.AroundPrintLog(Logger.java:47)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:644)
	at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:633)
	at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:70)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
	at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:95)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
	at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:212)
	at com.sun.proxy.$Proxy15.save(Unknown Source)
	at org.codeaction.test.MyTest.testSave(MyTest.java:18)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
	at org.springframework.test.context.junit4.statements.RunBeforeTestExecutionCallbacks.evaluate(RunBeforeTestExecutionCallbacks.java:74)
	at org.springframework.test.context.junit4.statements.RunAfterTestExecutionCallbacks.evaluate(RunAfterTestExecutionCallbacks.java:84)
	at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75)
	at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86)
	at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
	at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:251)
	at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:97)
	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
	at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
	at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
	at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
異常通知...
最終通知...
	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
	at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:190)
	at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
	at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
	at com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
	at com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:230)
	at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:58)

四、基於XML和註解的AOP配置

4.1、修改Service實現類

package org.codeaction.service.impl;

import org.codeaction.service.IAccountService;
import org.springframework.stereotype.Service;

@Service("accountService")
public class AccountServiceImpl implements IAccountService {
    @Override
    public void save() {
        System.out.println("save...");
        //int i = 100 / 0;
    }

    @Override
    public void update(int i) {
        System.out.println("update...");
    }

    @Override
    public int delete() {
        System.out.println("delete...");
        return 0;
    }
}

添加@Service註解，把AccountServiceImpl交給Spring容器管理。

4.2、修改日誌類

package org.codeaction.utils;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

@Component("logger")
@Aspect
public class Logger {

    @Pointcut("execution(* org.codeaction.service.impl.*.*(..))")
    private void pt(){}

    @Before("execution(* org.codeaction.service.impl.*.*(..))")
    public void beforePrintLog() {
        System.out.println("beforePrintLog....");
    }

    @AfterReturning("pt()")
    public void AfterReturningPrintLog() {
        System.out.println("AfterReturningPrintLog....");
    }

    @AfterThrowing("pt()")
    public void AfterThrowingPrintLog() {
        System.out.println("AfterThrowingPrintLog....");
    }

    @After("pt()")
    public void AfterPrintLog() {
        System.out.println("AfterPrintLog....");
    }

    //@Around("pt()")
    public Object AroundPrintLog(ProceedingJoinPoint pjt) {
        Object returnValue = null;
        try {
            //獲取參數
            Object[] args = pjt.getArgs();
            //調用業務層代碼
            System.out.println("前置通知...");
            returnValue = pjt.proceed();
            System.out.println("後置通知...");
        } catch (Throwable t) {
            t.printStackTrace();
            System.out.println("異常通知...");
        } finally {
            System.out.println("最終通知...");
        }

        return returnValue;
    }
}

添加@Component註解，把Logger交給Spring容器管理。

@Aspect用於把當前類聲明為切麵類。

@Pointcut用於指定切入點表達式。

@Before、@AfterReturning、@AfterThrowing、 @After、@Around分別用來配置前置通知、後置通知、異常通知、最終通知、環繞通知，它們都有value屬性，該屬性用來指定切入點表達式，還可以指定切入點表達式的引用。

4.3、修改Spring的配置文件

<?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"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd">
    <!-- 配置spring創建容器時要掃描的包 -->
    <context:component-scan base-package="org.codeaction"></context:component-scan>

    <!-- 配置spring開啟註解AOP的支持 -->
    <aop:aspectj-autoproxy></aop:aspectj-autoproxy>
</beans>

4.4、修改測試類

package org.codeaction.test;

import org.codeaction.service.IAccountService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:beans.xml")
public class MyTest {
    @Autowired
    private IAccountService accountService;

    @Test
    public void testSave() {
        accountService.save();
    }
}

在不開啟環繞通知的情況下，運行測試方法，控制台輸出如下：

beforePrintLog....
save...
AfterPrintLog....
AfterReturningPrintLog....

其他情況，大家可以自己測試一下。

五、基於純註解的AOP配置

純註解的情況，要完全拋棄Spring的XML配置文件。我們在上一節“基於XML和註解的AOP配置”代碼的基礎上進行配置，首先刪除配置文件beans.xml。

5.1、添加配置類

package org.codeaction.config;

import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableAspectJAutoProxy;

@Configuration
@ComponentScan(basePackages = "org.codeaction")
@EnableAspectJAutoProxy
public class MainConfig {
}

@EnableAspectJAutoProxy配置Spring開啟註解AOP的支持。

5.2、修改測試類

package org.codeaction.test;

import org.codeaction.config.MainConfig;
import org.codeaction.service.IAccountService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = MainConfig.class)
public class MyTest {
    @Autowired
    private IAccountService accountService;

    @Test
    public void testSave() {
        accountService.save();
    }
}

在不開啟環繞通知的情況下，運行測試方法，控制台輸出如下：

beforePrintLog....
save...
AfterPrintLog....
AfterReturningPrintLog....

其他情況，大家可以自己測試一下。

六、AOP實戰

在上一篇教程中，我們將Apache Commons DbUtils實現單表的CRUD操作的代碼進行了修改，使用動態代理的方式使其支持事務操作。我們使用動態代理在不改變Service層實現類方法代碼的前提下，對方法的功能進行了增強，接下來我們使用Spring提供的AOP的方式完成相同的功能，我們的代碼在上一篇文章實戰部分代碼的基礎上進行，首先刪除org.codeaction.proxy包及其下麵的所有內容。

6.1、修改JdbcConfig配置類

package org.codeaction.util;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;

@Component
@Aspect
public class JdbcUtils {
    private static DataSource dataSource;
    private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
    //獲取連接池對象
    public static DataSource getDataSource() {
        return dataSource;
    }

    @Autowired
    public void setDataSource(DataSource dataSource) {
        JdbcUtils.dataSource = dataSource;
    }

    @Pointcut("execution(* org.codeaction.service.impl.*.*(..))")
    public void pt() {

    }

    //獲取連接
    public static Connection getConnection() throws SQLException {
        Connection conn = tl.get();
        if(conn == null) {
            return dataSource.getConnection();
        }
	return conn;
    }
    //開啟事務
    @Before("pt()")
    public static void beginTransaction() throws SQLException {
        Connection conn = tl.get();
        if(conn != null) {
            throw new SQLException("已經開啟事務，不能重覆開啟");
	}
	conn = getConnection();
	conn.setAutoCommit(false);
	tl.set(conn);
    }
    //提交事務
    @AfterReturning("pt()")
    public static void commitTransaction() throws SQLException {
        Connection conn = tl.get();
	if(conn == null) {
	    throw new SQLException("連接為空，不能提交事務");
	}
	conn.commit();
	conn.close();
	tl.remove();
    }
    //回滾事務
    @AfterThrowing("pt()")
    public static void rollbackTransaction() throws SQLException {
        Connection conn = tl.get();
        if (conn == null) {
            throw new SQLException("連接為空，不能回滾事務");
	}
	conn.rollback();
	conn.close();
	tl.remove();
    }

    //@Around("pt()")
    public static Object around(ProceedingJoinPoint pjt) throws SQLException {
        Object returnValue = null;
	
        try {
            JdbcUtils.beginTransaction();
            Object[] args = pjt.getArgs();
            returnValue = pjt.proceed(args);
            JdbcUtils.commitTransaction();
        } catch (Throwable throwable) {
            throwable.printStackTrace();
            JdbcUtils.rollbackTransaction();
        }
	
        return returnValue;
    }
}

聲明當前類為切麵類，並配置通知。

6.2、修改主配置類

package org.codeaction.config;

import org.springframework.context.annotation.*;

@Configuration
@ComponentScan(basePackages = "org.codeaction")
@PropertySource("classpath:jdbc.properties")
@Import(JdbcConfig.class)
@EnableAspectJAutoProxy
public class MyConfig {

}

配置開啟註解支持。

運行轉賬測試方法，能夠正常完成轉賬操作；認為製造異常，能夠回滾。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • echarts圖表在Tab頁中width: 100%失效導致的第一個Tab頁之後的Tab頁圖表不能正常顯示的問題
    解決Tab切換echarts圖表不能正常顯示問題： // 繪圖div父容器的寬度 let w = $('.figure').width(); $('#fig-t').css('width', w); // 獲取父容器的寬度直接賦值給圖表以達到寬度100%的效果 $('#fig-f').css('wi ...
  • vue 學習筆記--全局api- Vue.directive
    Vue.directive 1.作用： 使用vue 函數構造自定義方法。 2.基本概念： 在主函數中構造自定義方法 併在模板中使用 構造方法： Vue.directive('demo',function(el,binding,vnode){ el.style='color:'+binding.val ...
  • Vue樣式穿透
    在開發中修改第三方組件樣式是很常見，但由於 scoped 屬性的樣式隔離，可能需要去除 scoped 或是另起一個 style 。 這些做法都會帶來副作用（組件樣式污染、不夠優雅），樣式穿透在css預處理器中使用才生效。 我們可以使用 >>> 或 /deep/ 解決這一問題: <style scop ...
  • svg高級應用及動畫
    canvas 和 webGL 這兩項圖形技術結合 css3 可以說能完成絕大部分的動畫和需求。但 canvas 和 webGL 畢竟是偏向底層的繪製引擎，某些場景使用起來還是過於繁瑣的，不分場合一律使用錘子解決的行為不值得提倡。svg 在解決排版，圖標，相關動畫還是非常高效的，而且 svg 還是矢量 ...
  • 大數據數據倉庫架構設計基礎概念和設計思想整理
    一、ODS層ODS 全稱是 Operational Data Store，一般對應的是操作性數據存儲，直接面向主題的，也叫數據運營層，通常是最接近數據源中數據的一層，數據源中的數據，經過抽取、洗凈、傳輸，也就是通常說的 ETL 之後的數據存入本層。本層的數據，總體上大多是按照源頭業務系統的分類方式而 ...
  • 比較全的常見的架構設計思想整理
    一、MPP 架構 1、MPP架構的基礎概念 MPP (Massively Parallel Processing)，即大規模並行處理，在資料庫非共用集群中，每個節點都有獨立的磁碟存儲系統和記憶體系統，業務數據根據資料庫模型和應用特點劃分到各個節點上，每台數據節點通過專用網路或者商業通用網路互相連接，彼 ...
  • 系統梳理一下鎖
    背景 有人對Java主流鎖做了下麵全面的梳理。梳理的確實挺好的。但是我看到這張圖，第一個感覺是：記不住。 因為分了太多類，彼此之間沒有什麼聯繫。做PPT可以。如果聊天或者面試，不用紙筆的情況下，就不太好描述了。也不利於對原理和應用的理解。 基於上述的考慮，我就自己系統的梳理一下鎖，希望可以有助於大家 ...
  • Java連載120-反射機制獲取構造方法和父類、父介面
    一、使用反射機制來 （1）獲取一個類； （2）獲取類的構造函數 （3）通過構造函數來獲取一個對象 package com.bjpowernode.java_learning; import java.lang.reflect.*; ​ public class D120_1_ConstructerO ...
一周排行
    -Advertisement-
    Play Games
  • WPF 已知問題 監聽 WMI 事件導致觸摸失效
    示例項目結構 在 Visual Studio 中創建一個 WinForms 應用程式後，項目結構如下所示： MyWinFormsApp/ │ ├───Properties/ │ └───Settings.settings │ ├───bin/ │ ├───Debug/ │ └───Release/ ...
  • [STAThread]特性
    [STAThread] 特性用於需要與 COM 組件交互的應用程式，尤其是依賴單線程模型（如 Windows Forms 應用程式）的組件。在 STA 模式下，線程擁有自己的消息迴圈，這對於處理用戶界面和某些 COM 組件是必要的。 [STAThread] static void Main(stri ...
  • UWP WinUI3 傳入 AddHandler 的 RoutedEventHandler 類型與事件所需不匹配將拋出參數異常
    在WinForm中使用全局異常捕獲處理 在WinForm應用程式中，全局異常捕獲是確保程式穩定性的關鍵。通過在Program類的Main方法中設置全局異常處理，可以有效地捕獲並處理未預見的異常，從而避免程式崩潰。 註冊全局異常事件 [STAThread] static void Main() { / ...
  • .NET 多版本 WinForm 開源控制項庫 SunnyUI
    前言 給大家推薦一款開源的 Winform 控制項庫，可以幫助我們開發更加美觀、漂亮的 WinForm 界面。 項目介紹 SunnyUI.NET 是一個基於 .NET Framework 4.0+、.NET 6、.NET 7 和 .NET 8 的 WinForm 開源控制項庫，同時也提供了工具類庫、擴展 ...
  • .net core8 使用Swagger（附當前源碼）
    說明 該文章是屬於OverallAuth2.0系列文章，每周更新一篇該系列文章（從0到1完成系統開發）。 該系統文章，我會儘量說的非常詳細，做到不管新手、老手都能看懂。 說明：OverallAuth2.0 是一個簡單、易懂、功能強大的許可權+可視化流程管理系統。 有興趣的朋友，請關註我吧(*^▽^*) ...
  • WPF 什麼時候 VisualTreeHelper.GetDescendantBounds 將返回無窮大
    一、下載安裝 1.下載git 必須先下載並安裝git，再TortoiseGit下載安裝 git安裝參考教程：https://blog.csdn.net/mukes/article/details/115693833 2.TortoiseGit下載與安裝 TortoiseGit，Git客戶端，32/6 ...
  • C# 開源教程帶你輕鬆掌握數據結構與演算法
    前言 在項目開發過程中，理解數據結構和演算法如同掌握蓋房子的秘訣。演算法不僅能幫助我們編寫高效、優質的代碼，還能解決項目中遇到的各種難題。 給大家推薦一個支持C#的開源免費、新手友好的數據結構與演算法入門教程：Hello演算法。 項目介紹 《Hello Algo》是一本開源免費、新手友好的數據結構與演算法入門 ...
  • 第22篇 生成proto文件bat腳本
    1.生成單個Proto.bat內容 @rem Copyright 2016, Google Inc. @rem All rights reserved. @rem @rem Redistribution and use in source and binary forms, with or with ...
  • 記一次 .NET某上位機視覺程式 卡死分析
    一：背景 1. 講故事 前段時間有位朋友找到我，說他的窗體程式在客戶這邊出現了卡死，讓我幫忙看下怎麼回事？dump也生成了，既然有dump了那就上 windbg 分析吧。 二：WinDbg 分析 1. 為什麼會卡死 窗體程式的卡死，入口門檻很低，後續往下分析就不一定了，不管怎麼說先用 !clrsta ...
  • 醫學DICOM文件與PACS系統進行數據傳輸
    前言 人工智慧時代，人臉識別技術已成為安全驗證、身份識別和用戶交互的關鍵工具。 給大家推薦一款.NET 開源提供了強大的人臉識別 API，工具不僅易於集成，還具備高效處理能力。 本文將介紹一款如何利用這些API，為我們的項目添加智能識別的亮點。 項目介紹 GitHub 上擁有 1.2k 星標的 C# ...
所有分類