首页 > 其他分享 >事务失效有哪几种原因

事务失效有哪几种原因

时间:2023-08-05 10:02:01浏览次数:32  
标签:事务 调用 代理 bean 哪几种 user 失效 StudentService public


事务失效有哪几种原因_ide

在做业务开发时,遇到了一个事务不起作用的问题。事情是这样的,方法内部的定时任务调用了一个带事务的方法,失败后事务没有回滚。查阅资料后,问题得到解决,记录下来分享给大家。

场景

我在这里模拟一个场景,大概的调用方式就如下面的代码这样。

@Override
    @Transactional(rollbackFor = RuntimeException.class)
    public void insertUser(User user) {
        userMapper.insertUser(user);
        throw new RuntimeException("");
    }
    
    /**
     * 内部调用新增方法
     *
     * @param user
     */
    @Override
    public void invokeInsertUser(User user) {
        this.insertUser(user);
    }

              
原因

AOP使用的是动态代理的机制,它会给类生成一个代理类,事务的相关操作都在代理类上完成。内部方式使用this调用方式时,使用的是实例调用,并没有通过代理类调用方法,所以会导致事务失效。

事务不生效的原因在于,spring基于AOP机制实现事务的管理,@Authwired StudentService studentService这样的方式,调用StudentService的方法时,实际上是通过StudentService的代理类调用StudentService的方法,代理类在执行目标方法前后,加上了事务管理的代码。

因此,只有通过注入的StudentService调用事务方法,才会走代理类,才会执行事务管理;如果在同类直接调用,没走代理类,事务就无效。

解决办法

方法一 引入自身bean

在类内部通过@Autowired将本身bean引入,然后通过调用自身bean,从而实现使用AOP代理操作。

注入自身bean

@Autowired
    @Lazy
    private UserService service;

修改invokeInsertUser方法

/**
     * 解决方法一 在bean中将自己注入进来
     * @param user
     */
    @Override
    public void invokeInsertUser(User user) {
        this.service.insertUser(user);
    }

可能有人会担心这样会有循环依赖的问题,事实上,spring通过三级缓存解决了循环依赖的问题,所以上面的写法不会有循环依赖问题。

但是!!!,这不代表spring永远没有循环依赖的问题(@Async导致循环依赖了解下)

