快捷導(dǎo)航

Java鎖競(jìng)爭(zhēng)導(dǎo)致sql慢日志原因分析

更新時(shí)間：2022年11月20日 15:40:18 作者：古柏樹(shù)下

這篇文章主要介紹了Java鎖競(jìng)爭(zhēng)導(dǎo)致sql慢的日志原因分析，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧

線(xiàn)上在同步用戶(hù)時(shí)，經(jīng)常出現(xiàn)簡(jiǎn)單sql的慢日志。根據(jù)方法找到代碼，發(fā)現(xiàn)方法內(nèi)使用redisson進(jìn)行鎖操作，waiTime和leaseTime都為3秒,數(shù)據(jù)庫(kù)操作比較簡(jiǎn)單，只是一個(gè)簡(jiǎn)單的用戶(hù)更新操作。代碼簡(jiǎn)化后如下

@Override
@Transactional(rollbackFor = Exception.class)
public LiveMemberResponseDTO becomeStudentNotQueryOrder(LiveBecomeStudentForOrderRequestDTO requestDTO) {
    EduUserEntity user = eduUserService.syncLocalByAccount(requestDTO.getOrderAccountId(), UserRegisterChannel.LIVE_APPLY);
    EduUserEntity applyUser = eduUserService.syncLocalByAccount(requestDTO.getApplyAccountId(), UserRegisterChannel.LIVE_APPLY);
    ...
    ...
    ...
}

調(diào)用了更新方法

@Override
@Lock(waitTime = 10000, leaseTime = 3000, value = RedisConstant.USER_SYNC_LOCAL, key = "#accountId")
public EduUserEntity syncLocalByAccount(String accountId, String mobile, String fullName, String source, UserRegisterChannel registerChannel) {
    EduUserEntity eduUserEntity = queryUsersByAccountId(accountId);
    boolean updateFlag = false;
    ....
	....
	....//判斷是否需要更新
    if (updateFlag) {
       saveOrUpdate(eduUserEntity);
    }
    return eduUserEntity;
}

由于這里事務(wù)里面嵌套了redis鎖，并且涉及到更新表，可能會(huì)有死鎖的情況。通過(guò)在獲取鎖的地方打上地址獲取到以下日志

可以看到[Thread-13]在等待了三秒后才獲取到redis，根據(jù)獲取鎖的時(shí)機(jī)，列出表格

事務(wù)A(Thread-13)	事務(wù)B(Thread-14)
獲取redis鎖
獲取db鎖
釋放redis鎖
	獲取redis鎖
	嘗試獲取db鎖
嘗試獲取redis鎖
	等待三秒
	redis鎖超時(shí)，釋放redis鎖
成功獲取redis鎖
完成業(yè)務(wù)
釋放redis和db鎖
	獲取db鎖

這是由于兩次更新user表過(guò)程中，使用了一個(gè)事務(wù)A，導(dǎo)致事務(wù)B來(lái)獲取db行鎖的時(shí)候，被事務(wù)A阻塞。但在被事務(wù)A阻塞前，已經(jīng)獲取到了redis鎖，所以導(dǎo)致事務(wù)A在獲取第二次更新的redis鎖的時(shí)候被阻塞，造成了死鎖。

最終導(dǎo)致，redis鎖超時(shí)，日志方面體現(xiàn)為慢sql，因?yàn)槭聞?wù)B的sql等待了三秒才拿到鎖。

這種情況是因?yàn)槭聞?wù)和redis鎖的嵌套導(dǎo)致，所以指定更新方法的事務(wù)傳播等級(jí)為PROPAGATION_REQUIRED_NEW，不管外層是否存著事務(wù)，都開(kāi)啟新事務(wù)。

修改后代碼

@Override
@Lock(waitTime = 10000, leaseTime = 3000, value = RedisConstant.USER_SYNC_LOCAL, key = "#accountId")
//這里開(kāi)啟新事務(wù)
@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
public EduUserEntity syncLocalByAccount(String accountId, String mobile, String fullName, String source, UserRegisterChannel registerChannel) {
    EduUserEntity eduUserEntity = queryUsersByAccountId(accountId);
    boolean updateFlag = false;
    ....
	....
	....//判斷是否需要更新
    if (updateFlag) {
       saveOrUpdate(eduUserEntity);
    }
    return eduUserEntity;
}

聲明式事務(wù)使用很簡(jiǎn)單，可以自動(dòng)幫我們進(jìn)行事務(wù)的開(kāi)啟、提交以及回滾等操作，但是事務(wù)的顆粒度是整個(gè)方法，無(wú)法進(jìn)行精細(xì)化控制。在使用過(guò)程中要注意事務(wù)的范圍與其他中間件的交互，通過(guò)指定適當(dāng)?shù)膫鞑サ燃?jí)來(lái)達(dá)到效果。

到此這篇關(guān)于Java鎖競(jìng)爭(zhēng)導(dǎo)致sql慢日志原因分析的文章就介紹到這了,更多相關(guān)Java sql慢日志內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: