目录

一、代码

二、Spring 事务失效之谜

一、代码

package com.xiaojie.annotation;

import java.lang.annotation.*;

/**
 * 自定义事务注解
 */
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface MyTransactional {
}

package com.xiaojie.util;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Component;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.interceptor.DefaultTransactionAttribute;

/**
 * @author Administrator
 *编程事务类，手动开始，手动提交，手动回滚
 */
@Component
@Scope("prototype")
public class TransactionUtils {
	private TransactionStatus status;
	@Autowired
	private DataSourceTransactionManager dataSourceTransactionManager;
		//开始事务
		public TransactionStatus begin() {
			TransactionStatus transaction = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
			return transaction;
		}
		//提交事务
		public void commit(TransactionStatus transaction) {
			dataSourceTransactionManager.commit(transaction);
		}
		//回滚事务
		public void rollback() {
			System.out.println("事务回滚。。。。。。");
			dataSourceTransactionManager.rollback(status);
		}
}

package com.xiaojie.aop;

import com.xiaojie.annotation.MyTransactional;
import com.xiaojie.util.TransactionUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.AfterThrowing;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.TransactionStatus;

import java.lang.reflect.Method;

/**
 * 自定义事务切面，原理
 * 通过环绕通知，当执行目标方法没有异常时提交事务
 * 当执行目标方法发生异常时，在异常通知中回滚事务，实现事务提交与回滚
 */
@Aspect
@Component
public class TransactionalAop {

    @Autowired
    private TransactionUtils transactionUtils;

    /**
     * 定义切入点
     */
    @Pointcut("execution(* com.xiaojie.service.*.*.*(..))")
    public void transactionalPoint(){}

    @Around("transactionalPoint()")
    public Object around(ProceedingJoinPoint point) throws Throwable {
        //获取方法名称
        String methodName = point.getSignature().getName();
        // 获取目标对象
        Class<? extends Object> targetClass = point.getTarget().getClass();
        // 获取目标对象类型
        Class[] par = ((MethodSignature) point.getSignature()).getParameterTypes();
        // 获取目标对象方法
        Method objMethod = targetClass.getDeclaredMethod(methodName, par);
        //获取目标方法上的注解
        MyTransactional declaredAnnotation = objMethod.getDeclaredAnnotation(MyTransactional.class);
        //如果方法上有注解则开始事务
        if (null==declaredAnnotation){
            //如果没有注解，则执行目标方法
            return point.proceed();
        }
        //有注解，开启事务
        System.out.println("开启事务。。。。。。。");
        TransactionStatus status = transactionUtils.begin();
        //调用目标方法
        Object proceed = point.proceed();
        if (status!=null){
            //提交事务
            transactionUtils.commit(status);
        }
        return proceed;
    }
    /**
     * 目标方法发生异常，则执行回滚事务
     */
    @AfterThrowing("transactionalPoint()")
    public void afterthrow() {
        //如果发生异常则回滚事务
        transactionUtils.rollback();
    }

}

完整代码请参考https://gitee.com/whisperofjune/spring-transactional.git

二、Spring 事务失效之谜

• spring的事务注解@Transactional只能放在public修饰的方法上才起作用，如果放在其他非public（private，protected）方法上，虽然不报错，但是事务不起作用
• 如使用mysql且引擎是MyISAM，则事务会不起作用，原因是MyISAM不支持事务，可以改成InnoDB引擎
• 在业务代码中如果抛出RuntimeException异常，事务回滚；但是抛出Exception，事务不回滚；需要在注解上配置
• @Transactional(rollbackFor={RuntimeException.class,Exception.class})
• 如果在加有事务的方法内，使用了try…catch..语句块对异常进行了捕获，而catch语句块没有throw  new RuntimeExecption异常，事务也不会回滚。因为aop捕获不到异常，不能进行异常通知从而不能执行事务回滚的方法。
• 在类A里面有方法a 和方法b， 然后方法b上面用 @Transactional加了方法级别的事务，在方法a里面 调用了方法b， 方法b里面的事务不会生效。原因是在同一个类之中，方法互相调用，切面无效 ，而不仅仅是事务。这里事务之所以无效，是因为spring的事务是通过aop实现的。
   

参考：https://blog.csdn.net/dhklsl/article/details/88354216