设为首页 收藏本站
查看: 727|回复: 0

[经验分享] Spring3+mysql 实现乐观锁的优化解决办法

[复制链接]

尚未签到

发表于 2016-10-17 08:43:25 | 显示全部楼层 |阅读模式
最近有个项目需要实现一个表的乐观锁:
最初代码:
int flag=0;
do{
UserInfo info=userInfoMapper.getByUserId(userId);
if(userInfoMapper.increaseBalance(userId,money,info.getVersion())>0){ //修改账户信息同时查看version状态
flag= 1;
}
}while(flag==0);


其中increaseBalance方法对应代码:
update user_info set
balance=balance+#{balance},
version=version+1
where user_id=#{userId} and version=#{version}

后来发现这样完全不行,因为mysql的默认隔离级别REPEATABLE-READ,即在一个事务中读取一个账户信息以及version总是不变的。
然后网上搜索了一圈,看到了两种方式:
1.例如这篇文章说的:http://sunjun041640.blog.163.com/blog/static/25626832201311184948586/
直接将数据库默认事务隔离级别改为READ_COMMITTED。
虽然方法是可行的,但是我这个项目有大量关于资金的操作,这样会更不安全。
2,采用spring的template,callback技术,在执行事务代码中发现特定的OptimisticLockFailureException 继续重新执行事务(这种方式对代码改动比较大,而且对整个长事务进行回滚比较耗费性能)
@Override
public <T> T execute(OptimisticLockingCallback<T> callback) throws Exception {
while (true) {
try {
return callback.doServiceInTransaction();
}
catch (Throwable e) {
if (e instanceof OptimisticLockFailureException) {
LOG.warn(e.getMessage());
continue;
} else {
LOG.error(e);
if (callback.throwWhenFailed()) {
throw new Exception(e);
} else {
return callback.failed();
}
}
}
}
}

苦苦思索的时候,突然脑洞大开,再回看第一版代码碰到的问题,其实就是更新失败重新获取userinfo信息不是最新的(Mysql隔离级别导致),那只要更新该表中对应的userid的信息,不就解决了
于是在数据库中新增加一个字段conflict,在更新账户失败时直接调用如下语句:
update user_info set conflict=conflict+1 where id=#{id}

这样既不需要更改数据库的隔离级别,对现有代码的改动也是最小的
最终成品:

int flag=0;
do{
UserInfo info=userInfoMapper.getByUserId(userId);
if(userInfoMapper.increaseBalance(userId,money,info.getVersion())>0){ //修改账户信息同时查看version状态
flag= 1;
}else{
if(userInfoMapper.updateConflict(info.getId())==0){ //出异常了
throw new RuntimeException("账户异常");
}
}
}while(flag==0);

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-287209-1-1.html 上篇帖子: MySQL Cluster管理节点配置文件-数据节点4G内存 下篇帖子: 解决com.mysql.jdbc.NonRegisteringDriver的内存泄漏
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表