方法二 通过ApplicationContext引入bean(通过spring上下文获取到当前代理类(推荐)

通过ApplicationContext获取bean,通过bean调用内部方法,就使用了bean的代理类。

注入ApplicationContext

@Autowired
    ApplicationContext applicationContext;

修改invokeInsertUser方法

/**
     * 解决方法二 通过applicationContext获取到bean
     * @param user
     */
    @Override
    public void invokeInsertUser(User user) {
        ((UserService)applicationContext.getBean("userService")).invokeInsertUser(user);
    }

demo2 整理成工具类:

@Component
public class SpringBeanUtil implements ApplicationContextAware {
 
    private static ApplicationContext applicationContext;
 
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
 
    /**
     * 通过class获取Bean
     * @param clazz class
     * @param <T> 泛型
     * @return bean
     */
    public static <T> T getBean(Class<T> clazz) {
        return applicationContext.getBean(clazz);
    }

              

                @Service
public class StudentServiceImpl implements StudentService {
 
    @Autowired
    private StudentMapper studentMapper;
 
    @Override
    public void insertStudent(){
        StudentService bean = SpringBeanUtil.getBean(StudentService.class);
        if (null != bean) {
            bean.insert();
        }
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void insert() {
        StudentDO studentDO = new StudentDO();
        studentDO.setName("小民");
        studentDO.setAge(22);
        studentMapper.insert(studentDO);
 
        if (studentDO.getAge() > 18) {
            throw new RuntimeException("年龄不能大于18岁");
        }
    }
}

方法三 通过AopContext获取当前类的代理类

通过AopContext获取当前类的代理类,直接通过代理类调用方法

在引导类(启动类)上添加@EnableAspectJAutoProxy(exposeProxy=true)注解

修改invokeInsertUser方法

@Service
public class StudentServiceImpl implements StudentService {
 
    @Autowired
    private StudentMapper studentMapper;
 
    @Override
    public void insertStudent(){
        getService().insert();
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void insert() {
        StudentDO studentDO = new StudentDO();
        studentDO.setName("小民");
        studentDO.setAge(22);
        studentMapper.insert(studentDO);
 
        if (studentDO.getAge() > 18) {
            throw new RuntimeException("年龄不能大于18岁");
        }
    }
 
    /**
     * 通过AopContext获取代理类
     * @return StudentService代理类
     */
    private StudentService getService(){
        return Objects.nonNull(AopContext.currentProxy()) ? (StudentService)AopContext.currentProxy() : this;
    }
}

exposeProxy = true用于控制AOP框架公开代理,公开后才可以通过AopContext获取到当前代理类。(默认情况下不会公开代理,因为会降低性能)

注意:不能保证这种方式一定有效,使用@Async时,本方式可能失效。

从@Async案例找到Spring框架的bug:exposeProxy=true不生效原因大剖析

以上就是内部方法调用时,事务不起作用的原因及解决办法。

----------------------------------------------拓展-----------------------------------------------------------------------

1.注意:除了@Transactional,@Async同样需要代理类调用,异步才会生效

2.spring通过三级缓存解决了循环依赖的问题

3.AopContext类详解

标签:事务,调用,代理,bean,哪几种,user,失效,StudentService,public
From: https://blog.51cto.com/u_16173281/6973497

相关文章

  • 外键字段的增删改查、多表查询、正反向的概念、子查询、多表查询之连表查询、聚合函数
    外键字段的增删改查多对多的外键增删改查图书和作者是多对多,借助于第三张表实现的,如果想绑定图书和作者的关系,本质上就是在操作第三方表操作第三张表问题:让你给图书添加一个作者,他俩的关系可是多对多让你给图书id=2添加一个作者id=1add方法book_obj=models.Book.objects......
  • Spring事务 --》@Transactional参数、事务实现方式、隔离级别、传播方式
    实现方式::在spring中有两种事务的实现方式,分别是编程式事务管理和编码式事务管理。编程式事务一般使用的是TransactionTemplate工具类来实现spring中使用的是@Transactional注解,可以作用于接口、接口方法、类以及类方法上。当作用于类上时,该类的所有public方法将都具有该类型的......
  • python有哪几种循环语句
    在Python中,常用的循环语句有以下几种:for循环:用于遍历给定的序列(如列表、字符串等)或可迭代对象的元素。循环会重复执行固定次数,或者依次遍历序列中的每个元素。示例:forelementinsequence:#在这里执行循环体代码while循环:通过判断条件是否为真来控制循环的执行。只......
  • Mybatis-Plus 多数据源 @DS注解部分失效
    环境springboot+mybatis-plus在controller层一个request中有多个service调用保存接口,发现在mapper层上定义的@DS注解指定数据源部分指向了primary数据源。导致表找不到。处理猜测是不能走mybatis-plus生成的batchSave方法,将controller中多个service处理逻辑放到指定service中,......
  • Redis从入门到放弃(5):事务
    文章目录1、事务的定义2、事务命令3、事务错误处理4、事务的冲突问题4.1、悲观锁(PessimisticLock)4.2、乐观锁(OptimisticLocking)5、总结:事务三特性1、事务的定义Redis的事务提供了一种“将多个命令打包,然后一次性、按顺序地执行”的机制。redis事务的主要作用就是串联多个命令......
  • mysql事务和索引详解
    mysql事务和索引详解1.事务注:事务就是一组操作的集合,成功一起成功,失败一起失败事务控制:开启事务:starttransaction;/begin;提交事务:commit;回滚事务:rollback;使用方法:首先graphTBid1[开启事务]-->id2{执行mysql}id2-->|语句全部执行成功|id3>提交事务]id2-->|语......
  • 【SpringBoot学习】2、idea 配置 SpringBoot 热启动详解,和热启动失效解决方案
    一、idea配置springboot热启动方法1、添加spring-boot-devtools的包,true必须加上。<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><optional>true</optional></d......
  • 外键字段的增删改查,多表查询,正反向的概念,子查询,多表查询之连表查询(基于双下划线
    外键字段的增删改查#多对多的外键增删改查图书和作者是多对多,借助于第三张表实现的,如果想绑定图书和作者的关系,本质上就是在操作第三方表#如何操作第三张表问题:让你给图书添加一个作者,他俩的关系可是多对多#多对多的增删该查#让你给图书id=2添加一个作者id=1b......
  • 16.map插入方式有哪几种?
    16.map插入方式有哪几种?1.用insert函数插入pair数据mapStudent.insert(pair<int,string>(1,"student_one"));2.用insert函数插入value_type数据mapStudent.insert(map<int,string>::value_type(1,"student_one"));3.在insert函数中使用make_pair()函数mapStu......
  • 数据库事务的四种隔离性及Oracle\MySQL默认隔离级别和原因分析
    1事务一个事务中的一系列的处理操作要么全部成功,要么一个都不做。在数据库操作中,一项事务(Transaction)是由一条或多条操作数据库的SQL语句组成的一个不可分割的工作单元。事务的处理结果有两种:1)当事务中的所有步骤全部成功执行时,事务提交,成功;2)如果其中任何一个步骤失败,该事务......