@Transactional 中使用线程锁导致了锁失效,惊了!
共 6364字,需浏览 13分钟
·
2024-05-25 00:00
阅读本文大概需要 2.8 分钟。
来自:juejin.cn/post/7311603432925102095
一、引出问题
@Transactional
。但是@Transactional
配合锁,会导致一些预期之外的问题!
1、数据准备
二、@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);
}
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(); // 解锁
}
}
@Transactional
之后,锁怎么就失效了呢!
4、问题分析
@Transactional
是通过使用AOP,在目标方法执行前后进行事务的开启和提交。所以,Lock锁住的代码,其实并没有包含住一整个事务!
三、解决方案
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(); // 解锁
}
}
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(); // 解锁
}
}
推荐阅读:
《云服务器限时免费领取》 轻量级服务器-2核4G5M 1个月 云服务器-2核4G3M 1个月 ⬇戳阅读原文领取 朕已阅