最近有个项目需要实现一个表的乐观锁:
最初代码:
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面试资料: BAT面试常问80题 Dubbo服务框架面试专题及答案整理文档 java筑基(基础)面试专题系列...面试必备之乐观锁与悲观锁 面试必问并发编程高级面试专题
2. **并发控制**:考虑到多个用户可能同时预约同一医生,系统需要具备良好的并发控制能力,采用乐观锁或悲观锁策略确保数据的一致性。 3. **性能优化**:针对高并发场景,可以通过缓存机制减少数据库的访问频率,...
另外,对于并发访问,考虑使用乐观锁或者悲观锁策略,保证数据一致性。 测试是系统开发不可或缺的一部分。JUnit是Java的单元测试框架,开发者可以编写测试用例,确保每个模块的功能正常。同时,集成测试确保各模块...
此外,根据秒杀场景,可能还需要设置库存字段为乐观锁,防止并发更新时的冲突。 7. **课程设计与毕业设计**:这个项目非常适合用作毕业设计或课程设计,因为它涵盖了Java Web开发的多个关键点,包括框架集成、...
本系统采用了乐观锁机制来解决这一问题。 2. **数据安全性**:通过加密算法保护敏感数据的安全性,例如对密码进行加密存储。 3. **性能优化**:采用缓存技术减少数据库访问频率,提高系统响应速度。 #### 七、总结 ...
该项目是一个使用IntelliJ IDEA(IDEA)作为集成开发环境,Maven作为构建工具,SSM(Spring、SpringMVC、MyBatis)框架作为基础架构,并结合MySQL数据库实现的高并发商品秒杀系统。下面将详细介绍这个项目涉及的关键...
解决方案是采用乐观锁或悲观锁机制,根据实际情况选择合适的并发控制策略。 - **大数据量处理**:随着用户数量增加,如何高效地处理大量数据?可以考虑引入分布式数据库或NoSQL数据库来解决传统关系型数据库在大数据...
这里需要考虑并发控制,确保同一本书不会被同时借出,可能需要用到乐观锁或者数据库的事务管理。 读者管理模块,包括读者注册、登录、信息修改等功能。涉及到用户认证(Authentication)和授权(Authorization),...
另外,对于并发访问的场景,可能需要引入锁机制或者采用乐观锁策略来避免数据冲突。在性能优化方面,可以对数据库进行索引优化,提高查询效率;对于频繁的读操作,可以考虑使用缓存技术,如Redis,减少数据库压力。 ...
ActiveMQ+RabbitMQ+Kafka、分布式限流面试专题系列:Nginx+zookeeper、集合、开源框架面试题系列:Spring+SpringMVC+MyBatis、面试必备之乐观锁与悲观锁、面试必问并发编程高级面试专题、面试常问必备之MySQL面试55...
- **并发处理**:采用乐观锁或悲观锁机制,有效处理高并发情况下的数据冲突问题。 - **用户体验优化**:通过前端技术(如Bootstrap、jQuery等)提升页面加载速度和交互体验。 #### 二、相关技术介绍 ##### (一)B...
此外,还介绍了如何使用 version 字段进行乐观锁控制。 ##### 2.8 继承策略简化 DAO 编写 通过使用继承策略,可以大大简化 DAO 接口和实现类的编写工作。例如,可以创建一个通用的基类来提供常用的方法实现,子类...
乐观锁在读取数据时不加锁,只有在更新时检查是否有其他线程同时修改;悲观锁则在读取数据时就加锁,防止其他线程修改。 - 分页机制:Hibernate自带的分页是通过Query或Criteria的setFirstResult和setMaxResults...
- **乐观锁**与**悲观锁**:乐观锁通常使用版本号或时间戳来检查数据是否被其他事务修改;悲观锁则是在事务开始时就获取锁,直到事务结束才释放。 - **排他锁**:阻止其他事务读取或写入数据。 - **共享锁**:...
* 悲观锁和乐观锁: + 一个锁机制 + 支持多种锁类型 * 基础集合: + 一个集合机制 + 支持多种集合类型 * Java垃圾回收机制: + 一个垃圾回收机制 + 支持多种垃圾回收策略 * GC是什么?: + 一个垃圾回收器 +...
乐观锁与悲观锁.pdf 开源框架面试.pdf 多线程面试.pdf 并发编程面试(下).pdf 并发编程(上).pdf zookeeper面试.pdf Tomcat面试.pdf SQL优化面试.pdf Spring面试.pdf SpringMVC面试.pdf SpringCloud面试.pdf ...
使用MySQL的悲观锁和乐观锁来处理秒杀请求。 利用Redis的watch监控和AtomicInteger的CAS机制来实现无锁并发控制。 2. 缓存优化 使用Redis作为缓存层,减少数据库的直接访问压力。 通过Redis的原子操作和事务...
如何设计一个秒杀系统系统的特点高效:秒杀涉及大量的并发读和并发写,因此支持高并发访问这点非常关键一致性:秒杀商品减库存的实现方式同样关键,有限数量的商品在同一时刻被很多倍的请求同时来减库存,在大并发...