HeapDump性能社区

性能工具
登录注册
性能文章>美团二面:spring事务不生效的15种场景>

美团二面:spring事务不生效的15种场景原创

捡田螺的小男孩
1年前
377035

前言

大家好，我是田螺。

日常开发中，我们经常使用到spring事务。最近星球一位还有去美团面试，被问了这么一道面试题: Spring 事务在哪几种情况下会不生效？ 今天田螺哥跟大家聊聊，spring事务不生效的15种场景。

1. 你的service类没有被Spring管理

//@Service （注释了@Service）
public class TianLuoServiceImpl implements TianLuoService {

    @Autowired
    private TianLuoMapper tianLuoMapper;
    
     @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional
    public void addTianLuo(TianLuo tianluo) {
        //保存tianluo实体数据库记录
        tianLuoMapper.save(tianluo);
        //保存tianluo流水数据库记录
        tianLuoFlowMapper.saveFlow(buildFlowByTianLuo(tianluo));
    }
}
  • 事务不生效的原因：上面例子中， @Service注解注释之后， spring事务（ @Transactional）没有生效，因为 Spring事务是由 AOP机制实现的，也就是说从 Spring IOC容器获取 bean时， Spring会为目标类创建代理，来支持事务的。但是 @Service被注释后，你的 service类都不是 spring管理的， 那怎么创建代理类来支持事务呢。
  • 解决方案：加上 @Service注解。

2.没有在Spring配置文件中启用事务管理器

@Configuration
public class AppConfig {
    // 没有配置事务管理器
}

@Service
public class MyService {
    @Transactional
    public void doSomething() {
        // ...
    }
}
  • 事务不生效的原因：没有在 AppConfig中配置事务管理器，因此 Spring无法创建事务代理对象，导致事务不生效。即使在 MyService中添加了 @Transactional注解，该方法也不会被 Spring管理的事务代理拦截。
  • 解决方案：为了解决这个问题，应该在 AppConfig中配置一个事务管器。例如：
@Configuration
public class AppConfig {
    @Bean
    public PlatformTransactionManager transactionManager() {
        return new DataSourceTransactionManager(dataSource());
    }
}

@Service
public class MyService {
    @Transactional
    public void doSomething() {
        // ...
    }
}

如果是Spring Boot项目，它默认会自动配置事务管理器并开启事务支持。

3. 事务方法被final、static关键字修饰

@Service
public class TianLuoServiceImpl  {

    @Autowired
    private TianLuoMapper tianLuoMapper;
    
    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional
    public final void addTianLuo(TianLuo tianluo) {
         //保存tianluo实体数据库记录
        tianLuoMapper.save(tianluo);
        //保存tianluo流水数据库记录
        tianLuoFlowMapper.saveFlow(buildFlowByTianLuo(tianluo));
    }
}
  • 事务不生效的原因：如果一个方法被声明为 final或者 static，则该方法不能被子类重写，也就是说无法在该方法上进行动态代理，这会导致 Spring无法生成事务代理对象来管理事务。
  • 解决方案： addTianLuo 事务方法不要用 final修饰或者 static修饰。

4. 同一个类中，方法内部调用

@Service
public class TianLuoServiceImpl implements TianLuoService {

    @Autowired
    private TianLuoMapper tianLuoMapper;
    
    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;
    
    public void addTianLuo(TianLuo tianluo){
     // 调用内部的事务方法
     this.executeAddTianLuo(tianluo);
   }

    @Transactional
    public void executeAddTianLuo(TianLuo tianluo) {
        tianLuoMapper.save(tianluo);
        tianLuoFlowMapper.saveFlow(buildFlowByTianLuo(tianluo));
    }
}
  • 事务不生效的原因: 事务是通过 Spring AOP代理来实现的，而在同一个类中，一个方法调用另一个方法时， 调用方法直接调用目标方法的代码，而不是通过代理类进行调用。即以上代码，调用目标 executeAddTianLuo方法不是通过代理类进行的，因此事务不生效。
  • 解决方案：可以新建多一个类，让这两个方法分开，分别在不同的类中。如下：
