Spring3+mysql 实现乐观锁的优化解决办法_JAVA_编程开发_程序员俱乐部

最近有个项目需要实现一个表的乐观锁：

最初代码：

class="java" name="code">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);