Springboot使用MybatisPlus實現(xiàn)mysql樂觀鎖

更新時間：2024年12月02日 08:23:48 作者：漫天轉悠

MySQL中的樂觀鎖（Optimistic?Locking）是一種并發(fā)控制策略,本文將使用Springboot和MybatisPlus實現(xiàn)MySQL中的樂觀鎖,需要的可以參考下

1 什么是mysql的樂觀鎖

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

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

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

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

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

2. 使用時間戳機制

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

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

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

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

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

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

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

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

為了支持樂觀鎖，數(shù)據(jù)庫表也需要相應地設計。通常是在表中添加一個version字段，用于記錄數(shù)據(jù)的版本信息。例如，創(chuàng)建一個名為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ù)版本號',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

在這個例子中，version字段的默認值設置為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 實體類中添加@Version注解

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

    // 樂觀鎖版本號
    @Version
    private Integer version;
}

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

4.4 測試樂觀鎖的效果

為了驗證樂觀鎖是否生效，可以通過編寫單元測試來模擬并發(fā)場景。例如，創(chuàng)建兩個線程同時嘗試更新同一條記錄，觀察更新的結果。如果其中一個線程更新成功，而另一個線程因為版本號不匹配而更新失敗，則說明樂觀鎖已經正確實現(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();
    }
}

在這個測試中，thread1和thread2幾乎同時啟動，試圖更新同一個用戶的姓名。由于樂觀鎖的存在，只有其中一個線程能夠成功更新數(shù)據(jù)，而另一個線程則會因為版本號不匹配而更新失敗。