@Service
public class TianLuoExecuteServiceImpl implements TianLuoExecuteService {

    @Autowired
    private TianLuoMapper tianLuoMapper;
    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;
    
    @Transactional
    public void executeAddTianLuo(TianLuo tianluo) {
        tianLuoMapper.save(tianluo);
        tianLuoFlowMapper.saveFlow(buildFlowByTianLuo(tianluo));
    }
}

@Service
public class TianLuoAddServiceImpl implements TianLuoAddService {

    @Autowired
    private TianLuoExecuteService tianLuoExecuteService;
    
    public void addTianLuo(User user){
     tianLuoExecuteService.executeAddTianLuo(user);
   }
}

当然，有时候你也可以在该 Service 类中注入自己，或者通过AopContext.currentProxy()获取代理对象。

5.方法的访问权限不是public

@Service
public class TianLuoServiceImpl implements TianLuoService {

    @Autowired
    private TianLuoMapper tianLuoMapper;
    
    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional
    private void addTianLuo(TianLuo tianluo) {
        tianLuoMapper.save(tianluo);
        tianLuoFlowMapper.saveFlow(buildFlowByTianLuo(tianluo));
    }
}

  • 事务不生效的原因： spring事务方法 addTianLuo的访问权限不是 public，所以事务就不生效啦，因为 Spring事务是由 AOP机制实现的， AOP机制的本质就是动态代理，而代理的事务方法不是 public的话， computeTransactionAttribute()就会返回null，也就是这时事务属性不存在了。大家可以看下 AbstractFallbackTransactionAttributeSource的源码：
  • 解决方案： addTianLuo事务方法的访问权限修改为 public。

6. 数据库的存储引擎不支持事务

Spring事务的底层，还是依赖于数据库本身的事务支持。在MySQL中，MyISAM存储引擎是不支持事务的，InnoDB引擎才支持事务。因此开发阶段设计表的时候，确认你的选择的存储引擎是支持事务的。

7 .配置错误的 @Transactional 注解

@Transactional(readOnly = true)
public void updateUser(User user) {
    userDao.updateUser(user);
}
  • 事务不生效的原因：虽然使用了 @Transactional注解，但是注解中的 readOnly=true属性指示这是一个只读事务，因此在更新 User实体时会抛出异常。
  • 解决方案：将 readOnly属性设置为 false，或者移除了 @Transactional注解中的 readOnly属性。

8.事务超时时间设置过短

@Transactional(timeout = 1)
public void doSomething() {
    //...
}
  • 事务不生效的原因：在上面的例子中， timeout属性被设置为 1秒，这意味着如果事务在 1 秒内无法完成，则报事务超时了。

9. 使用了错误的事务传播机制

@Service
public class TianLuoServiceImpl {
 
    @Autowired
    private TianLuoMapper tianLuoMapper;
    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;
 
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public  void doInsertTianluo(TianLuo tianluo) throws Exception {
        tianLuoMapper.save(tianluo);
        tianLuoFlowMapper.saveFlow(buildFlowByTianLuo(tianluo));
    }
}
  • 事务不生效的原因： Propagation.NOT_SUPPORTED传播特性不支持事务。
  • 解决方案：选择正确的事务传播机制。

帮大家复习一下，Spring提供了七种事务传播机制。它们分别是：

  • REQUIRED（默认）：如果当前存在一个事务，则加入该事务；否则，创建一个新事务。该传播级别表示方法必须在事务中执行。
  • SUPPORTS：如果当前存在一个事务，则加入该事务；否则，以非事务的方式继续执行。
  • MANDATORY：如果当前存在一个事务，则加入该事务；否则，抛出异常。
  • REQUIRES_NEW：创建一个新的事务，并且如果存在一个事务，则将该事务挂起。
  • NOT_SUPPORTED：以非事务方式执行操作，如果当前存在一个事务，则将该事务挂起。
  • NEVER：以非事务方式执行操作，如果当前存在一个事务，则抛出异常。
  • NESTED：如果当前存在一个事务，则在嵌套事务内执行。如果没有事务，则按 REQUIRED传播级别执行。嵌套事务是外部事务的一部分，可以在外部事务提交或回滚时部分提交或回滚。

