并发问题的解决一直是广大程序员的心病,而乐观锁便是能够有效解决高并发问题的一种模式,下面就让我们一起看看要如何在乐观锁下解决高并发问题吧。
乐观锁下解决高并发问题
例:
在一银行中,如若A、B操作员同时读取一个余额为1000元的账户,A操作员为该账户增加100元,B操作员在A操作员增加的同时为该账户扣除50元,A操作员先提交,B操作员后提交。所以最后账户余额为1000-50=950元,实际上应为1000+100-50=1050。这就是互联网中的典型并发问题。
乐观锁机制在一定程度上解决了这个问题。乐观锁,一般都是基于数据版本(Version)记录机制实现。什么是数据版本?就是在数据中为它增加一个版本标识,在基于数据库表的版本解决方案中,一般是通过为数据库表增加一个 “version” 字段来实现。
数据库在读取数据时,会把这个版本号一同读出,之后每更新一次,就会对版本号加一。此时,把提交数据的版本数据与数据库表对应记录的当前版本信息进行比对,如果提交的数据版本号大于数据库表当前版本号,则予以更新,不然就都认为是过期数据。
对于上面修改用户帐户余额的例子而言,假设在数据库中,帐户信息表有一个version字段,当前值为1;而当前帐户余额字段为1000元。假设操作员A先更新完,操作员B后更新。
步骤如下:
1)操作员A此时将其读出(version=1),并从其帐户余额中增100元(1000+100=1100)。
2)在操作员A操作的过程中,操作员B也读入此用户信息(version=1),并从其帐户余额中扣除50元(1000-50=950)。
3)操作员A完成了修改工作,将数据版本号加一(version=2),连同帐户增加后余额(balance=1100),提交至数据库更新,这时由于提交数据版本大于数据库记录当前版本,数据被更新,数据库记录version更新为2。
4)操作员B完成了操作,也将版本号加一(version=2)试图向数据库提交数据(balance=950),但此时比对数据库记录版本时发现,操作员B提交的数据版本号为2,数据库记录当前版本也为2,不满足 “提交版本必须大于记录当前版本才能执行更新 “的乐观锁机制,所以,操作员B的提交被驳回。
这样,就能避免操作员B使用基于version=1的旧数据修改的结果覆盖掉操作员A的操作结果的可能了。
具体实现代码:
A操作员:
select id, balance, version from account where id = "1"; 查询结果: id = 1, balance = 1000, version = 1 update account set balance = balance + 100, version = version + 1 where id = "1" and version = 1 select id, balance, version from account where id = "1"; 查询结果: id = 1, balance = 1100, version = 2
B操作员:
select id, balance, version from account where id = "1"; 查询结果: id = 1, balance = 1000, version = 1 # 操作员A已修改成功, account.balance = 1100、 account.version = 2, 操作员B也将版本号加一(version = 2) 试图向数据库提交数据(balance = 950), 但此时比对数据库记录版本时发现, 操作员B提交的数据版本号为2, 数据库记录当前版本也为2, 不满足“ 提交版本必须大于记录当前版本才能执行更新“ 的乐观锁策略, 因此, 操作员B的提交被驳回。 update account set balance = balance - 50, version = version + 1 where id = "1" and version = 1 select id, balance, version from account where id = "1"; 查询结果: id = 1, balance = 1100, version = 2
以上就是关于乐观锁解决高并发问题的全部内容了,更多相关java常见问答知识请关注网站奇Q工具网了解具体内容吧。
推荐阅读: