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
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類