Spring 50例常见错误（十六）

您所在的位置：网站首页 › spring编程常见错误 › Spring 50例常见错误（十六）

Spring 50例常见错误（十六）

#Spring 50例常见错误（十六）| 来源: 网络整理| 查看: 265

文章整理来源：Spring编程常见错误50例_spring_spring编程_bean_AOP_SpringCloud_SpringWeb_测试_事务_Data-极客时间

案例40：事务默认捕获的异常 RuntimeException 、Error

使用事务抛出异常，欲触发回滚

@Service public class StudentService { @Autowired private StudentMapper studentMapper; @Transactional public void saveStudent(String realname) throws Exception { Student student = new Student(); student.setRealname(realname); studentMapper.saveStudent(student); if (student.getRealname().equals("小明")) { throw new Exception("该学生已存在"); } } }

解析：事务本质上也是一种特殊的切面，在创建的过程中，被 CglibAopProxy 代理。事务处理的拦截器是 TransactionInterceptor ，当执行代理类的目标方法时，会触发 invoke() ，若有异常则会进入 comleteTransactionAfterThrowing 方法，在这方法中会先对异常的类型进行判定 rollbackOn 以确定是否执行回滚。

protected Object invokeWithinTransaction(Method method, @Nullable Class targetClass, final InvocationCallback invocation) throws Throwable { //省略非关键代码 Object retVal; try { retVal = invocation.proceedWithInvocation(); } catch (Throwable ex) { completeTransactionAfterThrowing(txInfo, ex); throw ex; } finally { cleanupTransactionInfo(txInfo); } //省略非关键代码 } ------------------------------------------------------------------------ protected void completeTransactionAfterThrowing(@Nullable TransactionInfo txInfo, Throwable ex) { // 省略非关键代码 // 判断是否需要回滚 rollbackOn if (txInfo.transactionAttribute != null && txInfo.transactionAttribute.rollbackOn(ex)) { try { //执行回滚 txInfo.getTransactionManager().rollback(txInfo.getTransactionStatus()); } catch (TransactionSystemException ex2) { ex2.initApplicationException(ex); throw ex2; } catch (RuntimeException | Error ex2) { throw ex2; } } //省略非关键代码 } ------------------------------------------------------------------------------- public boolean rollbackOn(Throwable ex) { // 层级 1：根据"rollbackRules"及当前捕获异常来判断是否需要回滚 RollbackRuleAttribute winner = null; int deepest = Integer.MAX_VALUE; if (this.rollbackRules != null) { for (RollbackRuleAttribute rule : this.rollbackRules) { // 当前捕获的异常可能是回滚“异常”的继承体系中的“一员” int depth = rule.getDepth(ex); if (depth >= 0 && depth < deepest) { deepest = depth; winner = rule; } } } // 层级 2：调用父类的 rollbackOn 方法来决策是否需要 rollback if (winner == null) { return super.rollbackOn(ex); } return !(winner instanceof NoRollbackRuleAttribute); } --------------------------------------------------------------------------- // 父类的 rollbackOn 方法来 public boolean rollbackOn(Throwable ex) { return (ex instanceof RuntimeException || ex instanceof Error); }

Spring 在处理事务过程中，并不会对 Exception 进行回滚，而会对 RuntimeException 或者 Error 进行回滚

解决：1.将抛出的异常类型改成 RuntimeException

2. 确定 @Transactional 的 rollbackFor 加入需要支持的异常类型

@Transactional(rollbackFor = Exception.class)

案例41：试图给 private 方法添加事务

给 private 方法添加了事务，但却不起作用

@Service public class StudentService { @Autowired private StudentMapper studentMapper; @Autowired private StudentService studentService; public void saveStudent(String realname) throws Exception { Student student = new Student(); student.setRealname(realname); studentService.doSaveStudent(student); } @Transactional private void doSaveStudent(Student student) throws Exception { studentMapper.saveStudent(student); if (student.getRealname().equals("小明")) { throw new RuntimeException("该用户已存在"); } } }

解析：当 Bean 初始化之后，开始尝试代理操作，这个过程是从 AbstractAutoProxyCreator 里的 postProcessAfterInitialization 方法开始处理的。根据 AopUtils 的 canApply 方法。判断切面定义里的条件，确定这个方法是否可以被应用创建成代理。其中有一段 methodMatcher.matches(method, targetClass) 是用来判断这个方法是否符合这样的条件

public static boolean canApply(Pointcut pc, Class targetClass, boolean hasIntroductions) { //省略非关键代码 for (Class clazz : classes) { Method[] methods = ReflectionUtils.getAllDeclaredMethods(clazz); for (Method method : methods) { if (introductionAwareMethodMatcher != null ? introductionAwareMethodMatcher.matches(method, targetClass, hasIntroductions) : methodMatcher.matches(method, targetClass)) { return true; } } } return false; } ----------------------------------------------------------------------- public boolean matches(Method method, Class targetClass) { //省略非关键代码 TransactionAttributeSource tas = getTransactionAttributeSource(); return (tas == null || tas.getTransactionAttribute(method, targetClass) != null); } ------------------------------------------------------------------------- public TransactionAttribute getTransactionAttribute(Method method, @Nullable Class targetClass) { //省略非关键代码 TransactionAttribute txAttr = computeTransactionAttribute(method, targetClass); //省略非关键代码 } } --------------------------------------------------------------------- protected TransactionAttribute computeTransactionAttribute(Method method, @Nullable Class targetClass) { //省略非关键代码 if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) { return null; } //省略非关键代码 }

最终，调用到 computeTransactionAttribute 这个方法，其主要功能是根据方法和类的类型确定是否返回事务属性，

1，allowPublicMethodsOnly 返回了 AnnotationTransactionAttributeSource 的 publicMethodsOnly 属性，而这个 publicMethodsOnly 属性是通过 AnnotationTransactionAttributeSource 的构造方法初始化的，默认为 true。

2. Modifier.isPublic() 这个方法根据传入的 method.getModifiers() 获取方法的修饰符。该修饰符是 java.lang.reflect.Modifier 的静态属性，对应的几类修饰符分别是：PUBLIC: 1，PRIVATE: 2，PROTECTED: 4。这里面做了一个位运算，只有当传入的方法修饰符是 public 类型的时候，才返回 true。

故只有当注解为事务的方法被声明为 public 的时候，才会被 Spring 处理

解决：只需要把它的修饰符从 private 改成 public 就可以了

【本文地址】

Spring 50例常见错误（十六）

Spring 50例常见错误（十六）

今日新闻

推荐新闻