Java與Mysql鎖相關(guān)知識(shí)總結(jié)
鎖的定義
在計(jì)算機(jī)程序中鎖用于獨(dú)占資源,獲取到鎖才可以操作對(duì)應(yīng)的資源。
鎖的實(shí)現(xiàn)
鎖在計(jì)算機(jī)底層的實(shí)現(xiàn),依賴于CPU提供的CAS指令(compare and swsp),對(duì)于一個(gè)內(nèi)存地址,會(huì)比較原值以及嘗試去修改的值,通過值是否修改成功,來表示是否強(qiáng)占到了這個(gè)鎖。
JVM中的鎖
jvm中,有2個(gè)常用的鎖
synchronized
synchronized是java提供的關(guān)鍵字鎖,可以鎖對(duì)象,類,方法。
在JDK1.6以后,對(duì)synchronized進(jìn)行了優(yōu)化,增加了偏向鎖和輕量鎖模式,現(xiàn)在synchronized鎖的運(yùn)行邏輯如下:
- 在初始加鎖時(shí),會(huì)增加偏向鎖,即“偏向上一次獲取該鎖的線程”,在偏向鎖下,會(huì)直接CAS獲取該鎖。該模式大大提高了單線程反復(fù)獲取同一個(gè)鎖的吞吐情況,在Java官方看來,大部分鎖的爭(zhēng)搶都發(fā)生在同個(gè)線程上。
- 如果偏向鎖CAS獲取失敗,說明當(dāng)前線程與偏向鎖偏向的線程不同,偏向鎖就會(huì)升級(jí)成輕量鎖,輕量鎖的特點(diǎn)就是通過自旋CAS去獲取鎖。
- 如果自旋獲取失敗,那么鎖就會(huì)升級(jí)成重量鎖,所有等待鎖的線程將被JVM掛起,在鎖釋放后,再由JVM統(tǒng)一通知喚醒,再去嘗試CAS鎖,如果失敗,繼續(xù)掛起。
很顯然,偏向鎖設(shè)計(jì)的目的是“在Java官方看來,對(duì)同一個(gè)鎖的爭(zhēng)搶大部分都發(fā)生在同個(gè)線程上”。
輕量鎖設(shè)計(jì)的目的是“在短期內(nèi),鎖的爭(zhēng)搶通過自旋CAS就可以獲取到,短時(shí)間內(nèi)的CPU自旋消耗小于線程掛起再喚醒的消耗”。
重量鎖就是最初優(yōu)化前的synchronized的邏輯了。
ReentrantLock
說到ReentrantLock,就不得不說到JUC里的AQS了。
AQS全稱AbstractQueueSynchronizer,幾乎JUC里所有的工具類,都依賴AQS實(shí)現(xiàn)。
AQS在java里,是一個(gè)抽象類,但是本質(zhì)上是一種思路在java中的實(shí)現(xiàn)而已。
AQS的實(shí)現(xiàn)邏輯如下:
- 構(gòu)造一個(gè)隊(duì)列
- 隊(duì)列中維護(hù)需要等待鎖的線程
- 頭結(jié)點(diǎn)永遠(yuǎn)是持有鎖(或持有資源)的節(jié)點(diǎn),等待的節(jié)點(diǎn)在頭結(jié)點(diǎn)之后依次連接。
- 頭結(jié)點(diǎn)釋放鎖后,會(huì)按照順序去喚醒那些等待的節(jié)點(diǎn),然后那些節(jié)點(diǎn)會(huì)再次去嘗試獲取鎖。
在synchronized鎖優(yōu)化以后,AQS的本質(zhì)與synchronized并沒有太大不同,兩者的性能也并沒有太大差距了,所以AQS現(xiàn)在的特點(diǎn)是:
- 是在java api層面實(shí)現(xiàn)的鎖,所以可以實(shí)現(xiàn)各種并發(fā)工具類,操作也更加靈活
- 因?yàn)樘峁┝顺瑫r(shí)時(shí)間等機(jī)制,操作靈活,所以不易死鎖。(相同的,如果發(fā)生死鎖,將更難排查,因?yàn)閖stack里將不會(huì)有deadlock標(biāo)識(shí))。
- 可以實(shí)現(xiàn)公平鎖,而synchronized必定是非公平鎖。
- 因?yàn)槭荍avaApi層實(shí)現(xiàn)的鎖,所以可以響應(yīng)中斷。
到這里你會(huì)發(fā)現(xiàn),其實(shí)ReentrantLock可以說是synchronized在JavaApi層的實(shí)現(xiàn)。
Mysql 鎖
共享鎖(S) 與排它鎖(X)
作用范圍
這兩種鎖都包括行級(jí)鎖和表級(jí)鎖。
獲取共享鎖時(shí),如果該數(shù)據(jù)被其他事務(wù)的排它鎖鎖住,則無法獲取,需要等待排它鎖釋放。
意向鎖
作用范圍
意向鎖為表鎖,在獲取表鎖之前,一定會(huì)檢查意向鎖。
意圖鎖定協(xié)議如下:
在事務(wù)獲得表中某行的共享鎖之前,它必須首先獲得表上的 IS 鎖或更強(qiáng)的鎖。
在事務(wù)獲得表中行的排他鎖之前,它必須首先獲得表的 IX 鎖。
在獲取任意表鎖的共享鎖或排它鎖之前,一定會(huì)檢查該表上的共享鎖。
表鎖以及意向鎖的互斥規(guī)則如下:
X IX S IS
X Conflict Conflict Conflict Conflict
IX Conflict Compatible Conflict Compatible
S Conflict Conflict Compatible Compatible
IS Conflict Compatible Compatible Compatible
意向鎖的作用在于:在獲取表鎖時(shí),可以通過意向鎖來快速判斷能否獲取。
因?yàn)楂@取行級(jí)鎖時(shí),會(huì)先獲取對(duì)應(yīng)的意向鎖,這樣另外的事務(wù)在獲取表鎖時(shí)就可以通過意向鎖快速的判斷,而不需要每行去掃描。
特別注意的是,意向鎖是可以疊加的,即會(huì)存在多個(gè),如T1事務(wù)獲取了意向鎖IX1和行級(jí)鎖X1,T2事務(wù)依舊可以獲取意向鎖IX2和行級(jí)鎖X2,所以僅在獲取表級(jí)鎖之前,才會(huì)檢查意向鎖。
記錄鎖
記錄鎖生效在索引上,用以在SELECT c1 FROM t WHERE c1 = 10 FOR UPDATE時(shí)保護(hù)該行數(shù)據(jù)不被其他事務(wù)更改。
記錄鎖在沒有索引時(shí)依舊會(huì)生效,因?yàn)閕nnodb會(huì)為每張表創(chuàng)建一個(gè)隱藏的索引。
記錄鎖是最基本的行鎖。
間隙鎖
間隙鎖生效在索引上,用于鎖定索引值后的行,防止插入,在select from table where index=? for update時(shí)會(huì)生效,例如index=1,則會(huì)鎖住index=1索引節(jié)點(diǎn)相關(guān)的行,防止其他事務(wù)插入數(shù)據(jù)。
但是并不會(huì)防止update語句,哪怕update的數(shù)據(jù)不存在。
Next-Key Locks
這個(gè)鎖是記錄鎖和間隙鎖的組合,簡(jiǎn)而言之在select from table where index=? for update時(shí),既會(huì)有間隙鎖防止insert,也會(huì)有記錄鎖在index上防止這一條數(shù)據(jù)的update和delete。這個(gè)Next-key只是對(duì)這兩種鎖的一種概括,因?yàn)檫@兩種鎖在select for update時(shí)通常會(huì)一起出現(xiàn)。
Insert Intention Locks
插入意向鎖,和意向鎖類似。不過是特殊的間隙鎖,并不發(fā)生在select for update,而是在同時(shí)發(fā)生insert時(shí)產(chǎn)生,例如在兩個(gè)事務(wù)同時(shí)insert索引區(qū)間為[4,7]時(shí),同時(shí)獲得該區(qū)間的意向鎖,此時(shí)事務(wù)不會(huì)阻塞,例如A:insert-5,B:insert-7,此時(shí)不會(huì)阻塞兩個(gè)事務(wù)。
插入意向鎖是一個(gè)特殊的間隙鎖,是為了防止正常間隙鎖鎖區(qū)間的情況下,insert頻繁阻塞而設(shè)計(jì)的,例如A:insert-5,B:insert-7,如果沒有插入意向鎖,那么5和7都要去嘗試獲取間隙鎖,此時(shí)第二個(gè)事務(wù)就會(huì)被阻塞,但是通過插入意向鎖,第二個(gè)事務(wù)就不會(huì)被阻塞,只有到插入的行確實(shí)沖突,才會(huì)被阻塞。
AUTO-INC Locks
自增鎖,這個(gè)鎖很明顯是表級(jí)insert鎖,為了保證自增主鍵的表的主鍵保持原子自增。
對(duì)于鎖這個(gè)東西,大家應(yīng)該多去理解各種鎖設(shè)計(jì)運(yùn)行的原理和模型,這樣在加深理解后,在使用起來才會(huì)更加深入和透徹。
常見鎖使用的場(chǎng)景和用法
double check
眾所周知,mysql的事務(wù)對(duì)防止重復(fù)插入并沒有什么卵用,唯一索引又存在很多缺點(diǎn),業(yè)務(wù)上最好不要使用,所以一般來說防止重復(fù)插入的通用做法就是使用分布式鎖,這就有一種比較常用的寫法。
final WeekendNoticeReadCountDO weekendNoticeReadCountDO = weekendNoticeReadRepositoryService.selectByNoticeId(noticeRequestDTO.getNoticeId()); if (weekendNoticeReadCountDO == null) { final String lockKey = RedisConstant.LOCK_WEEKEND_READ_COUNT_INSERT + ":" + noticeRequestDTO.getNoticeId(); ClusterLock lock = clusterLockFactory.getClusterLockRedis( RedisConstant.REDIS_KEY_PREFIX, lockKey ); if (lock.acquire(RedisConstant.REDIS_LOCK_DEFAULT_TIMEOUT)) { //double check final WeekendNoticeReadCountDO weekendNoticeReadCountDO = weekendNoticeReadRepositoryService.selectByNoticeId(noticeRequestDTO.getNoticeId()); if (weekendNoticeReadCountDO == null) { try { lock.execute(() -> { WeekendNoticeReadCountDO readCountDO = new WeekendNoticeReadCountDO(); readCountDO.setNoticeId(noticeRequestDTO.getNoticeId()); readCountDO.setReadCount(1L); readCountDO.setCreateTime(new Date()); readCountDO.setUpdateTime(new Date()); weekendNoticeReadRepositoryService.insert(readCountDO); return true; }); } catch (ApiException err) { throw err; } catch (Exception e) { log.error("插入", e); throw new ApiException(ErrorEnum.SERVER_ERROR.getCode(), "服務(wù)端出錯(cuò)"); } } else { weekendNoticeReadRepositoryService.noticeCountAdd(weekendNoticeReadCountDO); } } else { log.warn("redis鎖獲取超時(shí),key:{}", lockKey); throw new ApiException(ErrorEnum.SERVER_ERROR.getCode(), "服務(wù)器繁忙,請(qǐng)稍后重試"); } }
在獲取到鎖之后,可能是經(jīng)過等待才獲取到的鎖,此時(shí)上一個(gè)釋放鎖的線程可能已經(jīng)插入了數(shù)據(jù)了,所以在鎖內(nèi)部,依舊要再次校驗(yàn)一下數(shù)據(jù)是否存在。
這種寫法適合大多數(shù)需要唯一性的寫場(chǎng)景。
避免死鎖
如何避免死鎖?最簡(jiǎn)單有效的方法就是:**不要在鎖里再去獲取鎖,簡(jiǎn)而言之就是鎖最好單獨(dú)使用,不要套娃。
也要注意一些隱性鎖,比如數(shù)據(jù)庫。
事務(wù)A:
- 插入[5,7],插入意向鎖。
- select for update更新[100,150],間隙鎖。
事務(wù)B: - select for update更新[90,120],間隙鎖。
- 插入[4,6],插入意向鎖。
此時(shí)在并發(fā)場(chǎng)景下,就可能會(huì)出現(xiàn)A持有了[5,7]的間隙鎖,在等待事務(wù)B[90,120]的間隙鎖,事務(wù)B也一樣,就死鎖了。
**
順帶談?wù)劜l(fā)場(chǎng)景下常見的問題
讀寫混亂
在寫業(yè)務(wù)代碼,定義一些工具類或者緩存類的時(shí)候,很容易疏忽而發(fā)生類似的問題。
比如構(gòu)建一個(gè)static緩存,沒有使用ConcurrentHashMap中的putIfAbsent等方法,也沒有加鎖去構(gòu)建,導(dǎo)致上面的線程剛put了,下面的線程就刪掉了,或者重復(fù)構(gòu)建2次緩存。
Redis或者一些并發(fā)操作釋放鎖或者資源,沒有檢查是否是當(dāng)前線程持有
這點(diǎn)在Redis鎖的示例代碼也講到了。
線程A獲取到鎖,此時(shí)B,C在等待,然后A執(zhí)行時(shí)間過長(zhǎng),導(dǎo)致鎖超時(shí)被自動(dòng)釋放了,此時(shí)B獲取到了鎖,在快樂的執(zhí)行,然后A執(zhí)行完了之后,釋放鎖時(shí)沒有判斷是否還是自己持有,導(dǎo)致B持有的鎖被刪除了,此時(shí)C又獲取到了鎖,BC同時(shí)在執(zhí)行。
到此這篇關(guān)于Java與Mysql鎖相關(guān)知識(shí)總結(jié)的文章就介紹到這了,更多相關(guān)Java與Mysql鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
基于SpringBoot和Vue的動(dòng)態(tài)語音播放實(shí)現(xiàn)
本文介紹如何使用SpringBoot和Vue實(shí)現(xiàn)音頻文件的動(dòng)態(tài)播放,包括前端頁面設(shè)計(jì)、后端接口開發(fā)、音頻文件存儲(chǔ)和調(diào)用等方面。通過該實(shí)現(xiàn),用戶可以在網(wǎng)頁上直接播放音頻,增強(qiáng)用戶體驗(yàn),提高網(wǎng)站互動(dòng)性2023-04-04Java堆&優(yōu)先級(jí)隊(duì)列示例講解(下)
這篇文章主要通過示例詳細(xì)為大家介紹Java中的堆以及優(yōu)先級(jí)隊(duì)列,文中的示例代碼講解詳細(xì),對(duì)我們了解java有一定幫助,需要的可以參考一下2022-03-03Java的內(nèi)存區(qū)域與內(nèi)存溢出異常你了解嗎
這篇文章主要為大家詳細(xì)介紹了Java的內(nèi)存區(qū)域與內(nèi)存溢出異常,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下,希望能夠給你帶來幫助2022-03-03springboot使用redisTemplate操作lua腳本
本文主要介紹了springboot使用redisTemplate操作lua腳本,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08Java動(dòng)態(tài)規(guī)劃方式解決不同的二叉搜索樹
二叉搜索樹作為一個(gè)經(jīng)典的數(shù)據(jù)結(jié)構(gòu),具有鏈表的快速插入與刪除的特點(diǎn),同時(shí)查詢效率也很優(yōu)秀,所以應(yīng)用十分廣泛。本文將詳細(xì)講講二叉搜索樹的原理與實(shí)現(xiàn),需要的可以參考一下2022-10-10Java中Double、Float類型的NaN和Infinity的具體使用
Java在處理浮點(diǎn)數(shù)運(yùn)算時(shí),提供了NaN和Infinity兩個(gè)常量,本文主要介紹了Java中Double、Float類型的NaN和Infinity的具體使用,文中通過示例代碼介紹的非常詳細(xì),需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-06-06MapStruct對(duì)象映射轉(zhuǎn)換解決Bean屬性拷貝性能問題
無意間看到項(xiàng)目中有小伙伴用到了 MapStruct 來做對(duì)象映射轉(zhuǎn)換當(dāng)時(shí)我就很好奇,這個(gè)是什么框架,能夠解決什么問題,帶著這兩個(gè)疑問就有了下面的文章2022-02-02Spring加載properties文件的兩種方式實(shí)例詳解
這篇文章主要介紹了Spring加載properties文件的兩種方式,需要的朋友可以參考下2018-02-02