SpringBoot @Transactional声明事务无效问题

今天有个同事遇到一个问题，由于业务需求要求，在一个Service的一个方法A中有一个for循环，每次循环里面的业务逻辑有可能发生异常，这个时候就需要将这个循环内的所有数据库操作给回滚掉，但是又不能影响到之前循环里数据的更改，并且后面的循环里不发生异常的情况下也需要正常操作数据库。同事尝试了很久结果还是不能满足业务需求。
大概业务逻辑需求如下：

for(int i = 1;i<5;i++){
  /***
  **业务逻辑： 例如：每循环一次向数据库user表插入一条记录
**/
}

如果第一次循环没有发生异常，第二次循环发生异常，第三、四次循环都没有发生异常，那么最后数据表里有 1 3 4 三条记录，第二次插入数据没有写入，所以不能单单的在Service上加上事务。
按照这个业务需求我的想法在Service上加上@Transactional事务，将可能发生异常的业务代码提到另外一个方法B中，在B方法上面加上一个@Transactional注解，并且将B方法上事务传播行为改成PROPAGATION_REQUIRES_NEW（创建新事务，无论当前存不存在事务，都创建新事务），并且在第二次循环手动设置一个算术异常，Demo代码如下：

package com.dubboconsumer.dubboConsumer.service.imp;

import com.dubboconsumer.dubboConsumer.Mapper.DemoMapper;
import com.dubboconsumer.dubboConsumer.model.User;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

@Service
@Transactional
public class DemoService {
    @Resource
    private DemoMapper demoMapper;

    public void A(){
        for (int i = 1;i<5;i++){
           try {
               this.B(i);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void B(int i){//可能发生异常的方法B
            User user = new User();
            if (i==2){
                user.setId(2);
                user.setName("No"+i);
                user.setAge(i);
                demoMapper.insertUser(user);//往user表插入一条用户记录
                int a = 1/0;//抛出ArithmeticException异常
            }else {
                user.setId(i);
                user.setName("Yes"+i);
                user.setAge(i);
                demoMapper.insertUser(user);
            }
    }
}

运行代码，在代码执行到第二个循环int a = 1/0 时抛出异常，异常被方法A中catch到，但是数据库没有回滚，而是插入了 1、 2、3、4 四条记录，说明事务并没有生效。
然后网上找各种帖子，各种尝试：

首先数据库方面，因为我们的开发库之前就有事务回滚各种操作，我本地数据库（写demo用的本地库）的存储引擎也是InnoDB（mysql的引擎是InnoDB才支持事务回滚）。
异常类型方面，在方法B中的业务逻辑加上了try.catch块,然后再手动抛出一个RuntimeException，@Transactional加上rollbackFor = Exception.class

`package com.dubboconsumer.dubboConsumer.service.imp;

import com.dubboconsumer.dubboConsumer.Mapper.DemoMapper;
import com.dubboconsumer.dubboConsumer.model.User;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

@Service
@Transactional
public class DemoService {
    @Resource
    private DemoMapper demoMapper;


    public void A(){
        for (int i = 1;i<5;i++){
            try {
                this.B(i);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
    @Transactional(rollbackFor = Exception.class，propagation = Propagation.REQUIRES_NEW)
    public void B(int i){
        try {
            User user = new User();
            if (i==2){
                user.setId(2);
                user.setName("No"+i);
                user.setAge(i);
                demoMapper.insertUser(user);
                int a = 1/0;//抛出ArithmeticException异常
            }else {
                user.setId(i);
                user.setName("Yes"+i);
                user.setAge(i);
                demoMapper.insertUser(user);
            }
        }catch (Exception e){
            e.printStackTrace();
            //TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            throw new RuntimeException("插入出错！");
        }
    }
}

这样修改之后执行到 int a = 1/0; 异常会被try.catch到，但是再手动抛出异常时，异常又被方法A中Catch到，数据库里还是插入了1、2、3、4四条数据，所以事务并没有生效。

还有帖子说手动回滚，所以上面代码catch中加上TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); 但是结果并没有回滚，反而A中catch到报出错误：

org.springframework.transaction.NoTransactionException: No transaction aspect-managed TransactionStatus in scope
    at org.springframework.transaction.interceptor.TransactionAspectSupport.currentTransactionStatus(TransactionAspectSupport.java:122)
    at com.dubboconsumer.dubboConsumer.service.imp.DemoService.B(DemoService.java:44)
    at com.dubboconsumer.dubboConsumer.service.imp.DemoService.A(DemoService.java:20)
    at com.dubboconsumer.dubboConsumer.service.imp.DemoService$$FastClassBySpringCGLIB$$c7449c96.invoke(<generated>)
    at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:669)
    ...

大概意思是这个类里面没有事务，不能进行手动回滚。

问题还是没有解决，然后我又去网上翻各种帖子，在一个类似问题帖子回复中看到说，事务没有回滚可能是因为写在同一个类里，然后我就试了新建一个DoInsertService ，将方法B中的业务逻辑放到这个新建的DoInsertService ，并且在Service上加上@Transactional，代码如下：

package com.dubboconsumer.dubboConsumer.service.imp;

import com.dubboconsumer.dubboConsumer.Mapper.DemoMapper;
import com.dubboconsumer.dubboConsumer.model.User;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

@Repository
@Transactional(rollbackFor = Exception.class)
public class DoInsertService {
    @Resource
    private DemoMapper demoMapper;

    public void B(int i){
        User user = new User();
        if (i==2){
            user.setId(i);
            user.setName("No"+i);
            user.setAge(i);
            demoMapper.insertUser(user);
            int a = 1/0; //抛出ArithmeticException异常
        }else {
            user.setId(i);
            user.setName("Yes"+i);
            user.setAge(i);
            demoMapper.insertUser(user);
        }
    }
}

然后在原来的Service中调用DoInsertService的B方法，

package com.dubboconsumer.dubboConsumer.service.imp;

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;

@Service
public class DemoService {
    @Resource
    private DoInsertService doInsertService;

    public void A(){
        for (int i = 1;i<5;i++){
            try {
                doInsertService.B(i);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
}

运行代码A中catch到算术异常，这时再看数据库中数据，只有1、3、4三条记录，说明插入2这个数据时发生异常数据被回滚，没有插入数据库。

网上看到说原因是： Spring之所以可以对开启@Transactional的方法进行事务管理，是因为Spring为当前类生成了一个代理类，然后在执行相关方法时，会判断这个方法有没有@Transactional注解，如果有的话，则会开启一个事务。
但是，上面同一个类中A调用方式时，在调用B时，使用的并不是代理对象，从而导致this.B(i)时也不是代理对象，从而导致@Transactional失败。所以，Spring 从同一个类中的某个方法调用另一个有注解(@Transactional)的方法时，事务会失效，些事务的时候一定要注意到这一点。