Solon详解（四）- Solon的事务传播机制

• 2020 年 8 月 22 日
• 筆記
• JAVA, MVC, 事务, 注解

Solon详解系列文章：
Solon详解（一）- 快速入门
Solon详解（二）- Solon的核心
Solon详解（三）- Solon的web开发
Solon详解（四）- Solon的事务传播机制

在前面的篇章里我们已经见识了 Solon 对事务的控制，及其优雅曼妙的形态。该篇将对事务的传播机制做讲解。出于对用户的学习成本考虑，Solon 借签了Spring 的事务传播策略；并友好的支持多数据源事务。

一、为什么要有传播机制？

Solon 的事务是基于 aop 实现的，用者不用关心事务的开始、提交、回滚，只需要在方法上加 @XTran 注解。因为看不到内部情况，所以也会有些疑问：

• 场景一：方法A调用了方法B，但两个方法都有事务，这个时候如果方法B异常：
  • 是让方法B回滚，还是两个一起回滚？
• 场景二：方法A调用了方法B，但是只有方法A加了事务：
  • 是否让方法B也加入方法A的事务？
  • 如果方法B异常，是否回滚方法A？
• 场景三：方法A调用了方法B，两者都有事务，方法B已经正常执行完：
  • 但方法A异常，是否需要回滚方法B的数据？

这个时候事务的传播机制和策略就派上用场了。

二、传播机制生效条件与特点!

基于 aop 来代理事务控制的方案 ，大都是针对于接口或类的之间调用才起效的；所以在同一个类中两个方法之间的调用，传播机制是无效的。了解这一点很重要，不然容易出乌龙事件。

• 特点1：Solon 的事务传播策略与Spring差不多（出于对新用户的学习成本考虑）
• 特点2：Solon 可方便的支持多数据源事务
• 特点3：Solon 可方便支持分库框架或中间件的事务

三、传播机制的策略

下面的类型都是针对于被调用方法来说的，理解起来要想象成两个 service 方法的调用才可以。

• 补充1：如果当前为事务组，required 和 nested 策略的事务，会自动加入事务组
• 补充2：group=true 有时候可当 required 用
• 补充3：一般最常用的是 @XTran(group = true) 和 @Tran 的组合使用

四、XTran 属性说明

五、示例

• 父回滚，子回滚

@XService
public class UserService{
    @XTran
    public void addUser(UserModel user){
        //....
    }
}

@XController
public class DemoController{
    @XInject
    UserService userService; 
    
    //父回滚，子回滚
    //
    @XTran(group = true) 
    @XMapping("/user/add")
    pubblic void addUser(UserModel user){
        userService.addUser(user); 
        throw new RuntimeException("不让你加");
    }
    
    //父回滚，子回滚
    //
    @XTran
    @XMapping("/user/add2")
    pubblic void addUser2(UserModel user){
        userService.addUser(user); 
        throw new RuntimeException("不让你加");
    }
}

• 父回滚，子不回滚

@XService
public class UserService{
    @XTran(policy = TranPolicy.requires_new)
    public void addUser(UserModel user){
        //....
    }
}

@XController
public class DemoController{
    @XInject
    UserService userService; 
    
    //父回滚，子不回滚
    //
    @XTran(group = true) 
    @XMapping("/user/add")
    pubblic void addUser(UserModel user){
        userService.addUser(user); 
        throw new RuntimeException("不让你加；但还是加了:(");
    }
    
    //父回滚，子不回滚
    //
    @XTran
    @XMapping("/user/add2")
    pubblic void addUser2(UserModel user){
        userService.addUser(user); 
        throw new RuntimeException("不让你加；但还是加了:(");
    }
}

• 子回滚父不回滚

@XService
public class UserService{
    @XTran(policy = TranPolicy.nested)
    public void addUser(UserModel user){
        //....
        throw new RuntimeException("不让你加");
    }
}

@XController
public class DemoController{
    @XInject
    UserService userService; 
    
    //子回滚父不回滚
    //
    @XTran(group = true) 
    @XMapping("/user/add")
    pubblic void addUser(UserModel user){
        try{
            userService.addUser(user); 
        }catch(ex){ }
    }
    
    //子回滚父不回滚
    //
    @XTran
    @XMapping("/user/add2")
    pubblic void addUser2(UserModel user){
        try{
            userService.addUser(user); 
        }catch(ex){ }
    }
}

• 多数据源事务示例

@XService
public class UserService{
    @XTran("db1")
    public void addUser(UserModel user){
        //....
    }
}

@XService
public class AccountService{
    @XTran("db2")
    public void addAccount(UserModel user){
        //....
    }
}

@XController
public class DemoController{
    @XInject
    AccountService accountService; 
    
    @XInject
    UserService userService; 
    
    @XTran(group = true) 
    @XMapping("/user/add")
    pubblic void addUser(UserModel user){
        userService.addUser(user);     //会执行db1事务
        
        accountService.addAccount(user);    //会执行db2事务
    }
}