正文
一、代码
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实现的。
