`
koloum
  • 浏览: 11283 次
  • 性别: Icon_minigender_1
  • 来自: 浙江
社区版块
存档分类
最新评论

Spring3+mysql 实现乐观锁的优化解决办法

阅读更多
最近有个项目需要实现一个表的乐观锁:

最初代码:
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);
分享到:
评论

相关推荐

    Java架构面试资料合集Spring面试专题及答案MySQL面试Redis面试资料.zip

    Java架构面试资料合集Spring面试专题及答案MySQL面试Redis面试资料: BAT面试常问80题 Dubbo服务框架面试专题及答案整理文档 java筑基(基础)面试专题系列...面试必备之乐观锁与悲观锁 面试必问并发编程高级面试专题

    基于ssm+mysql的智慧医疗预约挂号管理系统源码数据库.docx

    2. **并发控制**:考虑到多个用户可能同时预约同一医生,系统需要具备良好的并发控制能力,采用乐观锁或悲观锁策略确保数据的一致性。 3. **性能优化**:针对高并发场景,可以通过缓存机制减少数据库的访问频率,...

    IDEA+MySql学生管理系统.7z

    另外,对于并发访问,考虑使用乐观锁或者悲观锁策略,保证数据一致性。 测试是系统开发不可或缺的一部分。JUnit是Java的单元测试框架,开发者可以编写测试用例,确保每个模块的功能正常。同时,集成测试确保各模块...

    基于SSM+mysql框架的高并发和商品秒杀项目.zip

    此外,根据秒杀场景,可能还需要设置库存字段为乐观锁,防止并发更新时的冲突。 7. **课程设计与毕业设计**:这个项目非常适合用作毕业设计或课程设计,因为它涵盖了Java Web开发的多个关键点,包括框架集成、...

    基于ssm+mysql的小型超市仓库管理系统源码数据库.doc

    本系统采用了乐观锁机制来解决这一问题。 2. **数据安全性**:通过加密算法保护敏感数据的安全性,例如对密码进行加密存储。 3. **性能优化**:采用缓存技术减少数据库访问频率,提高系统响应速度。 #### 七、总结 ...

    基于IDEA+Maven+SSM框架+mysql的高并发的商品秒杀项目.zip

    该项目是一个使用IntelliJ IDEA(IDEA)作为集成开发环境,Maven作为构建工具,SSM(Spring、SpringMVC、MyBatis)框架作为基础架构,并结合MySQL数据库实现的高并发商品秒杀系统。下面将详细介绍这个项目涉及的关键...

    基于ssm+mysql学习交流平台源码数据库.doc

    解决方案是采用乐观锁或悲观锁机制,根据实际情况选择合适的并发控制策略。 - **大数据量处理**:随着用户数量增加,如何高效地处理大量数据?可以考虑引入分布式数据库或NoSQL数据库来解决传统关系型数据库在大数据...

    Java课程设计-图书管理系统(SSM+MySQL)

    这里需要考虑并发控制,确保同一本书不会被同时借出,可能需要用到乐观锁或者数据库的事务管理。 读者管理模块,包括读者注册、登录、信息修改等功能。涉及到用户认证(Authentication)和授权(Authorization),...

    课程设计,宾馆客房预订系统,使用Vue+SpringBoot+MySQL.zip

    另外,对于并发访问的场景,可能需要引入锁机制或者采用乐观锁策略来避免数据冲突。在性能优化方面,可以对数据库进行索引优化,提高查询效率;对于频繁的读操作,可以考虑使用缓存技术,如Redis,减少数据库压力。 ...

    Java程序员面试题全.zip

    ActiveMQ+RabbitMQ+Kafka、分布式限流面试专题系列:Nginx+zookeeper、集合、开源框架面试题系列:Spring+SpringMVC+MyBatis、面试必备之乐观锁与悲观锁、面试必问并发编程高级面试专题、面试常问必备之MySQL面试55...

    基于ssm+mysql的高校学生社团管理系统源码数据库.docx

    - **并发处理**:采用乐观锁或悲观锁机制,有效处理高并发情况下的数据冲突问题。 - **用户体验优化**:通过前端技术(如Bootstrap、jQuery等)提升页面加载速度和交互体验。 #### 二、相关技术介绍 ##### (一)B...

    spring+hibernate多层web开发eclipse下的开发模板.doc

    此外,还介绍了如何使用 version 字段进行乐观锁控制。 ##### 2.8 继承策略简化 DAO 编写 通过使用继承策略,可以大大简化 DAO 接口和实现类的编写工作。例如,可以创建一个通用的基类来提供常用的方法实现,子类...

    struts+hibernate+Spring面试题

    乐观锁在读取数据时不加锁,只有在更新时检查是否有其他线程同时修改;悲观锁则在读取数据时就加锁,防止其他线程修改。 - 分页机制:Hibernate自带的分页是通过Query或Criteria的setFirstResult和setMaxResults...

    Java面试解析总结:Java+Redis+数据库+解决方案+分布式...docx

    - **乐观锁**与**悲观锁**:乐观锁通常使用版本号或时间戳来检查数据是否被其他事务修改;悲观锁则是在事务开始时就获取锁,直到事务结束才释放。 - **排他锁**:阻止其他事务读取或写入数据。 - **共享锁**:...

    独孤九剑-------面试题

    * 悲观锁和乐观锁: + 一个锁机制 + 支持多种锁类型 * 基础集合: + 一个集合机制 + 支持多种集合类型 * Java垃圾回收机制: + 一个垃圾回收机制 + 支持多种垃圾回收策略 * GC是什么?: + 一个垃圾回收器 +...

    Java、数据库、spring框架等面试题及答案

    乐观锁与悲观锁.pdf 开源框架面试.pdf 多线程面试.pdf 并发编程面试(下).pdf 并发编程(上).pdf zookeeper面试.pdf Tomcat面试.pdf SQL优化面试.pdf Spring面试.pdf SpringMVC面试.pdf SpringCloud面试.pdf ...

    (源码)基于SpringBoot和Redis的秒杀系统.zip

    使用MySQL的悲观锁和乐观锁来处理秒杀请求。 利用Redis的watch监控和AtomicInteger的CAS机制来实现无锁并发控制。 2. 缓存优化 使用Redis作为缓存层,减少数据库的直接访问压力。 通过Redis的原子操作和事务...

    seconds-kill:基于Springboot + Redis + Kafka的秒杀系统,乐观锁+缓存+限流+异步,TPS从500优化到3000

    如何设计一个秒杀系统系统的特点高效:秒杀涉及大量的并发读和并发写,因此支持高并发访问这点非常关键一致性:秒杀商品减库存的实现方式同样关键,有限数量的商品在同一时刻被很多倍的请求同时来减库存,在大并发...

Global site tag (gtag.js) - Google Analytics