1 什么是mysql的樂(lè)觀鎖

MySQL中的樂(lè)觀鎖（Optimistic Locking）是一種并發(fā)控制策略，它基于這樣一個(gè)假設(shè)：數(shù)據(jù)沖突并不頻繁發(fā)生，因此在讀取數(shù)據(jù)時(shí)不會(huì)對(duì)數(shù)據(jù)加鎖，而是在提交更新的時(shí)候才會(huì)正式對(duì)數(shù)據(jù)的沖突與否進(jìn)行檢測(cè)。如果發(fā)現(xiàn)沖突了，則讓返回沖突信息，讓用戶(hù)決定如何去做下一步，比如重試或者回滾。樂(lè)觀鎖的核心思想是盡量減少鎖定資源的時(shí)間，提高系統(tǒng)的并發(fā)性能，同時(shí)保證數(shù)據(jù)的一致性。

2 樂(lè)觀鎖的實(shí)現(xiàn)方式

樂(lè)觀鎖的實(shí)現(xiàn)通常有兩種主要的方式：使用數(shù)據(jù)版本（Version）記錄機(jī)制和時(shí)間戳機(jī)制。這兩種方式都是為了確保在并發(fā)環(huán)境中，當(dāng)多個(gè)事務(wù)試圖修改同一份數(shù)據(jù)時(shí)，能夠正確地處理這些請(qǐng)求，避免數(shù)據(jù)不一致的問(wèn)題。

1. 使用數(shù)據(jù)版本（Version）記錄機(jī)制

這是最常見(jiàn)的一種樂(lè)觀鎖實(shí)現(xiàn)方式。具體來(lái)說(shuō)，就是在數(shù)據(jù)庫(kù)表中增加一個(gè)數(shù)字類(lèi)型的version字段來(lái)表示數(shù)據(jù)被修改的次數(shù)。當(dāng)讀取數(shù)據(jù)時(shí)，將version字段的值一同讀出；在更新數(shù)據(jù)時(shí)，會(huì)檢查當(dāng)前記錄的version值是否與之前讀取的一致。如果一致，則更新成功，并將version值加1；如果不一致，則認(rèn)為數(shù)據(jù)已經(jīng)被其他事務(wù)修改，當(dāng)前更新失敗，通常會(huì)提示用戶(hù)重新嘗試。

2. 使用時(shí)間戳機(jī)制

另一種實(shí)現(xiàn)樂(lè)觀鎖的方式是使用時(shí)間戳（Timestamp）。這種方式與版本號(hào)類(lèi)似，但使用的字段類(lèi)型是時(shí)間戳。在更新提交的時(shí)候，系統(tǒng)會(huì)檢查當(dāng)前數(shù)據(jù)庫(kù)中數(shù)據(jù)的時(shí)間戳和自己更新前取到的時(shí)間戳進(jìn)行對(duì)比，如果一致則OK，否則就是版本沖突。這種方法的一個(gè)缺點(diǎn)是，當(dāng)并發(fā)事務(wù)時(shí)間間隔小于當(dāng)前系統(tǒng)平臺(tái)的最小時(shí)間單位時(shí)，可能發(fā)生覆蓋前一個(gè)事務(wù)結(jié)果的問(wèn)題。

3 SpringBoot下實(shí)現(xiàn)樂(lè)觀鎖思路

在Spring Boot項(xiàng)目中使用MyBatis-Plus和MySQL實(shí)現(xiàn)樂(lè)觀鎖，主要是為了應(yīng)對(duì)并發(fā)環(huán)境下的數(shù)據(jù)一致性問(wèn)題。樂(lè)觀鎖是一種并發(fā)控制策略，它假設(shè)多個(gè)事務(wù)不會(huì)發(fā)生沖突，在執(zhí)行操作時(shí)不加鎖，非常樂(lè)觀，只需每次提交時(shí)利用標(biāo)識(shí)進(jìn)行對(duì)比，確認(rèn)其他事務(wù)沒(méi)修改過(guò)即可提交。這種方式適用于讀多寫(xiě)少的應(yīng)用場(chǎng)景，因?yàn)樗鼪](méi)有加鎖，避免了鎖競(jìng)爭(zhēng)帶來(lái)的性能消耗，所以吞吐量非常高。

本文將使用數(shù)據(jù)版本（Version）記錄機(jī)制來(lái)對(duì)樂(lè)觀鎖進(jìn)行實(shí)現(xiàn)。

注意：請(qǐng)確保已經(jīng)引入了mybaitsplus和mysql和test測(cè)試依賴(lài)，以及成功配置連接上數(shù)據(jù)庫(kù)，本文將不做依賴(lài)引入示例。

4 MyBatis-Plus中的樂(lè)觀鎖插件配置

MyBatis-Plus提供了現(xiàn)成的樂(lè)觀鎖插件OptimisticLockerInnerInterceptor，可以方便地集成到Spring Boot項(xiàng)目中。要啟用這個(gè)插件，首先需要在項(xiàng)目的配置類(lèi)中注冊(cè)該插件。以下是具體的配置步驟：

