转载

拜托，不要在问我@Transactional注解了

前言

在一个阳光明媚的周五，我正开心的敲着代码，突然看到一个技术交流群中正在火热的讨论着某个话题，好奇心驱使着我点开看了一下，原来是某位同僚正在远程面试，面试官出了这样的一道题

我心里默默的笑了笑，这特喵的该不会是哪个crud仔自己排查不出来，所以找面试者来套方案的吧。

本想帮一帮这位同僚，奈何公司规定：上班时间不允许装逼。

ps：突然想到自己似乎也没有对这方面知识做过系统的学习，于是默默的拿出小本本记录了下来。

ps：先明确一点，要使用事务，首先你的数据库肯定得支持事务，你说你数据库都不支持事务，那就算神仙来了也没用的好吧。

事务不生效的场景

非事务方法内部调用不生效

Controller

/**
 * 用于验证事务不生效的场景
 * @author hcq
 * @date 2020/4/24 22:27
 */
@RestController
@RequestMapping("/student/transaction")
@AllArgsConstructor
public class TransactionController {

    private TransactionService transactionService;

    /**
     * 非事务方法内部调用 事务不生效
     */
    @RequestMapping("/innerCall")
    public String  innerCall(){
        Student stu=new Student(IdUtils.get32UUID(),"张三",22,"男");
        transactionService.innerCall(stu);
        return "SUCCESS";
    }


}
复制代码

Service

@Service
@AllArgsConstructor
public class TransactionServiceImpl implements TransactionService {

    private StudentMapper studentMapper;

    @Override
    public void innerCall(Student student) {
        saveRecordAndThrowRuntimeException(student);
    }

    @Override
    @Transactional(rollbackFor = {})
    public void saveRecordAndThrowRuntimeException(Student student){
        studentMapper.insert(student);
        throw new RuntimeException("抛出运行时异常");
    }

}
复制代码

可以看到最后的结果是，数据库中成功保存了这个数据（也就是事务没有生效）

然后我们再来分析一下为什么事务会不生效（这就很考验你的java功底喽）。

之前我也因为这个问题困扰过一段时间，后来所幸遇到高人指点，高人告诉我“ java中的方法调用，调用的只是代码片段”，也就说方法间的调用其实和你直接把另一个方法的代码复制过来是一样的效果。所以代码在执行时就变成了下面这个样子。

@Service
@AllArgsConstructor
public class TransactionServiceImpl implements TransactionService {

    private StudentMapper studentMapper;

    @Override
    public void innerCall(Student student) {
        studentMapper.insert(student);
        throw new RuntimeException("抛出运行时异常");
    }

    @Override
    @Transactional(rollbackFor = {})
    public void saveRecordAndThrowRuntimeException(Student student){
        studentMapper.insert(student);
        throw new RuntimeException("抛出运行时异常");
    }

}
复制代码

看到这里你应该已经明白了为什么事务没生效了吧。（因为压根就没有@Transaction注解啊）

对此我还有另一种解释：Controller中所依赖的Service其实是IOC提供的一个代理对象，而这个代理对象在调用具体的方法时，会通过判断该方法上面是否包含@Transactional注解来决定是否要开启事务，而这个innerCall方法没有包含此注解，所以Spring代理对象会认为此方法不需要开启事务，在innerCall方法调用事务方法的过程中，其实方法的调用者已经由Spring代理对象转换为了这个类的原生对象（也就是this关键字）。而我们的这个原生对象是没有对@Transaction注解做任何处理的，所以事务自然也不会生效。

ps：就算看不懂也没关系哦，这个作者的脑洞有点大。哈哈

抛出检查异常事务不回滚（需指定要回滚的异常才会回滚）

Controller

@RestController
@RequestMapping("/student/transaction")
@AllArgsConstructor
public class TransactionController {

    private TransactionService transactionService;

    /**
     * 检查异常（Checked Exception）事务不回滚
     */
    @RequestMapping("/checkedException")
    public String  checkedException() throws IOException {
        Student stu=new Student(IdUtils.get32UUID(),"张三",22,"男");
        transactionService.checkedException(stu);
        return "SUCCESS";
    }

    /**
     * 检查异常（Checked Exception）事务回滚
     */
    @RequestMapping("/checkedExceptionAndRollBack")
    public String  checkedExceptionAndRollBack() throws IOException {
        Student stu=new Student(IdUtils.get32UUID(),"张三",22,"男");
        transactionService.checkedExceptionAndRollBack(stu);
        return "SUCCESS";
    }
}
复制代码

Service

@Service
@AllArgsConstructor
public class TransactionServiceImpl implements TransactionService {

    private StudentMapper studentMapper;

