1 什么是mysql的樂觀鎖

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

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

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

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

這是最常見的一種樂觀鎖實(shí)現(xiàn)方式。具體來說，就是在數(shù)據(jù)庫表中增加一個(gè)數(shù)字類型的version字段來表示數(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ì)提示用戶重新嘗試。

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

另一種實(shí)現(xiàn)樂觀鎖的方式是使用時(shí)間戳（Timestamp）。這種方式與版本號(hào)類似，但使用的字段類型是時(shí)間戳。在更新提交的時(shí)候，系統(tǒng)會(huì)檢查當(dāng)前數(shù)據(jù)庫中數(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é)果的問題。

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

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

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

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

4 MyBatis-Plus中的樂觀鎖插件配置

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

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

為了支持樂觀鎖，數(shù)據(jù)庫表也需要相應(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 配置樂觀鎖插件

在Spring Boot的配置類中添加OptimisticLockerInnerInterceptor插件?？梢酝ㄟ^@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();
        // 注冊樂觀鎖插件
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }
}

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

接下來，在實(shí)體類中為需要使用樂觀鎖的字段添加@Version注解。例如，對(duì)于一個(gè)用戶實(shí)體類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;

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

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

4.4 測試樂觀鎖的效果

為了驗(yàn)證樂觀鎖是否生效，可以通過編寫單元測試來模擬并發(fā)場景。例如，創(chuàng)建兩個(gè)線程同時(shí)嘗試更新同一條記錄，觀察更新的結(jié)果。如果其中一個(gè)線程更新成功，而另一個(gè)線程因?yàn)榘姹咎?hào)不匹配而更新失敗，則說明樂觀鎖已經(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 {
        // 線程1
        Thread thread1 = new Thread(() -> {
            User user1 = userMapper.selectById(1L);
            user1.setName("zhangsan");
            userMapper.updateById(user1);
        });

        // 線程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è)測試中，thread1和thread2幾乎同時(shí)啟動(dòng)，試圖更新同一個(gè)用戶的姓名。由于樂觀鎖的存在，只有其中一個(gè)線程能夠成功更新數(shù)據(jù)，而另一個(gè)線程則會(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)建查詢條件時(shí)，應(yīng)該為每個(gè)更新操作創(chuàng)建新的wrapper實(shí)例，以避免潛在的問題。

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

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

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

最新評(píng)論