怎么使用MyBatisPlus+SpringBoot實(shí)現(xiàn)樂(lè)觀鎖功能

第怎么使用MyBatisPlus+SpringBoot實(shí)現(xiàn)樂(lè)觀鎖功能一、商城數(shù)據(jù)不一致的場(chǎng)景

如果商城中有一件商品，成本價(jià)是80元，售價(jià)是100元。經(jīng)理先是通知小李，說(shuō)你去把商品價(jià)格增加50元。小李正在玩游戲，耽擱了一個(gè)小時(shí)。正好一個(gè)小時(shí)后，經(jīng)理覺(jué)得商品價(jià)格增加到150元，價(jià)格太高，可能會(huì)影響銷量。又通知小王，你把商品價(jià)格降低30元。

此時(shí)，小李和小王同時(shí)操作商品后臺(tái)系統(tǒng)。小李操作的時(shí)候，系統(tǒng)先取出商品價(jià)格100元；小王也在操作，取出的商品價(jià)格也是100元。小李將價(jià)格加了50元，并將100+50=150元存入了數(shù)據(jù)庫(kù)；小王將商品減了30元，并將100-30=70元存入了數(shù)據(jù)庫(kù)。是的，如果沒(méi)有鎖，小李的操作就完全被小王的覆蓋了。

現(xiàn)在商品價(jià)格是70元，比成本價(jià)低10元。幾分鐘后，這個(gè)商品很快出售了1千多件商品，老板虧1萬(wàn)多。

二、演示這一過(guò)程

1、數(shù)據(jù)庫(kù)中增加商品表

CREATETABLEproduct

idBIGINT(20)NOTNULLAUTO_INCREMENTCOMMENT主鍵ID,

nameVARCHAR(30)NULLDEFAULTNULLCOMMENT商品名稱,

priceINT(11)DEFAULT0COMMENT價(jià)格,

versionINT(11)DEFAULT0COMMENT樂(lè)觀鎖版本號(hào),

PRIMARYKEY(id)

INSERTINTOproduct(id,NAME,price)VALUES(1,筆記本,100);

2、創(chuàng)建實(shí)體類

@Data

publicclassProduct{

privateLongid;

privateStringname;

privateIntegerprice;

privateIntegerversion;

}

3、創(chuàng)建Mapper

publicinterfaceProductMapperextendsBaseMapperProduct{

}

4、進(jìn)行測(cè)試

@RunWith(SpringRunner.class)

@SpringBootTest

publicclassProductVersionTest{

@Resource

privateProductMapperproductMapper;

@Test

publicvoidtestProductUpdate(){

//1、小李

Productp1=productMapper.selectById(1L);

//2、小王

Productp2=productMapper.selectById(1L);

//3、小李將價(jià)格加了50元，存入了數(shù)據(jù)庫(kù)

p1.setPrice(p1.getPrice()+50);

intresult1=productMapper.updateById(p1);

System.out.println(小李修改結(jié)果：+result1);

//4、小王將商品減了30元，存入了數(shù)據(jù)庫(kù)

p2.setPrice(p2.getPrice()-30);

intresult2=productMapper.updateById(p2);

System.out.println(小王修改結(jié)果：+result2);

//最后的結(jié)果

Productp3=productMapper.selectById(1L);

System.out.println(最后的結(jié)果：+p3.getPrice());

}

最后輸出的是70元，與經(jīng)理預(yù)期的120元不同，導(dǎo)致虧損，如何防止這樣的異常發(fā)生，解決方案是使用樂(lè)觀鎖

三、樂(lè)觀鎖方案

數(shù)據(jù)庫(kù)中添加version字段：取出記錄時(shí)，獲取當(dāng)前version

SELECTid,`name`,price,`version`FROMproductWHEREid=1

更新時(shí)，version+1，如果where語(yǔ)句中的version版本不對(duì)，則更新失敗

UPDATEproductSETprice=price+50,`version`=`version`+1WHEREid=1AND`version`=1

四、樂(lè)觀鎖實(shí)現(xiàn)流程

1、修改實(shí)體類

添加@Version注解

@Version

privateIntegerversion;

2、添加樂(lè)觀鎖插件

@Configuration

//@MapperScan(com.koo.modules.*.dao)

publicclassMybatisPlusConfig{

*新的分頁(yè)插件,一緩和二緩遵循mybatis的規(guī)則,需要設(shè)置MybatisConfiguration#useDeprecatedExecutor=false避免緩存出現(xiàn)問(wèn)題(該屬性會(huì)在舊插件移除后一同移除)

@Bean

publicMybatisPlusInterceptormybatisPlusInterceptor(){

MybatisPlusInterceptorinterceptor=newMybatisPlusInterceptor();

interceptor.addInnerInterceptor(newPaginationInnerInterceptor(DbType.MySQL));

//實(shí)現(xiàn)樂(lè)觀鎖，保證數(shù)據(jù)的準(zhǔn)確性

interceptor.addInnerInterceptor(newOptimisticLockerInnerInterceptor());

returninterceptor;

@Bean

publicConfigurationCustomizerconfigurationCustomizer(){

returnconfiguration-configuration.setUseDeprecatedExecutor(false);

}

3、優(yōu)化流程

（判斷第二次更新數(shù)據(jù)是否成功，不成功則重新取數(shù)據(jù)進(jìn)行更新）

@RunWith(SpringRunner.class)

@SpringBootTest

publicclassProductVersionTest{

@Resource

privateProductMapperproductMapper;

@Test

publicvoidtestProductUpdate(){

//1、小李

Productp1=productMapper.selectById(1L);

//2、小王

Productp2=productMapper.selectById(1L);

//3、小李將價(jià)格加了50元，存入了數(shù)據(jù)庫(kù)

p1.setPrice(p1.getPrice()+50);

intresult1=productMapper.updateById(p1);

System.out.println(小李修改結(jié)果：+result1);

//4、小王將商品減了30元，存入了數(shù)據(jù)庫(kù)

p2.setPrice(p2.getPrice()-30);

intresult2=productMapper.updateById(p2);

System.out.println(小王修改結(jié)果：+result2);

if(result2==0){//更新失敗，重試

System.out.println(小王重試

//重新獲取數(shù)據(jù)

p2=productMapper.selectById(1L);

//更新

p2.setPri