如何通過AOP環繞通知如何實現事務控制

小編給大家分享一下如何通過AOP環繞通知如何實現事務控制，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！

通過AOP環繞通知實現事務控制

1、導入相關的依賴

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.0.2.RELEASE</version>
    </dependency>
    <dependency>
         <groupId>c3p0</groupId>
         <artifactId>c3p0</artifactId>
         <version>0.9.1.2</version>
     </dependency>
     <dependency>
          <groupId>org.aspectj</groupId>
          <artifactId>aspectjweaver</artifactId>
          <version>1.8.7</version>
      </dependency>
</dependencies>

2、配置連接池和開啟AOP注解

以下采用的是xml配置方式，當然也可以使用純注解配置

<!-- 配置數據源 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    <!--連接數據庫的必備信息-->
    <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
    <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test"></property>
    <property name="user" value="root"></property>
    <property name="password" value="root"></property>
</bean>
<!--開啟spring對注解AOP的支持-->
<aop:aspectj-autoproxy></aop:aspectj-autoproxy>

2、創建鏈接工具類

package com.gzl.utils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.sql.DataSource;
import java.sql.Connection;
/**
 * 連接的工具類，它用于從數據源中獲取一個連接，并且實現和線程的綁定
 */
@Component("connectionUtils")
public class ConnectionUtils {
    private ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
    @Autowired
    private DataSource dataSource;
    /**
     * 獲取當前線程上的連接
     * @return
     */
    public Connection getThreadConnection() {
        try{
            //1.先從ThreadLocal上獲取
            Connection conn = tl.get();
            //2.判斷當前線程上是否有連接
            if (conn == null) {
                //3.從數據源中獲取一個連接，并且存入ThreadLocal中
                conn = dataSource.getConnection();
                tl.set(conn);
            }
            //4.返回當前線程上的連接
            return conn;
        }catch (Exception e){
            throw new RuntimeException(e);
        }
    }
    /**
     * 把連接和線程解綁
     */
    public void removeConnection(){
        tl.remove();
    }
}

3、AOP環繞事務類

package com.gzl.utils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
 * 和事務管理相關的工具類，它包含了，開啟事務，提交事務，回滾事務和釋放連接
 */
@Component("txManager")
@Aspect
public class TransactionManager {
    @Autowired
    private ConnectionUtils connectionUtils;
  /**
     * 需要進行事務控制的類或者方法，EL表達式配置
     */
    @Pointcut("execution(* com.gzl.service.impl.*.*(..))")
    private void pt1(){}
    /**
     * 開啟事務
     */
    public  void beginTransaction(){
        try {
            connectionUtils.getThreadConnection().setAutoCommit(false);
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    /**
     * 提交事務
     */
    public  void commit(){
        try {
            connectionUtils.getThreadConnection().commit();
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    /**
     * 回滾事務
     */
    public  void rollback(){
        try {
            connectionUtils.getThreadConnection().rollback();
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    /**
     * 釋放連接
     */
    public  void release(){
        try {
            connectionUtils.getThreadConnection().close();//還回連接池中
            connectionUtils.removeConnection();
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    @Around("pt1()")
    public Object aroundAdvice(ProceedingJoinPoint pjp){
        Object rtValue = null;
        try {
            //1.獲取參數
            Object[] args = pjp.getArgs();
            //2.開啟事務
            this.beginTransaction();
            //3.執行方法
            rtValue = pjp.proceed(args);
            //4.提交事務
            this.commit();
            //返回結果
            return  rtValue;
        }catch (Throwable e){
            //5.回滾事務
            this.rollback();
            throw new RuntimeException(e);
        }finally {
            //6.釋放資源
            this.release();
        }
    }
}

spring AOP 環繞通知的思路

環繞通知Around Advice就是在指定的程序前后均執行相關的服務，設計思路如下：

1、設計一個接口

package com.spring.service;
public interface IComponent { 
public void bussiness1();
public void bussiness2();
public void bussiness3();
}

2、編寫這個接口的實現

package com.spring.service;
public class Component implements IComponent{
 @Override
 public void bussiness1() {
  // TODO Auto-generated method stub
  System.out.println("這是業務1");
 }
 @Override
 public void bussiness2() {
  // TODO Auto-generated method stub
  System.out.println("這是業務2");
 }
 @Override
 public void bussiness3() {
  // TODO Auto-generated method stub
  System.out.println("這是業務3");
 }
}

3、編寫前置通知的邏輯代碼

該代碼必須實現org.aopalliance.intercept.Method Interceptor接口，需要的服務都寫在這里。

4、編寫XML配置文件

通過代理來實現AOP的環繞通知，看一下org.aopalliance.intercept.MethodInterceptor接口的源代碼。該接口不是Spring內部的接口，而是AOP Alliance標準所指定的，不過Spring對這個接口有一個具體的實現過程，同時該接口相融所有遵守AOP Alliance標準的所有AOP框架。

環繞通知相當于前置通知和后置通知的結合，不同的是在MethodInterceptor的invoke（）方法中，可以自由地使用MethodInvocation提供的proceed（）方法來執行目標對象的方法，同時proceed（）方法將會返回目標方法執行后的返回結果，在invoke方法結束前還可以修改該結果，下面還是以上面的那個例子來示范一下環繞通知的應用。

編寫一個環繞通知的類，該類實現MethodInterceptor接口。這里調用了MethodInvocation的proceed（）方法，也就是說，調用了目標對象Component中的business1等方法，在這個方法的前后分別增加了驗證和通知執行，接著修改一下配置文件，去掉前置通知和后置通知的配置，只需要將這個環繞通知添加進去就可以了，具體代碼如下：

這里只需要配置一個環繞通知的Bean，并且將這個Bean配置到interceptorNames中就完成了所有的工作，測試代碼與前面的相同，可以看到結果也與前面的相同。

看完了這篇文章，相信你對“如何通過AOP環繞通知如何實現事務控制”有了一定的了解，如果想了解更多相關知識，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！