Spring事物基础知识及AOP相关陷阱分析

目录

• 一、事务的定义
• 二、事务的属性
• 三、Spring 事务的隔离级别

• 3.1 隔离级别引出的问题

• 3.1.1 脏读
• 3.1.2 不可重复读
• 3.1.3 幻读

• 5.1 事务只读

• 5.1.1 应用场景
• 5.1.2 使用方式

• 5.2.1 使用方式

• 5.3.1 使用方式

• 6.1 AOP 代理陷阱复现

• 6.2.1 伪代码

• 6.3.1 注入自身
• 6.3.2 使用 ApplicationContext 获取目标类
• 6.3.3 使用 AopContext

@Transactional(propagation = Propagation.REQUIRES, readOnly = true)
public List<Product> findAllProducts() {
    return this.productDao.findAllProducts();
}

// 回滚Exception类型异常
@Transactional(rollbackFor = Exception.class)
public void test1() throws Exception {
    // ..
}
// 回滚自定义类型异常
@Transactional(rollbackForClassName = "org.transaction.demo.CustomException")
public void test2() throws Exception {
    // ..
}
// 不回滚自定义类型异常
@Transactional(noRollbackFor = CustomException.class)
public void test3() throws Exception {
    // ..
}

//设置事务超时时间，单位秒
@Transactional(timeout = 5)
public void test() {
    // ..
}

//每次外层事务调用都会开启一个新事务
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void test() {
    // ..
}

//设置事务隔离级别为串行
@Transactional(isolation = Isolation.SERIALIZABLE))
public void test() {
    // ..
}

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

    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        //代理之前做增强
        System.out.println("代理之前...");
        //根据需要添加事务处理逻辑
        ...
        //调用原有方法 insertMale
        Object obj = method.invoke(object, args);
        //做增强
        System.out.println("代理之后...");
        //根据需要添加事务处理逻辑
        ...
        return obj;
    }

    public void insertMale(User user) {
        user.setGender("male");
        //这里的 this 指向了目标类而不是代理类
        //所以及时下面的方法添加了事务注解，但是并没有除法增强实现，事务也还是不生效的
        this.insertUser(user);
    }

@Service
public class TestService {
    @Autowired
    private TestService testService;
    @Transactional(rollbackFor = RuntimeException.class)
    public void insertUser(User user) {
        userMapper.insertUser(user);
        throw new RuntimeException("");
    }
    /**
     * 内部调用新增方法
     */
    public void insertMale(User user) {
        user.setGender("male");
        //这里使用 字段 testService 调用事务方法
        testService.insertUser(user);
    }
}

@Service
public class TestService {
    @Autowired
    private ApplicationContext applicationContext;
    @Transactional(rollbackFor = RuntimeException.class)
    public void insertUser(User user) {
        userMapper.insertUser(user);
        throw new RuntimeException("");
    }
    /**
     * 内部调用新增方法
     */
    public void insertMale(User user) {
        user.setGender("male");
        //这里使用上下文获取目标类实例
        TestService testService = applicationContext.getBean(TestService.class);
        testService.insertUser(user);
    }
}

@SpringBootApplication
//配置：导出代理对象到AOP上下文
@EnableAspectJAutoProxy(exposeProxy = true)
public class DemoApplication {
}

public class TestService {
    @Transactional(rollbackFor = RuntimeException.class)
    public void insertUser(User user) {
        userMapper.insertUser(user);
        throw new RuntimeException("");
    }
    /**
     * 内部调用新增方法
     */
    public void insertMale(User user) {
        user.setGender("male");
        //使用AOP上下文获取目标代理类
        TestService testService = (TestService) AopContext.currentProxy();
        testService.insertUser(user);
    }
}