Springboot使用PlatformTransactionManager接口的事務處理

1、SpringBoot中可以使用PlatformTransactionManager接口來實現事務的統一控制，而進行控制的時候也可以采用注解或者AOP切面配置形式來完成，建議進行Aop切面進行事務管理，但是要寫好注釋，不然一些人后期找代碼邏輯很容易看懵逼的。

在業務層的方法上啟用事務控制，可以加到方法上，也可以加到該業務類上，根據自己的需求來進行。

package com.demo.service.impl;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.demo.dao.UserDao;
import com.demo.po.UserInfo;
import com.demo.service.UserService;

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserDao userDao;

    /**
     * 在業務層的方法上啟用事務管理
     */
    @Transactional(propagation = Propagation.REQUIRED, readOnly = true)
    @Override
    public List<UserInfo> findAll() {
        
        return userDao.findAll();
    }

}

在程序主類中還需要配置事務管理注解，使用注解@EnableTransactionManagement開啟事務。

package com.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.transaction.annotation.EnableTransactionManagement;

@SpringBootApplication // 啟動Springboot程序，而后自帶子包掃描
@EnableJpaRepositories(basePackages = "com.demo.dao")
@EnableTransactionManagement // 啟動事務管理
public class DemoApplication {

    public static void main(String[] args) {
        // 啟動Springboot程序
        SpringApplication.run(DemoApplication.class, args);
    }

}

如果在業務層中定義@Transactional注解實現事務的控制，全部使用注解控制必然會造成代碼的大量重復。在實際工作中，SpringBoot與事務結合最好的控制方法就是定義一個事務的配置類。取消業務Service層的事務注解配置，並定義TransactionConfig配置類，如下所示：

package com.demo.config;

import java.util.HashMap;
import java.util.Map;

import org.aspectj.lang.annotation.Aspect;
import org.springframework.aop.Advisor;
import org.springframework.aop.aspectj.AspectJExpressionPointcut;
import org.springframework.aop.support.DefaultPointcutAdvisor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource;
import org.springframework.transaction.interceptor.RuleBasedTransactionAttribute;
import org.springframework.transaction.interceptor.TransactionAttribute;
import org.springframework.transaction.interceptor.TransactionInterceptor;

@Configuration // 定義配置Bean
@Aspect // 采用Aop切面處理,定義切面類,切面通常是指封裝的用於橫向插入系統功能（事務、日志）的類。
public class TransactionConfig {

    private static final int TRANSACTION_METHOD_TIMEOUT = 5; // 事務超時時間為5秒鍾

    // 定義切面表達式
    private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.demo..service.*.*(..))";

    // 注入事務管理對象
    @Autowired
    private PlatformTransactionManager transactionManager;

    /**
     * 切面名稱必須為txAdvice
     * 
     * @return
     */
    @Bean(value = "txAdvice")
    public TransactionInterceptor transactionConfig() {
        // 定義只讀事務控制，該事務不需要啟動事務支持
        RuleBasedTransactionAttribute readOnly = new RuleBasedTransactionAttribute();
        // 設置只讀事務
        readOnly.setReadOnly(true);
        readOnly.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);

        // 定義更新事務，同時設置事務操作的超時時間
        RuleBasedTransactionAttribute required = new RuleBasedTransactionAttribute();
        required.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
        // 設置事務超時時間為5秒鍾
        required.setTimeout(TRANSACTION_METHOD_TIMEOUT);

        // 定義業務切面
        Map<String, TransactionAttribute> transactionmap = new HashMap<String, TransactionAttribute>();
        transactionmap.put("add*", required);
        transactionmap.put("edit*", required);
        transactionmap.put("delete*", required);
        transactionmap.put("get*", readOnly);
        transactionmap.put("list*", readOnly);
        transactionmap.put("find*", readOnly);

        // 使用名稱匹配
        NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();
        source.setNameMap(transactionmap);

        // 對設置名稱的方法進行事務操作
        TransactionInterceptor transactionInterceptor = new TransactionInterceptor();
        transactionInterceptor.setTransactionManager(transactionManager);
        transactionInterceptor.setTransactionAttributeSource(source);

        // 返回事務信息
        return transactionInterceptor;
    }

    @Bean
    public Advisor transactionAdviceAdvisor() {
        AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
        // 定義切面
        pointcut.setExpression(AOP_POINTCUT_EXPRESSION);
        DefaultPointcutAdvisor advisor = new DefaultPointcutAdvisor(pointcut, transactionConfig());
        return advisor;
    }

}

此時程序中的事務控制可以利用TransactionConfig類結合AspectJ切面與業務層中的方法匹配，而后就不再需要業務方法使用@Transactional注解重復定義了，需要注意的是啟動主類要加上@EnableTransactionManagement啟動事務管理。