@Transactional 中使用线程锁导致了锁失效，震惊我一整年！

👉 这是一个或许对你有用的社群

🐱 一对一交流/面试小册/简历优化/求职解惑，欢迎加入「芋道快速开发平台」知识星球。下面是星球提供的部分资料： 

• 《项目实战（视频）》：从书中学，往事上“练”
• 《互联网高频面试题》：面朝简历学习，春暖花开
• 《架构 x 系统设计》：摧枯拉朽，掌控面试高频场景题
• 《精进 Java 学习指南》：系统学习，互联网主流技术栈
• 《必读 Java 源码专栏》：知其然，知其所以然

来源：juejin.cn/post/
7311603432925102095

• 一、引出问题
• 1、数据准备
• 二、@Transactional是如何导致锁失效的
• 1、不加锁
• 2、使用锁
• 3、使用锁+@Transactional
• 4、问题分析
• 三、解决方案
• 1、@Transactional单独一个方法
• 2、使用编程式事务

一、引出问题

很多小伙伴使用Spring事务时，为了省事都喜欢使用@Transactional。但是@Transactional配合锁，会导致一些预期之外的问题！

在此举例说明。

1、数据准备

我们将在该表中，实现level数据递减的并发操作。

Controller中，简单模拟10个线程各自执行10次：

基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

• 项目地址：https://github.com/YunaiV/ruoyi-vue-pro
• 视频教程：https://doc.iocoder.cn/video/

二、@Transactional是如何导致锁失效的

1、不加锁

// service代码
public void test() {
    // 简单的select + update 模拟业务场景
    Model model = mapper.choseOne("99");

 // 实现 level -- 操作
    Model updater = new Model();
    updater.setId("99");
    updater.setLevel(model.getLevel() - 1);
    mapper.updateOne(updater);
}

执行结果：我们发现，level只扣减了26，说明存在并发问题！

2、使用锁

// service代码
private Lock lock = new ReentrantLock();

public void test() {
 try {
     //加锁
     lock.lock();
     // 简单的select + update 模拟业务场景
     Model model = mapper.choseOne("99");
 
  // 实现 level -- 操作
     Model updater = new Model();
     updater.setId("99");
     updater.setLevel(model.getLevel() - 1);
     mapper.updateOne(updater);
 } finally {
       lock.unlock(); // 解锁
    }
}

执行结果：我们发现，使用锁是可以控制并发问题。

3、使用锁+@Transactional

// service代码
private Lock lock = new ReentrantLock();

@Transactional
public void test() {
 try {
     //加锁
     lock.lock();
     // 简单的select + update 模拟业务场景
     Model model = mapper.choseOne("99");
 
  // 实现 level -- 操作
     Model updater = new Model();
     updater.setId("99");
     updater.setLevel(model.getLevel() - 1);
     mapper.updateOne(updater);
 } finally {
       lock.unlock(); // 解锁
    }
}

执行结果：我们发现，level只扣减了86！用了@Transactional之后，锁怎么就失效了呢！

4、问题分析

我们都知道，@Transactional是通过使用AOP，在目标方法执行前后进行事务的开启和提交。所以，Lock锁住的代码，其实并没有包含住一整个事务！

通过下面的图理解一下：

当线程A将level设置为99时，此时锁已经释放了，但是事务还没提交！！线程B此时可以获取到锁并进行查询，查询出来的level还是线程A修改之前的100，所以出现了并发问题。

基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

• 项目地址：https://github.com/YunaiV/yudao-cloud
• 视频教程：https://doc.iocoder.cn/video/

三、解决方案

1、@Transactional单独一个方法

private Lock lock = new ReentrantLock();
@Transactional
public void test1() {
    // 简单的select + update 模拟业务场景
    Model model = mapper.choseOne("99");

 // 实现 level -- 操作
    Model updater = new Model();
    updater.setId("99");
    updater.setLevel(model.getLevel() - 1);
    mapper.updateOne(updater);
}

@Autowired
@Lazy
private CommonService commonService;
public void test() {
    try {
        // 加锁
        lock.lock();
        // 自己注入自己，以使用到其代理类
        commonService.test1();
    } finally {
        lock.unlock(); // 解锁
    }
}

执行结果：没有并发问题出现！

或者直接在controller层加锁，也是一样的道理。

2、使用编程式事务

// service代码
private Lock lock = new ReentrantLock();
@Autowired
private PlatformTransactionManager transactionManager;
public void test() {
 try {
     //加锁
     lock.lock();
     // 编程式事务
        TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition());
        
     // 简单的select + update 模拟业务场景
     Model model = mapper.choseOne("99");
 
  // 实现 level -- 操作
     Model updater = new Model();
     updater.setId("99");
     updater.setLevel(model.getLevel() - 1);
     mapper.updateOne(updater);
     
  // 在锁中提交
        transactionManager.commit(status);
 } finally {
       lock.unlock(); // 解锁
    }
}

执行结果：我们发现，将整个事务都锁住，就没问题了！