一、原因

外部经过spring容器调用service的方法事务才生效，service类内部方法间相互调用事务不生效，也就是传说中的自调用失效问题。主要原因是 Spring数据库事务的约定,其实现原理是AOP,而AOP的原理是动态代理,在自调用的过程中,是类自身的调用,而不是代理对象去调用,那么就不会产生AOP,这样 Spring就不能把你的代码织入到约定的流程中,于是就产生了现在看到的失败场景。

二、场景

    @Resource
    private UserInfoService userInfoService;
 
    /**
    * 新增
    * @author zhouzhiyao
    * @date 2021/08/03
    **/
    @RequestMapping("/insert")
    @ResponseBody
    public void insert(@RequestBody UserInfo userInfo){
        userInfoService.innerTest(userInfo);
    }

@Resource
    private UserInfoMapper userInfoMapper;
 
    
    @Transactional(rollbackFor = Exception.class)
    public void insert(UserInfo userInfo) {
        userInfoMapper.insert(userInfo);
        System.out.println("我异常了:"+(1/0));
    }
    
    
    public void innerTest(UserInfo userInfo){
        this.insert(userInfo);
    }

这种事务是不具有传递性的，依然会将数据插入到数据库中

image.png

 

image.png

 

三、解决方案

1、引入自身bean

    @Resource
    private UserInfoMapper userInfoMapper;
 
    @Resource
    private UserInfoService userInfoService;
    
    @Transactional(rollbackFor = Exception.class)
    public void insert(UserInfo userInfo) {
        userInfoMapper.insert(userInfo);
        System.out.println("我异常了:"+(1/0));
    }
    
    
    public void innerTest(UserInfo userInfo){
        userInfoService.insert(userInfo);
    }

image.png

image.png

 

事务生效了,没有插进去

2、通过ApplicationContext引入bean

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

@Resource
    private UserInfoMapper userInfoMapper;
 
    @Resource
    private UserInfoService userInfoService;
    
    @Autowired
    ApplicationContext applicationContext;
    
    @Transactional(rollbackFor = Exception.class)
    public void insert(UserInfo userInfo) {
        userInfoMapper.insert(userInfo);
        System.out.println("我异常了:"+(1/0));
    }
    
    
    public void innerTest(UserInfo userInfo){
        //userInfoService.insert(userInfo);
        ((UserInfoService)applicationContext.getBean("userInfoService")).insert(userInfo);
    }

3、通过AopContext获取当前类的代理类

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

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

引入包

        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
        </dependency>

@MapperScan("com.zhouzy.ssm.mapper") //扫描的mapper
@SpringBootApplication
@EnableWebMvc
@EnableAspectJAutoProxy(exposeProxy=true)
public class Webapplication {
    public static void main(String[] args) {
        SpringApplication.run(Webapplication.class, args);
    }
}

@Transactional(rollbackFor = Exception.class)
    public void insert(UserInfo userInfo) {
        userInfoMapper.insert(userInfo);
        System.out.println("我异常了:"+(1/0));
    }
    
    
    public void innerTest(UserInfo userInfo){
        //userInfoService.insert(userInfo);
        //((UserInfoService)applicationContext.getBean("userInfoService")).insert(userInfo);
        ((UserInfoService) AopContext.currentProxy()).insert(userInfo);
    }

作者：枫之羽
链接：https://www.jianshu.com/p/3f3cac1ca2b9
来源：简书
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。