溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

mybatis?plus樂(lè)觀鎖如何實(shí)現(xiàn)

發(fā)布時(shí)間:2022-05-27 13:45:41 來(lái)源:億速云 閱讀:208 作者:iii 欄目:開(kāi)發(fā)技術(shù)

本篇內(nèi)容介紹了“mybatis plus樂(lè)觀鎖如何實(shí)現(xiàn)”的有關(guān)知識(shí),在實(shí)際案例的操作過(guò)程中,不少人都會(huì)遇到這樣的困境,接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!

一、什么是樂(lè)觀鎖

樂(lè)觀鎖其實(shí)用一句話來(lái)形容其作用就是:當(dāng)要更新一條記錄的時(shí)候,希望這條記錄沒(méi)有被別人更新,從而實(shí)現(xiàn)線程安全的數(shù)據(jù)更新。

結(jié)合下場(chǎng)景,記得那是一張庫(kù)存表,有一個(gè)字段記錄商品庫(kù)存,涉及多個(gè)地方都有可能去更新它:

  • 程序A 查詢到了這條數(shù)據(jù),得到庫(kù)存是800,準(zhǔn)備+200更新成1000,但是還沒(méi)更新。

  • 程序B 也查詢到了這條數(shù)據(jù),得到庫(kù)存是800,準(zhǔn)備-200更新成600,并且提交更新了。

那么,這時(shí)候A再提交更新之后,B就會(huì)發(fā)現(xiàn)明明是自己是800-200=600,怎么最后變成了1000?
這就是因?yàn)锳的事務(wù)導(dǎo)致了B的數(shù)據(jù)更新丟失。

文字可能讀起來(lái)比較晦澀,有請(qǐng)靈魂畫手:

mybatis?plus樂(lè)觀鎖如何實(shí)現(xiàn)

正常情況下:

  • 按先后順序是, A先更新成1000,然后B再拿1000-200,更新成800,這樣B就沒(méi)異議了。

  • 或者實(shí)在要2個(gè)同時(shí)更新,那也只能有一個(gè)成功,這樣也沒(méi)異議。

二、MP來(lái)實(shí)現(xiàn)樂(lè)觀鎖

樂(lè)觀鎖的實(shí)現(xiàn),通過(guò)增加一個(gè)字段,比如version,來(lái)記錄每次的更新。
查詢數(shù)據(jù)的時(shí)候帶出version的值,執(zhí)行更新的時(shí)候,會(huì)再去比較version,如果不一致,就更新失敗。

還是用之前的user表,增加了新的字段version

1.在實(shí)體類里增加對(duì)于的字段,并且加上自動(dòng)填充(你也可以每次手動(dòng)填充)

@Data
public class User {
    @TableId(type = IdType.ID_WORKER)
    private Long id;
    private String name;
    private Integer age;
    private String email;
    @TableField(fill = FieldFill.INSERT)        // 新增的時(shí)候填充數(shù)據(jù)
    private Date createTime;
    @TableField(fill = FieldFill.INSERT_UPDATE) // 新增或修改的時(shí)候填充數(shù)據(jù)
    private Date updateTime;
    @TableField(fill = FieldFill.INSERT)
    @Version
    private Integer version; // 版本號(hào)
}
@Component //此注解表示 將其交給spring去管理
public class MyMetaObjectHandler implements MetaObjectHandler {
    @Override
    public void insertFill(MetaObject metaObject) {
        this.setFieldValByName("createTime", new Date(), metaObject);
        this.setFieldValByName("updateTime", new Date(), metaObject);
        this.setFieldValByName("version", 0, metaObject); //新增就設(shè)置版本值為0
    }
    @Override
    public void updateFill(MetaObject metaObject) {
        this.setFieldValByName("updateTime", new Date(), metaObject);
    }
}

2. 配置插件

為了便于管理,可以見(jiàn)一個(gè)包,用于存放各種配置類,順便把配置在啟動(dòng)類里的mapper掃描也換到這里來(lái)。

package com.pingguo.mpdemo.config;
import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
// 配置掃描mapper的路徑
@MapperScan("com.pingguo.mpdemo.mapper")
public class MpConfig {
    // 樂(lè)觀鎖插件
    @Bean
    public OptimisticLockerInterceptor optimisticLockerInterceptor() {
        return new OptimisticLockerInterceptor();
    }
}

3.測(cè)試樂(lè)觀鎖

先新增一條測(cè)試數(shù)據(jù):

    //    新增
    @Test
    void addUser() {
        User user = new User();
        user.setName("大周");
        user.setAge(22);
        user.setEmail("laowang@123.com");
        userMapper.insert(user);
    }

新增成功,可以看到version值是0。

mybatis?plus樂(lè)觀鎖如何實(shí)現(xiàn)

再來(lái)試一下正常的修改:

//      測(cè)試樂(lè)觀鎖
    @Test
    void testOptimisticLocker() {
        User user = userMapper.selectById(1342502561945915393L);
        user.setName("大周2");
        userMapper.updateById(user);
    }

修改成功,可以看到version 變成了1。

mybatis?plus樂(lè)觀鎖如何實(shí)現(xiàn)

最后,模擬下并發(fā)更新,樂(lè)觀鎖更新失敗的情況:

    //  測(cè)試樂(lè)觀鎖-失敗
    @Test
    void testOptimisticLockerFailed() {
        User user = userMapper.selectById(1342502561945915393L);
        user.setName("大周3");
        User user2 = userMapper.selectById(1342502561945915393L);
        user2.setName("大周4");
        userMapper.updateById(user2); // 這里user2插隊(duì)到user前面,先去更新
        userMapper.updateById(user); // 這里由于user2先做了更新后,版本號(hào)不對(duì),所以更新失敗
    }

按照樂(lè)觀鎖的原理,user2是可以更新成功的,也就是name會(huì)修改為“大周4”,version會(huì)加1。user因?yàn)榍昂竽玫降陌姹咎?hào)不對(duì),更新失敗。

mybatis?plus樂(lè)觀鎖如何實(shí)現(xiàn)

結(jié)果符合預(yù)期,我們也可以看下mybatis的日志,進(jìn)一步了解一下:

可以看到上面首先是2個(gè)查詢,查詢到的version都是1。

mybatis?plus樂(lè)觀鎖如何實(shí)現(xiàn)

接著,第一個(gè)執(zhí)行update語(yǔ)句的時(shí)候,where條件中version=1,可以找到數(shù)據(jù),于是更新成功,切更新version=2。

mybatis?plus樂(lè)觀鎖如何實(shí)現(xiàn)

ps:這里圖丟了一個(gè)我重新補(bǔ)的一個(gè)數(shù)據(jù),說(shuō)明下意思,忽略ID與上面的不一致。

而第二個(gè)再執(zhí)行update的時(shí)候,where條件version=1,已經(jīng)找不到了,因?yàn)関ersion已經(jīng)被上面的更新成了2,所以更新失敗。

“mybatis plus樂(lè)觀鎖如何實(shí)現(xiàn)”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI