1.需求分析

    專案上線後，在併發的情況，資料庫會插入重複的記錄；在這種情況，mysql的悲觀鎖或樂觀鎖可以用來實現程式碼邏輯的併發控制。

 2.悲觀鎖

①悲觀鎖，屬於排它鎖；當事務在操作資料時，它會把這部分資料進行鎖定，直到操作完畢後再解鎖，然後其他事務操作才可操作這部分的資料，這可以防止其他事務讀取或修改表中的資料；大多數情況下，悲觀鎖依靠資料庫的鎖機制實現排它性。

悲觀鎖的應用例項：

②synchronized屬於典型的悲觀鎖，通過同步程式碼塊將需要鎖住的邏輯鎖住，當該事務操作完成後，後續的事務方可執行該邏輯

 synchronized (ServiceAutoOverTimeJob.class
 
){

       if(!serviceIsOverTime.equals("1") && serviceStauts.equals("1") && serviceEnabled.equals("1") && publishFree.equals("0")){//待接單,服務沒超時,可用狀態,付了車票錢
//超時單
pinCarMapper.setServiceTimeOut(serviceId);
String orderId = businessOrderMapper.findOrderIdByServiceId(serviceId);
PinCar pinCar = pinCarMapper
 
.selectByPrimaryKey(serviceId);
JSMSCode.setJSMSCodeByChannel(0);
// 生成支付訂單
String freeLose = pinCarMapper.getIsFreeLoseService(serviceId);
String userId = pinCarMapper.getUserIdByServiceId(serviceId);//釋出者
String whoPublish =  pinCarMapper.getServicePublishBy(serviceId);
String mobile = userMapper.findMobileById(userId); 
 
//使用者手機
String total_amount;
String body;
        if(whoPublish.equals("1")){ //1：表示車主釋出
//剩餘座位的爽約金
Double restLoseAmount =  pinCarMapper.getLoseAccountByServiceId(serviceId);
Double rest = PublishAmountUtil.getdoubleAmount(restLoseAmount);
total_amount = String.valueOf(rest);
body = "車主待接單服務超時爽約金退還";
}else{ //0：表示乘客
total_amount = pinCarMapper.getTicketAmountByServiceId(serviceId);
body = "乘客待接單服務超時";
}
        //返還服務釋出者釋出的金額
Integer increaseAmount =  accountMapper.updateAmount(userId,total_amount);
//獲取訂單號
String orderCode = businessOrderMapper.findOrderCodeById(orderId);
// 生成服務釋出者的錢包流水
Double ticketAmount = this.accountMapper.findAmountByUserId(userId);
AccountFlow ticketflow = AccountFlow.newBuilder().setUserId(userId).setOrderCode(orderCode)
                .setBody(body).setIsInflow("1").setTotal_amount(total_amount).setRemainAmount(ticketAmount.toString())
                .build();
Integer insertAccountFlow =  this.accountFlowMapper.insert(ticketflow.toMap());
// 手動資料回滾
if (increaseAmount != 1 || insertAccountFlow != 1) {
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
}

    }else if(publishFree.equals("1")){  //免車票釋出
//超時單
pinCarMapper.setServiceTimeOut(serviceId);
}
}

類似上述情況運用悲觀鎖，該程式的併發效能顯然降低了，同時在高併發的情況會十分消耗mysql效能，悲觀鎖多用於訪問頻率不是很多的需求場景；

③select ... for update

SELECT * FROM yivi_sys_user WHERE id = 1 FOR UPDATE 

當使用了select ... for update的方式後，這樣就通過資料庫實現了悲觀鎖。此時在user表中id為1的那條資料就被悲觀鎖鎖定了，其他的事務必須等待該次事務提交完畢之後才能執行，這樣我們也可以保證當前的資料不會被其他事務修改

3.樂觀鎖

  樂觀鎖(Optimistic Lock), 顧名思義，就是樂觀的認為別人不會修改資料，所以每次拿資料的時候不會上鎖，但是在更新的時候會它檢查下是否有人去更新這個資料，可以使用資料版本記錄機制來實現鎖。樂觀鎖適用於多讀的應用型別，這樣可以提高系統的併發量。樂觀鎖的實現主要通過程式碼邏輯實現，跟mysql的鎖機制沒有半毛錢的關係。

樂觀鎖的應用例項

①在待鎖的資料表內新增一個version欄位或時間戳

②更新資料的sql

<update id="updateRedPacketStatus" parameterType="java.util.Map">
UPDATE
     yivi_red_packet
    SET
     packet_status=1,
     packet_version = packet_version + 1,
     packet_update_time = now()
    WHERE
     packet_id = #{packetId}
    AND
     packet_version = #{version}
</update>

③程式碼邏輯實現樂觀鎖

params.put("version","0"); //樂觀鎖控制併發
Integer updateResult = this.redPacketMapper.updateRedPacketStatus(params);
if(updateResult > 0){
    //資料更新操作
}else{
    //獲取鎖失敗
}

每次資料更新後，version的值會增加1；只有傳入的version值等於資料庫記錄的version值時，該事務才能對資料進行更新操作，其他的事務一律遮蔽在外，這就實現了所謂的“樂觀鎖”。

好了，我是張星，歡迎加入博主技術交流群，群號：313145288