脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Transactional synchronized

当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内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • springboot集成mqtt超级详细步骤

    springboot集成mqtt超级详细步骤

    这篇文章主要介绍了springboot集成mqtt超级详细步骤，本文分步骤结合实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-06-06
  • Java线程池的四种拒绝策略详解

    Java线程池的四种拒绝策略详解

    jdk1.5 版本新增了JUC并发编程包,极大的简化了传统的多线程开发,下面这篇文章主要介绍了Java线程池的四种拒绝策略的相关资料,文中通过实例代码介绍的非常详细，需要的朋友可以参考下
    2022-04-04
  • Java使用Zxing二维码生成的简单示例

    Java使用Zxing二维码生成的简单示例

    ZXing是一个开源的,用Java实现的多种格式的1D/2D条码图像处理库,下面这篇文章主要给大家介绍了关于Java使用Zxing二维码生成的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下
    2023-01-01
  • Java HashMap两种简便排序方法解析

    Java HashMap两种简便排序方法解析

    这篇文章主要介绍了Java HashMap两种简便排序方法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-01-01
  • 解决myBatis返回integer值的问题

    解决myBatis返回integer值的问题

    这篇文章主要介绍了解决myBatis返回integer值的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-11-11
  • MyBatis在insert插入操作时返回主键ID的配置（推荐）

    MyBatis在insert插入操作时返回主键ID的配置（推荐）

    这篇文章主要介绍了MyBatis在insert插入操作时返回主键ID的配置的相关资料,需要的朋友可以参考下
    2017-10-10
  • SpringBoot应用自定义logback日志详解

    SpringBoot应用自定义logback日志详解

    默认情况下，SpringBoot内部使用logback作为系统日志实现的框架，将日志输出到控制台，不会写到日志文件。本篇文章主要讲解下如何自定义logabck.xml以及对logback文件中配置做一个详解，需要的可以参考一下
    2022-10-10
  • springboot通过注解、接口创建定时任务详解

    springboot通过注解、接口创建定时任务详解

    使用SpringBoot创建定时任务其实是挺简单的,这篇文章主要给大家介绍了关于springboot如何通过注解、接口创建这两种方法实现定时任务的相关资料,需要的朋友可以参考下
    2021-07-07
  • SpringBoot详细分析自动装配原理并实现starter

    SpringBoot详细分析自动装配原理并实现starter

    相对于传统意义上的Spring项目，SpringBoot具有开箱即用，简化配置，内置Tomcat等等等等一系列的特点。在这些特点中，最重要的两条就是约定优于配置和自动装配
    2022-07-07
  • 关于Springboot日期时间格式化处理方式总结

    关于Springboot日期时间格式化处理方式总结

    这篇文章主要介绍了关于Springboot日期时间格式化处理方式总结,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-03-03

最新评论