浅谈mybatis 乐观锁实现,解决并发问题

情景展示：

银行两操作员同时操作同一账户就是典型的例子。

比如A、B操作员同时读取一余额为1000元的账户，A操作员为该账户增加100元，B操作员同时为该账户扣除50元，A先提交，B后提交。最后实际账户余额为1000-50=950元，但本该为1000+100-50=1050。这就是典型的并发问题。

乐观锁机制在一定程度上解决了这个问题。乐观锁，大多是基于数据版本(Version)记录机制实现。何谓数据版本？即为数据增加一个版本标识，在基于数据库表的版本解决方案中，一般是通过为数据库表增加一个 “version” 字段来实现。

读取出数据时，将此版本号一同读出，之后更新时，对此版本号加一。此时，将提交数据的版本数据与数据库表对应记录的当前版本信息进行比对，如果提交的数据版本号大于数据库表当前版本号，则予以更新，否则认为是过期数据。

对于上面修改用户帐户信息的例子而言，假设数据库中帐户信息表中有一个version字段，当前值为1；而当前帐户余额字段(balance)为1000元。假设操作员A先更新完，操作员B后更新。

a、操作员A此时将其读出(version=1)，并从其帐户余额中增加100(1000+100=1100)。

b、在操作员A操作的过程中，操作员B也读入此用户信息(version=1)，并从其帐户余额中扣除50(1000-50=950)。

c、操作员A完成了修改工作，将数据版本号加一(version=2)，连同帐户增加后余额(balance=1100)，提交至数据库更新，此时由于提交数据版本大于数据库记录当前版本，数据被更新，数据库记录version更新为2。

d、操作员B完成了操作，也将版本号加一(version=2)试图向数据库提交数据(balance=950)，但此时比对数据库记录版本时发现，操作员B提交的数据版本号为2，数据库记录当前版本也为2，不满足 “提交版本必须大于记录当前版本才能执行更新 “的乐观锁策略，因此，操作员B的提交被驳回。

这样，就避免了操作员B用基于version=1的旧数据修改的结果覆盖操作员A的操作结果的可能。

示例代码：

account建库脚本

drop table if exists account_wallet;
 
/*==============================================================*/
/* Table: account_wallet          */
/*==============================================================*/
create table account_wallet
(
 id     int not null comment '用户钱包主键',
 user_open_id   varchar(64) comment '用户中心的用户唯一编号',
 user_amount   decimal(10,5),
 create_time   datetime,
 update_time   datetime,
 pay_password  <div style="color:transparent">本文来源gaodai.ma#com搞##代!^码@网*</div> varchar(64),
 is_open    int comment '0:代表未开启支付密码，1:代表开发支付密码',
 check_key   varchar(64) comment '平台进行用户余额更改时，首先效验key值，否则无法进行用户余额更改操作',
 version    int comment '基于mysql乐观锁，解决并发访问'
 primary key (id)
);

dao层

AccountWallet selectByOpenId(String openId);

int updateAccountWallet(AccountWallet record);

service 层

AccountWallet selectByOpenId(String openId);

int updateAccountWallet(AccountWallet record);

serviceImpl层

 public AccountWallet selectByOpenId(String openId) {
 // TODO Auto-generated method stub
 return accountWalletMapper.selectByOpenId(openId);
 }
 
 public int updateAccountWallet(AccountWallet record) {
 // TODO Auto-generated method stub
 return accountWalletMapper.updateAccountWallet(record);
 }

喜欢 (0)赏

[搞代码]

分享 (0)