4.1 數(shù)據(jù)庫(kù)表設(shè)計(jì)

為了支持樂(lè)觀鎖，數(shù)據(jù)庫(kù)表也需要相應(yīng)地設(shè)計(jì)。通常是在表中添加一個(gè)version字段，用于記錄數(shù)據(jù)的版本信息。例如，創(chuàng)建一個(gè)名為user的表，其中包含version字段：

CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  `age` int(11) DEFAULT NULL,
  `email` varchar(255) DEFAULT NULL,
  `version` int(11) DEFAULT 1 COMMENT '數(shù)據(jù)版本號(hào)',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

在這個(gè)例子中，version字段的默認(rèn)值設(shè)置為1，以便于初始化。

4.2 配置樂(lè)觀鎖插件

在Spring Boot的配置類(lèi)中添加OptimisticLockerInnerInterceptor插件。可以通過(guò)@Bean注解的方式注入插件，如下所示：

import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class MyBatisPlusConfig {

    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        // 注冊(cè)樂(lè)觀鎖插件
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }
}

4.3 實(shí)體類(lèi)中添加@Version注解

接下來(lái)，在實(shí)體類(lèi)中為需要使用樂(lè)觀鎖的字段添加@Version注解。例如，對(duì)于一個(gè)用戶(hù)實(shí)體類(lèi)User，可以在version字段上添加此注解：

import com.baomidou.mybatisplus.annotation.Version;
import lombok.Data;

@Data
public class User {
    private Long id;
    private String name;
    private Integer age;
    private String email;

    // 樂(lè)觀鎖版本號(hào)
    @Version
    private Integer version;
}

這里需要注意的是，@Version注解支持的數(shù)據(jù)類(lèi)型包括：int, Integer, long, Long, Date, Timestamp, LocalDateTime。整數(shù)類(lèi)型下newVersion = oldVersion + 1，并且newVersion會(huì)回寫(xiě)到entity中。

4.4 測(cè)試樂(lè)觀鎖的效果

為了驗(yàn)證樂(lè)觀鎖是否生效，可以通過(guò)編寫(xiě)單元測(cè)試來(lái)模擬并發(fā)場(chǎng)景。例如，創(chuàng)建兩個(gè)線(xiàn)程同時(shí)嘗試更新同一條記錄，觀察更新的結(jié)果。如果其中一個(gè)線(xiàn)程更新成功，而另一個(gè)線(xiàn)程因?yàn)榘姹咎?hào)不匹配而更新失敗，則說(shuō)明樂(lè)觀鎖已經(jīng)正確實(shí)現(xiàn)。

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class OptimisticLockTest {

    @Autowired
    private UserMapper userMapper;

    @Test
    public void testOptimisticLock() throws InterruptedException {
        // 線(xiàn)程1
        Thread thread1 = new Thread(() -> {
            User user1 = userMapper.selectById(1L);
            user1.setName("zhangsan");
            userMapper.updateById(user1);
        });

        // 線(xiàn)程2
        Thread thread2 = new Thread(() -> {
            User user2 = userMapper.selectById(1L);
            user2.setName("lisi");
            userMapper.updateById(user2);
        });

        thread1.start();
        thread2.start();

        thread1.join();
        thread2.join();
    }
}

在這個(gè)測(cè)試中，thread1和thread2幾乎同時(shí)啟動(dòng)，試圖更新同一個(gè)用戶(hù)的姓名。由于樂(lè)觀鎖的存在，只有其中一個(gè)線(xiàn)程能夠成功更新數(shù)據(jù)，而另一個(gè)線(xiàn)程則會(huì)因?yàn)榘姹咎?hào)不匹配而更新失敗。

5 注意事項(xiàng)

版本號(hào)字段的默認(rèn)值：建議將version字段的默認(rèn)值設(shè)置為1，這樣可以確保初次插入數(shù)據(jù)時(shí)版本號(hào)就已經(jīng)存在。

update(entity, wrapper)方法下的wrapper不能復(fù)用：這意味著在構(gòu)建查詢(xún)條件時(shí)，應(yīng)該為每個(gè)更新操作創(chuàng)建新的wrapper實(shí)例，以避免潛在的問(wèn)題。

自定義SQL語(yǔ)句：如果使用了自定義的SQL語(yǔ)句進(jìn)行更新操作，那么需要手動(dòng)處理版本號(hào)的比較和更新，否則樂(lè)觀鎖將不會(huì)生效。

通過(guò)上述步驟，就可以在Spring Boot項(xiàng)目中使用MyBatis-Plus和MySQL實(shí)現(xiàn)樂(lè)觀鎖，從而有效地解決并發(fā)環(huán)境下的數(shù)據(jù)一致性問(wèn)題。

到此這篇關(guān)于Springboot使用MybatisPlus實(shí)現(xiàn)mysql樂(lè)觀鎖的文章就介紹到這了,更多相關(guān)Springboot MybatisPlus實(shí)現(xiàn)樂(lè)觀鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論