搞懂spring事务

Posted 2020-10-19 kevin.li

最近一个官网的项目,我在service层有两个添加数据的操作,很意外报错了,然后就研究到了事务

之前只是知道声明式事务和编程式事务,编程式的事务显得比较麻烦,一般都是使用声明式事务..

spring提供了很多种配置方式: 

编程式事务:

　　开启事务;

　　try{

　　　　更新或添加操作;

　　　　提交;

　　}catch(..){

　　　　回滚;

　　}

声明式事务:

　　提交,回滚的操作写在了一个代理类里头,在执行事务方法之前开启事务,在执行完方法之前提交或者回滚事务

　　

1 给每个bean(service类)配置一个代理类

2 所有service类公用一个代理类

3 拦截器(aop的方式)

4 全注解(在service类加上Transaction)

注 : spring只对runtiomException才会回滚(经测试的) 提供了对应的属性设置异常类型

下面是我项目里头事务的配置 (config配置呢) :

 

/**
 * 注解声明式事务配置(相当于上述的aop方式的配置)
 * @author liyong
 *
 */
@Configuration
public class TxAdviceTransactionConfig {
    private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.mike.mihome.*.service..*.*(..))";
    
    @Autowired
    private PlatformTransactionManager transactionManager;
    
    @Bean
    public TransactionInterceptor txAdvice(){
        NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();
        
        //只读事务，不做更新操作
        RuleBasedTransactionAttribute readOnlyTx = new RuleBasedTransactionAttribute();
        readOnlyTx.setReadOnly(true);
        readOnlyTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);
        
        //当前存在事务就使用当前事务，当前不存在事务就创建一个新的事务
        RuleBasedTransactionAttribute requiredTx = new RuleBasedTransactionAttribute();
//        requiredTx.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class))); //设置异常类型
        requiredTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
        requiredTx.setTimeout(10000);
        
        Map<String, TransactionAttribute> txMap = new HashMap<String, TransactionAttribute>();
        txMap.put("query*", readOnlyTx);
        txMap.put("get*", readOnlyTx);
        
        txMap.put("*", requiredTx);
        source.setNameMap(txMap);
        
        TransactionInterceptor txAdvice = new TransactionInterceptor(transactionManager, source);
        return txAdvice;
    }
    
    @Bean
    public Advisor txAdviceAdvisor() {
        AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
        pointcut.setExpression(AOP_POINTCUT_EXPRESSION);
        return new DefaultPointcutAdvisor(pointcut, txAdvice());
    }
}