10. rollbackFor属性配置错误

@Service
public class TianLuoServiceImpl implements TianLuoService {

    @Autowired
    private TianLuoMapper tianLuoMapper;
    
    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional(rollbackFor = Error.class)
    public void addTianLuo(TianLuo tianluo) {
        //保存tianluo数据库记录
        tianLuoMapper.save(tianluo);
        //保存tianluo流水数据库记录
        tianLuoFlowMapper.saveFlow(tianluo);
        //模拟异常抛出
        throw new Exception();
    }
}
  • 事务不生效的原因: 其实 rollbackFor属性指定的异常必须是 Throwable或者其子类。默认情况下， RuntimeException和 Error两种异常都是会自动回滚的。但是因为以上的代码例子，指定了 rollbackFor = Error.class，但是抛出的异常又是 Exception，而 Exception和Error没有任何什么继承关系，因此事务就不生效。

大家可以看一下Transactional注解源码哈：

  • 解决方案： rollbackFor属性指定的异常与抛出的异常匹配。

11.事务注解被覆盖导致事务失效

public interface MyRepository {
    @Transactional
    void save(String data);
}

public class MyRepositoryImpl implements MyRepository {
    @Override
    public void save(String data) {
        // 数据库操作
    }
}

public class MyService {

    @Autowired
    private MyRepository myRepository;

    @Transactional
    public void doSomething(String data) {
        myRepository.save(data);
    }
}

public class MyTianluoService extends MyService {
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void doSomething(String data) {
        super.doSomething(data);
    }
}
  • 事务失效的原因： MyTianluoService是 MyService的子类，并且覆盖了 doSomething()方法。在该方法中，使用了不同的传播行为 （REQUIRES_NEW）来覆盖父类的 @Transactional注解。在这种情况下，当调用 MyTianluoService的 doSomething()方法时，由于子类方法中的注解覆盖了父类的注解， Spring框架 将不会在父类的方法中启动事务。因此，当 MyRepository的 save()方法被调用时，事务将不会被启动，也不会回滚。这将导致数据不一致的问题，因为在 MyRepository的 save()方法中进行的数据库操作将不会回滚。

12.嵌套事务的坑

@Service
public class TianLuoServiceInOutService {

    @Autowired
    private TianLuoFlowService tianLuoFlowService;
    @Autowired
    private TianLuoMapper tianLuoMapper;

    @Transactional
    public void addTianLuo(TianLuo tianluo) throws Exception {
        tianLuoMapper.save(tianluo);
        tianLuoFlowService.saveFlow(tianluo);
    }
}

@Service
public class TianLuoFlowService {

    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional(propagation = Propagation.NESTED)
    public void saveFlow(TianLuo tianLuo) {
        tianLuoFlowMapper.save(tianLuo);
        throw new RuntimeException();
    }
}

以上代码使用了嵌套事务，如果saveFlow出现运行时异常，会继续往上抛，到外层addTianLuo的方法，导致tianLuoMapper.save也会回滚啦。如果不想因为被内部嵌套的事务影响，可以用try-catch包住，如下：

    @Transactional
    public void addTianLuo(TianLuo tianluo) throws Exception {
        tianLuoMapper.save(tianluo);
        try {
            tianLuoFlowService.saveFlow(tianluo);
        } catch (Exception e) {
          log.error("save tian luo flow fail,message:{}",e.getMessage());
        }
    }

13. 事务多线程调用

