java樂觀鎖實現案例
阿新 • • 發佈:2019-02-07
簡單說說樂觀鎖。樂觀鎖是相對於悲觀鎖而言。悲觀鎖認為,這個執行緒,發生併發的可能性極大,執行緒衝突機率大,比較悲觀。一般用synchronized實現,保證每次操作資料不會衝突。樂觀鎖認為,執行緒衝突可能性小,比較樂觀,直接去操作資料,如果發現數據已經被更改(通過版本號控制),則不更新資料,再次去重複 所需操作,知道沒有衝突(使用遞迴演算法)。
因為樂觀鎖使用遞迴+版本號控制 實現,所以,如果執行緒衝突機率大,使用樂觀鎖會重複很多次操作(包括查詢資料庫),尤其是遞迴部分邏輯複雜,耗時和耗效能,是低效不合適的,應考慮使用悲觀鎖。
樂觀鎖悲觀鎖的選擇:
樂觀鎖:併發衝突機率小,對應模組遞迴操作簡單 時使用
悲觀鎖:併發機率大,對應模組操作複雜 時使用
下面給出一個樂觀鎖例項:
/**
* 自動派單
* 只查出一條 返回list只是為了和查詢介面統一
* 視訊稽核訂單不派送
* @param paramMap
* @return
*/
public List<AutomaticAssignDto> automaticAssign(Map<String, Object> paramMap){
//派送規則
String changeSortSet = RedisCacheUtil.getValue(CACHE_TYPE.APP, "changeSortSet");
if (StringUtils.isBlank(changeSortSet)) {
changeSortSet = customerManager.getDictionaryByCode("changeSortSet");
if (StringUtils.isNotBlank(changeSortSet)) {
RedisCacheUtil.addValue(CACHE_TYPE.APP, "changeSortSet", changeSortSet,30,TimeUnit.DAYS);
} else {
changeSortSet = ConstantsUtil.AssignRule.FIFO; // 預設先進先審
}
}
AutomaticAssignDto automaticAssignDto = new AutomaticAssignDto();
automaticAssignDto.setChangeSortSet(changeSortSet);
automaticAssignDto.setUserTeam(CommonUtils.getValue(paramMap, "userTeam"));
List<AutomaticAssignDto> waitCheckList = automaticAssignMybatisDao.automaticAssignOrder(automaticAssignDto);
if(waitCheckList != null && waitCheckList.size()>0){
automaticAssignDto = waitCheckList.get(0);
automaticAssignDto.setSendStatus(ConstantsUtil.SendStatus.SEND);
automaticAssignDto.setBindTime(new Date());
automaticAssignDto.setUserId(Long.parseLong(paramMap.get("userId").toString()) );
int sum = automaticAssignMybatisDao.bindAutomaticAssignInfo(automaticAssignDto);
if(sum == 1){
return waitCheckList;
}else{
//已被更新 則再次獲取
return automaticAssign(paramMap);
}
}else{
return null;
}
}
對應更新的sql:
<update id="bindAutomaticAssignInfo" parameterType="com.star.manager.dto.apply.AutomaticAssignDto">
UPDATE t_automatic_assign
SET
SEND_STATUS = #{sendStatus} ,
BIND_TIME = SYSDATE() ,
LOCKED_FINISHTIME = SYSDATE(),
USER_ID = #{userId} ,
VERSION = VERSION + 1,
UPDATE_DATE = SYSDATE()
WHERE SLT_ACCOUNT_ID = #{sltAccountId}
AND VERSION = #{version}
</update>
簡要說明:表設計時,需要往表裡加一個version欄位。每次查詢時,查出帶有version的資料記錄,更新資料時,判斷資料庫裡對應id的記錄的version是否和查出的version相同。若相同,則更新資料並把版本號+1;若不同,則說明,該資料傳送併發,被別的執行緒使用了,進行遞迴操作,再次執行遞迴方法,知道成功更新資料為止。
上述automaticAssign方法即實現了一個樂觀鎖,作用是衝資料庫裡更新一條資料病返回前端。如果併發率大,一次請求可能則會重複執行很多次automaticAssign,則效能低。如果併發很樂觀,使用者請求少,則不需要用synchronized,多執行緒時效能高。
在此只是簡單說說,詳細概念等需另行查閱相關資料。