乐观锁的总结

乐观锁( Optimistic Locking ) 相对悲观锁而言,乐观锁假设认为数据一般情况下不会造成冲突,
所以在数据进行提交更新的时候,才会正式对数据的冲突与否进行检测,如果发现冲突了,
则让返回用户错误的信息,让用户决定如何去做。那么我们如何实现乐观锁呢,一般来说有以下2种方式:

1.使用数据版本(Version)记录机制实现,这是乐观锁最常用的一种实现方式。何谓数据版本?
即为数据增加一个版本标识,一般是通过为数据库表增加一个数字类型的 “version” 字段来实现。
当读取数据时,将version字段的值一同读出,数据每更新一次,对此version值加一。
当我们提交更新的时候,判断数据库表对应记录的当前版本信息与第一次取出来的version值进行比对,
如果数据库表当前版本号与第一次取出来的version值相等,则予以更新,否则认为是过期数据。
用下面的一张图来说明:





22a9518f-e355-315f-8d66-d91af4fda723.jpg
如上图所示,如果更新操作顺序执行,则数据的版本(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表初始数据如下:
Sql代码  

    mysql> select * from t_goods;  
    +----+--------+------+---------+  
    | id | status | name | version |  
    +----+--------+------+---------+  
    |  1 |      1 | 道具 |       1 |  
    |  2 |      2 | 装备 |       2 |  
    +----+--------+------+---------+  
    2 rows in set  
      
    mysql>  

对于乐观锁的实现,我使用MyBatis来进行实践,具体如下:

Goods实体类:
Java代码  

    /** 
     * ClassName: Goods  
     * Function: 商品实体. 
     * date:  
     */  
    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)更新商品信息. 
     * @param goods 商品对象 
     * @return 影响的行数 
     */  
    int updateGoodsUseCAS(Goods goods);  

mapper.xml
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?"成功":"失败"));  
    }  

输出结果:
Shell代码  

    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表中数据如下:
Sql代码  

    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如下:
Sql代码 

    update t_goods   
    set status=2,version=version+1  
    where id=#{id} and version=#{version};  

这样我们就实现了乐观锁
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,651评论 6 501
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,468评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,931评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,218评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,234评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,198评论 1 299
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,084评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,926评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,341评论 1 311
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,563评论 2 333
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,731评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,430评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,036评论 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,676评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,829评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,743评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,629评论 2 354

推荐阅读更多精彩内容