@Service
public class TianLuoService {

    @Autowired
    private TianLuoMapper tianLuoMapper;

    @Autowired
    private TianLuoFlowService tianLuoFlowService;

    @Transactional
    public void addTianLuo(TianLuo tianluo) {
        //保存tianluo数据库记录
        tianLuoMapper.save(tianluo);
        //多线程调用
        new Thread(() -> {
            tianLuoFlowService.saveFlow(tianluo);
        }).start();
    }
}

@Service
public class TianLuoFlowService {

    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional
    public void save(TianLuo tianLuo) {
        tianLuoFlowMapper.saveFlow(tianLuo);
    }
}
  • 事务不生效原因：这是因为 Spring事务是基于线程绑定的， 每个线程都有自己的事务上下文，而多线程环境下可能会存在多个线程共享同一个事务上下文的情况，导致事务不生效。 Spring事务管理器通过使用线程本地变量（ ThreadLocal）来实现线程安全。大家有兴趣的话，可以去看下源码哈.

在Spring事务管理器中，通过TransactionSynchronizationManager类来管理事务上下文。TransactionSynchronizationManager内部维护了一个ThreadLocal对象，用来存储当前线程的事务上下文。在事务开始时，TransactionSynchronizationManager会将事务上下文绑定到当前线程的ThreadLocal对象中，当事务结束时，TransactionSynchronizationManager会将事务上下文从ThreadLocal对象中移除。

14.异常被捕获并处理了，没有重新抛出

@Service
public class TianLuoServiceImpl implements TianLuoService {

    @Autowired
    private TianLuoMapper tianLuoMapper;

    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional
    public void addTianLuo(TianLuo tianluo) {
        try {
            //保存tianluo数据库记录
            tianLuoMapper.save(tianluo);
            //保存tianluo flow数据库记录
            tianLuoFlowMapper.saveFlow(tianluo);
        } catch (Exception e) {
            log.error("add TianLuo error,id:{},message:{}", tianluo.getId(),e.getMessage());
        }
    }

}
  • 事务不生效的原因: 事务中的异常已经被业务代码捕获并处理，而没有被正确地传播回事务管理器，事务将无法回滚。我们可以从 spring源码( TransactionAspectSupport这个类)中找到答案：
public abstract class TransactionAspectSupport implements BeanFactoryAware, InitializingBean {

 //这方法会省略部分代码，只留关键代码哈
  @Nullable
 protected Object invokeWithinTransaction(Method method, @Nullable Class<?> targetClass, final InvocationCallback invocation) throws Throwable {

  if (txAttr == null || !(ptm instanceof CallbackPreferringPlatformTransactionManager)) {
  
   TransactionInfo txInfo = createTransactionIfNecessary(ptm, txAttr, joinpointIdentification);
   Object retVal;
   try {
        //Spring AOP中MethodInterceptor接口的一个方法，它允许拦截器在执行被代理方法之前和之后执行额外的逻辑。
    retVal = invocation.proceedWithInvocation();
   }
   catch (Throwable ex) {
        //用于在发生异常时完成事务(如果Spring catch不到对应的异常的话，就不会进入回滚事务的逻辑)
    completeTransactionAfterThrowing(txInfo, ex);
    throw ex;
   }
   finally {
    cleanupTransactionInfo(txInfo);
   }

      //用于在方法正常返回后提交事务。
   commitTransactionAfterReturning(txInfo);
   return retVal;
  }
}

在invokeWithinTransaction方法中，当Spring catch到Throwable异常的时候，就会调用completeTransactionAfterThrowing()方法进行事务回滚的逻辑。但是，在TianLuoServiceImpl类的spring事务方法addTianLuo中，直接把异常catch住了，并没有重新throw出来，因此 Spring自然就catch不到异常啦，因此事务回滚的逻辑就不会执行，事务就失效了。

