java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > Transactional synchronized

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

作者：思想领袖

前些时间刚好刷到了有关于“# 【事务与锁】当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 返回的结果不一致。所以这段代码存在一个并发问题，可能导致数据的不一致性。

解决方法

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

代码参考

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

您可能感兴趣的文章:
阅读全文