当Transactional遇上synchronized的解决方法分享

 更新时间:2023年05月07日 14:08:17   作者:思想领袖  
前些时间刚好刷到了有关于“# 【事务与锁】当Transactional遇上synchronized”这一类的文章,感觉这也是工作中经常会遇到的一类问题了。所以就针对这个话题进行了分析并整理了常用的解决方法,希望对大家有所帮助

问题情形

假设代码如下:

//controller层:
@GetMapping("/t1")
@Transactional(rollbackFor = Exception.class)
public void getTest1() {
    String n = countNumService.getCount();
    System.out.println(" t1 : " + n);
    try {
        Thread.sleep(60000);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
}

@GetMapping("/t2")
@Transactional(rollbackFor = Exception.class)
public void getTest2() {
    String n = countNumService.getCount();
    System.out.println(" t2 : " + n);
    // 忽略其他的增删操作
}

//service层:
@Override
@Transactional(rollbackFor = Exception.class)
public synchronized String getCount() {
    // 获取
    CountNum countNum = countNumMapper.selectById(1);

    countNum.setNumber(countNum.getNumber() + 1);
    // 修改
    countNumMapper.updateById(countNum);

    return countNum.getNumber().toString();
}

问题分析

首先,在 getTest1()getTest2() 这两个方法中都加了 @Transactional 注解,因此它们会分别开启自己的事务。假设在某一刻,两个线程同时调用了 /t1/t2 接口,并且 /t1 接口中执行了较长的睡眠操作,于是 /t2 的业务逻辑率先完成,并且更新了数据库中的Number字段。

随后 /t1 的业务逻辑也完成了,但是由于之前被阻塞了 60 秒钟,此时读取到的计数器值已经过期了,不能反映最新的状态。因此 /t1 返回的结果将是过期的数据,与 /t2 返回的结果不一致。所以这段代码存在一个并发问题,可能导致数据的不一致性

解决方法

这里我给出常用的解决方法:

  • getCount() 方法上的 synchronized 去掉,使用乐观锁的方式来控制并发访问。
  • /t1/t2 两个接口的事务设置为同一个事务,即两个接口共享同一个事务上下文。可以通过 Spring 的声明式事务管理机制来实现。(在 Spring 框架中,我们可以使用 @Transactional 注解来声明式地管理事务。使用 PROPAGATION_REQUIRED 属性可以表示当前方法需要加入到一个存在的事务中,如果不存在,则开启新的事务。)
  • getCount() 方法中,进行增量更新,而不是直接把Number字段加 1,例如使用 update count_num set number = number + 1 where id = ? 等 SQL 语句来实现。
  • 保留synchronized关键字的情况下,添加事务管理器进行手动事务管理。

代码参考

1.乐观锁方案

@Override
@Transactional(rollbackFor = Exception.class)
public String getCount() {
    CountNum countNum = countNumMapper.selectById(1);
    // 使用版本号作为乐观锁
    int version = countNum.getVersion();
    countNum.setNumber(countNum.getNumber() + 1);
    countNum.setVersion(version + 1);
    // 更新操作必须要包含版本号字段
    int rows = countNumMapper.updateById(countNum);
    if (rows == 0) {
        throw new OptimisticLockException("事务中更新失败");
    }
    return countNum.getNumber().toString();
}

2.将 /t1 和 /t2 两个接口的事务设置为同一个事务。在 CountNumService 类的事务注解上添加了 propagation = Propagation.REQUIRED 属性,表示当前方法需要加入到一个已存在的事务中。此时,如果 /t1/t2 调用的是同一个 CountNumService 实例,则它们将共享同一个事务上下文。

@Service
public class CountNumService {
    @Autowired
    private CountNumMapper countNumMapper;
    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
    public String getCount() {
         // 与之前代码相同
    }
}
@RestController
public class CountNumController {
    @Autowired
    private CountNumService countNumService;
    @GetMapping("/t1")
    public void getTest1() {
        String n = countNumService.getCount();
        System.out.println(" t1 : " + n);
        try {
            Thread.sleep(60000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
    @GetMapping("/t2")
    public void getTest2() {
        String n = countNumService.getCount();
        System.out.println(" t2 : " + n);
        // 忽略其他的增删操作
    }
}

3.SQL中增量更新方案

@Mapper
public interface CountNumMapper {
    @Update("UPDATE count_num SET number = number + 1 WHERE id = 1")
    int updateNumber();
}
@Override
@Transactional(rollbackFor = Exception.class)
public String getCount() {
    // 直接执行 SQL 语句进行增量更新操作
    countNumMapper.updateNumber();
    // 再查询一次获取最新值
    CountNum countNum = countNumMapper.selectById(1);
    return countNum.getNumber().toString();
}

4.手动事务管理方案

@Service
public class CountNumService {
    @Autowired
    private CountNumMapper countNumMapper;

    // 使用spring事务管理器
    @Autowired
    private PlatformTransactionManager transactionManager;

    public synchronized String getCount() {
        TransactionStatus status = null;
        try {
            DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
            //将传播行为设置为 PROPAGATION_REQUIRED,以确保当前方法在事务内执行:
            definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
            //获取当前事务的状态信息:
            status = transactionManager.getTransaction(definition);
            
            CountNum countNum = countNumMapper.selectById(1);
            countNum.setNumber(countNum.getNumber() + 1);

            int rows = countNumMapper.updateById(countNum);
            if (rows == 0) {
                throw new RuntimeException("事务中更新失败");
            }
            //提交事务:
            transactionManager.commit(status);
            return countNum.getNumber().toString();
        } catch (Exception e) {
            if (status != null) {
                //回滚事务:
                transactionManager.rollback(status);
            }
            throw e;
        }
    }
}

到此这篇关于当Transactional遇上synchronized的解决方法分享的文章就介绍到这了,更多相关Transactional synchronized内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 如何基于JWT实现接口的授权访问详解

    如何基于JWT实现接口的授权访问详解

    授权是最常见的JWT使用场景,下面这篇文章主要给大家介绍了关于如何基于JWT实现接口的授权访问的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下
    2022-02-02
  • Groovy的规则脚本引擎实例解读

    Groovy的规则脚本引擎实例解读

    这篇文章主要介绍了Groovy的规则脚本引擎实例解读,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-03-03
  • 应用Java泛型和反射导出CSV文件的方法

    应用Java泛型和反射导出CSV文件的方法

    这篇文章主要介绍了应用Java泛型和反射导出CSV文件的方法,通过一个自定义函数结合泛型与反射的应用实现导出CSV文件的功能,具有一定的参考借鉴价值,需要的朋友可以参考下
    2014-12-12
  • SpringBoot 2.x 整合Lombok的方法示例

    SpringBoot 2.x 整合Lombok的方法示例

    Spring Boot是非常高效的开发框架,lombok是一套代码模板解决方案,将极大提升开发的效率,这篇文章主要介绍了SpringBoot 2.x 整合Lombok的方法示例,感兴趣的小伙伴们可以参考一下
    2018-06-06
  • mybatis-plus开启sql日志打印的三种方法

    mybatis-plus开启sql日志打印的三种方法

    本文主要介绍了mybatis-plus开启sql日志打印的三种方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-05-05
  • Spring中自动注入的两种方式总结

    Spring中自动注入的两种方式总结

    Spring的核心技术IOC(Intorol of Converse控制反转)的实现途径是DI(dependency Insert依赖注入)。而依赖注入(DI)的实现方式又有两种,xml方式和注解方式。本文就来详细聊聊这两个方式,需要的可以了解一下
    2022-10-10
  • Java 利用枚举实现接口进行统一管理

    Java 利用枚举实现接口进行统一管理

    这篇文章主要介绍了Java 利用枚举实现接口进行统一管理,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2021-02-02
  • 基于Spring Batch 配置重试逻辑

    基于Spring Batch 配置重试逻辑

    这篇文章主要介绍了Spring Batch 配置重试逻辑,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • 基于SpringBoot接口+Redis解决用户重复提交问题

    基于SpringBoot接口+Redis解决用户重复提交问题

    当网络延迟的情况下用户多次点击submit按钮导致表单重复提交,用户提交表单后,点击浏览器的【后退】按钮回退到表单页面后进行再次提交也会出现用户重复提交,办法有很多,我这里只说一种,利用Redis的set方法搞定,需要的朋友可以参考下
    2023-10-10
  • Java读取本地json文件及相应处理方法

    Java读取本地json文件及相应处理方法

    今天小编就为大家分享一篇Java读取本地json文件及相应处理方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-09-09

最新评论