    @Override
    @Transactional(rollbackFor = {})
    public void checkedException(Student stu) throws IOException {
        studentMapper.insert(stu);
        throw new IOException("找不到XXX.xml");
    }

    /**
     * 指明IOException异常进行回滚
     * 此处需要注意的是不能在本方法中把IOException异常catch掉，否则也会导致事务无法回滚
     * @param stu 学生信息
     * @throws IOException IO异常
     */
    @Override
    @Transactional(rollbackFor = {IOException.class})
    public void checkedExceptionAndRollBack(Student stu) throws IOException {
        checkedException(stu);
    }
}
复制代码

最终的执行结果是：

checkedException：成功的添加了一条记录（事务没有回滚）
checkedExceptionAndRollBack：没有添加记录，事务回滚

“ 抛出检查异常事务不会回滚 ” 和 “ 抛出检查异常事务不会生效 ” ，这是两个不同的概念，事务有没有生效是由IOC代理对象有没有捕获到异常决定的，而事务捕获到检查异常时要不要回滚，则应该是由你来告诉这个代理对象。

相关特性

传播机制

传播机制是Spring中定义的一个概念，在mysql中并不存在这一概念，它规定了多个事务之间应该以何种方式进行传播。

Spring为此定义了7种事务的传播途径

传播途径	描述/结论
Propagation.REQUIRED（必要的）	Spring默认的传播机制，若存在事务则在原事务中运行，若不存在事务则创建一个事务
Propagation.SUPPORTS（支持）	支持当前事务，如果不存在事务，则以非事务方式执行。
Propagation.MANDATORY（强制的）	强势要求使用事务，若当前环境不存在事务则抛出异常
Propagation.REQUIRES_NEW（新事务）	把当前事务挂起（暂停），创建一个新的事务去执行，执行完毕后恢复原事务
Propagation.NOT_SUPPORTED（不支持）	把当前事务挂起（暂停），以非事务的方式去运行，运行完毕后恢复原事务
Propagation.NEVER（决不使用）	绝不使用事务，如果当前环境存在事务则抛出异常
Propagation.NESTED(嵌套的)	若当前环境存在事务则嵌套在当前事务中执行（类似于REQUIRED）

Propagation.REQUIRED

Spring默认的传播机制，若存在事务则在原事务中运行，若不存在事务则创建一个事务

Controller

/**
 * 用于验证事务Propagation.REQUIRED级别的传播机制
 *  Propagation.REQUIRED 是默认的传播机制
 * @author hcq
 * @date 2020/4/24 22:34
 */
@RestController
@RequestMapping("/student/propagation/required")
@AllArgsConstructor
@Slf4j
public class RequiredPropagationController {

    private StudentMapper studentMapper;
    private RequiredPropagationService requiredPropagationService;

    /**
     * 结论1：不存在事务则创建一个事务 （经常被使用到的场景）
     */
    @RequestMapping("/noExistTransaction")
    public String noExistTransaction(){
        Student stu=new Student(IdUtils.get32UUID(),"张三",22,"男");
        requiredPropagationService.saveRecordAndThrowRuntimeException(stu);
        return "SUCCESS";
    }

    /**
     * 结论2：若存在事务则在原事务中运行 （经常被使用到的场景）
     *  通过观察test001是否被回滚？可以验证Controller中与Service中的是否是同一个事务
     *  
     *  若test001被回滚则说明是同一个事务
     *  若test001未回滚则表示不是同一个事务
     */
    @RequestMapping("/existTransaction")
    @Transactional(rollbackFor = {})
    public String  existTransaction(){
        studentMapper.insert(new Student("test001","小红",22,"女"));
        Student stu=new Student(IdUtils.get32UUID(),"张三",22,"男");
        try {
            requiredPropagationService.saveRecordAndThrowRuntimeException(stu);
        }catch (Exception e){
           log.info("捕获异常，防止其影响观察结果！");
        }
        return "SUCCESS";
    }
}
复制代码

Service

@Service
@AllArgsConstructor
public class RequiredPropagationServiceImpl implements RequiredPropagationService {

    private StudentMapper studentMapper;

    @Override
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = {})
    public void saveRecordAndThrowRuntimeException(Student student) {
        studentMapper.insert(student);
        throw new RuntimeException("抛出运行时异常");
    }
}
复制代码

执行结果：

场景1：事务回滚，数据库中无数据，说明确实存在事务，结论1正确
场景2：事务回滚，数据库中无数据。且后台打印了UnexpectedRollbackException异常日志，提示：”Transaction rolled back because it has been marked as rollback-only“，我们来分析一下这个过程，首先service抛出异常后将事务标记为仅回滚状态，然后controller中将service抛出的异常catch掉后想要提交事务，但是发现此事务已经被标记为仅回滚，所以又抛出了UnexpectedRollbackException异常。由此可得出结论2正确