  • 解决方案：在 spring事务方法中，当我们使用了 try-catch，如果catch住异常，记录完异常日志什么的，一定要重新把异常抛出来，正例如下：
@Service
public class TianLuoServiceImpl implements TianLuoService {

    @Autowired
    private TianLuoMapper tianLuoMapper;

    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional(rollbackFor = Exception.class)
    public void addTianLuo(TianLuo tianluo) {
        try {
            //保存tianluo数据库记录
            tianLuoMapper.save(tianluo);
            //保存tianluo flow数据库记录
            tianLuoFlowMapper.saveFlow(tianluo);
        } catch (Exception e) {
            log.error("add TianLuo error,id:{},message:{}", tianluo.getId(),e.getMessage());
            throw e;
        }
    }
}

15. 手动抛了别的异常

@Service
public class TianLuoServiceImpl implements TianLuoService {

    @Autowired
    private TianLuoMapper tianLuoMapper;
    
    @Autowired
    private TianLuoFlowMapper tianLuoFlowMapper;

    @Transactional
    public void addTianLuo(TianLuo tianluo) throws Exception {
        //保存tianluo数据库记录
        tianLuoMapper.save(tianluo);
        //保存tianluo流水数据库记录
        tianLuoFlowMapper.saveFlow(tianluo);
        throw new Exception();
    }
}
  • 失效的原因：上面的代码例子中，手动抛了 Exception异常，但是是不会回滚的，因为Spring默认只处理 RuntimeException和Error，对于普通的 Exception不会回滚，除非，用 rollbackFor属性指定配置。
  • 解决方案：添加属性配置 @Transactional(rollbackFor = Exception.class)。

注解为事务范围的方法中，事务的回滚仅仅对于unchecked的异常有效。对于checked异常无效。也就是说事务回滚仅仅发生在，出现RuntimeException或Error的时候。通俗一点就是：代码中出现的空指针等异常，会被回滚。而文件读写、网络超时问题等，spring就没法回滚了。

 

点赞收藏
分类：
Java语言
标签：
java
Spring
捡田螺的小男孩

公众号:捡田螺的小男孩

请先登录，查看3条精彩评论吧
快去登录吧，你将获得
  • 浏览更多精彩评论
  • 和开发者讨论交流，共同进步
5
3
Lv3
捡田螺的小男孩

徽章

公众号:捡田螺的小男孩

推荐阅读

浅析AbstractQueuedSynchronizer日常Bug排查-集群逐步失去响应为什么要做代码Review？JVM coredump分析系列（5）：使用netty-tcnative出现SIGSEGV crash分析Java核心知识体系5：反射机制详解最新发布！阿里巴巴内部实战AlibabaSentinel高并发流量治理手册
站内搜索
Linux
SpringBoot
锁
字节码
火焰图
故障排查
java
jvm
gc
linux
内存泄漏
内核

专题推荐

对于刚刚接触 JVM 的同学来说，JVM 就像一个黑盒一样，完全不知道这是一个什么东西。所以对于小白来说，最重要是搞清楚 JVM 到底是干嘛的，以及其常用的知识框架。针对这样的需求，才有了这个专题，从零开始循序渐进地介绍了 JVM，相信是很不错的 JVM 入门教程。
15篇文章32049阅读量
通过阅读 Redis 源码，可以学习和掌握到的计算机系统设计思想，redis 涉及的知识点有很多，本期专题我们由浅入深，简洁的给大家剖析Redis源码。
15篇文章24013阅读量

本月精选性能专题

本月精选线上案例

本月精选原创好文

HeapDump

有性能问题，上HeapDump性能社区

Copyright © 2019-2024 heapdump.cn 版权所有 浙ICP备17054444号

联系我们

HeapDump性能社区

网媒渠道

堆堆酱

扫码加堆堆酱好友

友情链接

PerfMa官网SegmentFault思否TesterHomeXPocket开源社区DCloud 问答社区稀土掘金博客园W3CTech