上一篇文章《MySQL悲观锁总结和实践》谈到了MySQL悲观锁,但是悲观锁并不是适用于任何场景,它也有它存在的一些不足,因为悲观锁大多数情况下依靠数据库的锁机制实现,以保证操作最大程度的独占性。如果加锁的时间过长,其他用户长时间无法访问,影响了程序的并发访问性,同时这样对数据库性能开销影响也很大,特别是对长事务而言,这样的开销往往无法承受。所以与悲观锁相对的,我们有了乐观锁,具体参见下面介绍:
乐观锁介绍:
乐观锁( Optimistic Locking ) 相对悲观锁而言,乐观锁假设认为数据一般情况下不会造成冲突,所以在数据进行提交更新的时候,才会正式对数据的冲突与否进行检测,如果发现冲突了,则让返回用户错误的信息,让用户决定如何去做。那么我们如何实现乐观锁呢,一般来说有以下2种方式:
1.使用数据版本(Version)记录机制实现,这是乐观锁最常用的一种实现方式。何谓数据版本?即为数据增加一个版本标识,一般是通过为数据库表增加一个数字类型的 “version” 字段来实现。当读取数据时,将version字段的值一同读出,数据每更新一次,对此version值加一。当我们提交更新的时候,判断数据库表对应记录的当前版本信息与第一次取出来的version值进行比对,如果数据库表当前版本号与第一次取出来的version值相等,则予以更新,否则认为是过期数据。用下面的一张图来说明:
如上图所示,如果更新操作顺序执行,则数据的版本(version)依次递增,不会产生冲突。但是如果发生有不同的业务操作对同一版本的数据进行修改,那么,先提交的操作(图中B)会把数据version更新为2,当A在B之后提交更新时发现数据的version已经被修改了,那么A的更新操作会失败。
2.乐观锁定的第二种实现方式和第一种差不多,同样是在需要乐观锁控制的table中增加一个字段,名称无所谓,字段类型使用时间戳(timestamp), 和上面的version类似,也是在更新提交的时候检查当前数据库中数据的时间戳和自己更新前取到的时间戳进行对比,如果一致则OK,否则就是版本冲突。
使用举例:以MySQL InnoDB为例
还是拿之前的实例来举:商品goods表中有一个字段status,status为1代表商品未被下单,status为2代表商品已经被下单,那么我们对某个商品下单时必须确保该商品status为1。假设商品的id为1。
下单操作包括3步骤:
1.查询出商品信息
select (status,status,version) from t_goods where id=#{id}
2.根据商品信息生成订单
3.修改商品status为2
update t_goods
set status=2,version=version+1
where id=#{id} and version=#{version};
那么为了使用乐观锁,我们首先修改t_goods表,增加一个version字段,数据默认version值为1。
t_goods表初始数据如下:
mysql> select * from t_goods; +----+--------+------+---------+ | id | status | name | version | +----+--------+------+---------+ | 1 | 1 | 道具 | 1 | | 2 | 2 | 装备 | 2 | +----+--------+------+---------+ 2 rows in set mysql>
对于乐观锁的实现,我使用MyBatis来进行实践,具体如下:
Goods实体类:
/** * ClassName: Goods <br/> * Function: 商品实体. <br/> * date: 2013-5-8 上午09:16:19 <br/> * @author chenzhou1025@126.com */ public class Goods implements Serializable { /** * serialVersionUID:序列化ID. */ private static final long serialVersionUID = 6803791908148880587L; /** * id:主键id. */ private int id; /** * status:商品状态:1未下单、2已下单. */ private int status; /** * name:商品名称. */ private String name; /** * version:商品数据版本号. */ private int version; @Override public String toString(){ return "good id:"+id+",goods status:"+status+",goods name:"+name+",goods version:"+version; } //setter and getter }
GoodsDao
/** * updateGoodsUseCAS:使用CAS(Compare and set)更新商品信息. <br/> * * @author chenzhou1025@126.com * @param goods 商品对象 * @return 影响的行数 */ int updateGoodsUseCAS(Goods goods);
mapper.xml
<update id="updateGoodsUseCAS" parameterType="Goods"> <![CDATA[ update t_goods set status=#{status},name=#{name},version=version+1 where id=#{id} and version=#{version} ]]> </update>
GoodsDaoTest测试类
@Test public void goodsDaoTest(){ int goodsId = 1; //根据相同的id查询出商品信息,赋给2个对象 Goods goods1 = this.goodsDao.getGoodsById(goodsId); Goods goods2 = this.goodsDao.getGoodsById(goodsId); //打印当前商品信息 System.out.println(goods1); System.out.println(goods2); //更新商品信息1 goods1.setStatus(2);//修改status为2 int updateResult1 = this.goodsDao.updateGoodsUseCAS(goods1); System.out.println("修改商品信息1"+(updateResult1==1?"成功":"失败")); //更新商品信息2 goods1.setStatus(2);//修改status为2 int updateResult2 = this.goodsDao.updateGoodsUseCAS(goods1); System.out.println("修改商品信息2"+(updateResult2==1?"成功":"失败")); }
输出结果:
good id:1,goods status:1,goods name:道具,goods version:1 good id:1,goods status:1,goods name:道具,goods version:1 修改商品信息1成功 修改商品信息2失败
说明:
在GoodsDaoTest测试方法中,我们同时查出同一个版本的数据,赋给不同的goods对象,然后先修改good1对象然后执行更新操作,执行成功。然后我们修改goods2,执行更新操作时提示操作失败。此时t_goods表中数据如下:
mysql> select * from t_goods; +----+--------+------+---------+ | id | status | name | version | +----+--------+------+---------+ | 1 | 2 | 道具 | 2 | | 2 | 2 | 装备 | 2 | +----+--------+------+---------+ 2 rows in set mysql>
我们可以看到 id为1的数据version已经在第一次更新时修改为2了。所以我们更新good2时update where条件已经不匹配了,所以更新不会成功,具体sql如下:
update t_goods set status=2,version=version+1 where id=#{id} and version=#{version};
这样我们就实现了乐观锁
以上就是我对MySQL乐观锁的总结和实践,写得比较浅显,有不对的地方欢迎拍砖
相关推荐
在IT领域,数据库管理和编程语言的交互是至关重要的,尤其是当涉及到并发控制和数据安全时。本主题聚焦于“MySQL与...通过阅读《第15章_锁.pdf》和《锁总结.txt》等资料,可以进一步深入了解这一领域的细节和实践技巧。
在实际开发中,了解MySQL的最佳实践和常见问题解决方案是至关重要的,这有助于构建稳定、高效的数据库系统。随着技术的发展,MySQL持续更新改进,学习和掌握最新的特性和最佳实践是每个数据库管理员和开发者的必修课...
MySQL是世界上最受欢迎的关系型数据库管理系统之一,其性能、稳定性和可扩展性使其在各种规模的应用中得到广泛应用。...通过不断实践和理论学习,才能更好地掌握MySQL并应用于实际项目,从而提升系统的稳定性和性能。
你需要理解乐观锁和悲观锁的概念,以及REPEATABLE READ、READ COMMITTED、SERIALIZABLE等不同的事务隔离级别。死锁问题及其检测与解决策略也是面试中常被问到的内容。 数据库复制是实现高可用性和负载均衡的关键。...
此外,还有乐观锁和悲观锁的概念,它们分别代表了不同的并发控制策略。 接下来,我们转向存储过程。存储过程是预编译的一组SQL语句,可以封装复杂的业务逻辑并多次重用。在MySQL中,创建存储过程可以通过`CREATE ...
此外,它也是乐观锁和悲观锁策略中的重要组成部分。乐观锁假设很少发生并发冲突,只在提交时检查冲突;而悲观锁则在开始操作前就获取锁,防止并发冲突。 为了实现写锁,数据库系统通常会维护一种锁定机制,如锁定表...
本系统采用了乐观锁机制来解决这一问题。 2. **数据安全性**:通过加密算法保护敏感数据的安全性,例如对密码进行加密存储。 3. **性能优化**:采用缓存技术减少数据库访问频率,提高系统响应速度。 #### 七、总结 ...
总结来说,MySQL并发更新数据时的处理方法包括利用事务的显式锁定和乐观锁机制。选择哪种方法取决于具体的应用需求和系统性能要求。在实际应用中,可能需要结合业务逻辑、并发量和数据库性能综合考虑,以达到最佳的...
- 分布式事务:支持两阶段提交(2PC)、乐观锁等事务机制,保证事务的ACID特性。 - 数据分片:数据会根据Key范围切分成多个Region,TiDB通过Range-based策略实现自动的数据分裂。 - 负载均衡:通过PD调度,实现存储...
解决方案是采用乐观锁或悲观锁机制,根据实际情况选择合适的并发控制策略。 - **大数据量处理**:随着用户数量增加,如何高效地处理大量数据?可以考虑引入分布式数据库或NoSQL数据库来解决传统关系型数据库在大数据...
2. 并发控制:在多用户环境下,确保数据的一致性和完整性,常用方法有锁机制、乐观锁、悲观锁等。 六、数据库备份与恢复 1. 备份:定期或按需复制数据库,防止数据丢失。 2. 恢复:在系统故障后,通过备份数据将...
2. 并发控制:在多用户环境中,SQL使用锁定、乐观锁和悲观锁策略来防止数据冲突。隔离级别(读未提交、读已提交、可重复读和串行化)决定了数据的并发行为。 五、存储过程与触发器 1. 存储过程:存储过程是一组预...
8. **事务与并发控制**:正确设置事务隔离级别,使用乐观锁、悲观锁或MVCC(多版本并发控制)机制,可以有效处理并发问题,保证数据一致性。 9. **监控与调优工具**:如MySQL的Performance Schema,Oracle的AWR报告...
- 对于入账操作,采用异步记账的方式,利用乐观锁和重试机制。 - 对于出账操作,则采用实时记账,使用悲观锁来保证数据的正确性。 ### 监控系统 文档还提到了监控系统的重要性,它包括实时业务监控系统、数据源...
此外,使用乐观锁或悲观锁机制也是控制并发访问的有效手段。 第三题,如何备份和恢复MySQL数据库?MySQL提供多种备份工具,如mysqldump、xtrabackup等。常规的全量备份可以通过mysqldump命令实现,增量备份则需要...
2. 并发控制:并发操作可能导致数据不一致,通过锁定机制(如读锁、写锁)和乐观锁、悲观锁策略来解决。 六、索引优化 1. 索引:加速查询的关键工具,分为B树索引、哈希索引和全文索引等类型。创建索引可以提升...
5. **并发控制与事务处理**:考生需要理解ACID属性(原子性、一致性、隔离性和持久性),以及并发控制机制,如锁定、乐观锁和多版本并发控制(MVCC)。 6. **数据库恢复技术**:这部分可能包括日志系统、检查点、前...
此外,还会涉及并发控制,如锁机制和乐观锁策略,确保多用户环境下数据的一致性。 七、备份与恢复 数据库的备份和恢复是保障数据安全的重要环节。我们将学习如何进行全量备份、增量备份和差异备份,以及在数据丢失...
详细探讨了线程池的实现原理、线程生命周期、锁机制以及线程安全问题,包括volatile关键字的实现原理,悲观锁和乐观锁的概念,以及CAS乐观锁的ABA问题。 集合框架方面,详细阐述了List和Set的区别,List和Map的区别...