成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

再有人問你分布式鎖是什么,就把這篇文章發(fā)給他

開發(fā) 架構(gòu) 開發(fā)工具 分布式
現(xiàn)在面試,一般都會聊聊分布式系統(tǒng)這塊的東西。通常面試官都會從服務(wù)框架(Spring Cloud、Dubbo)聊起,一路聊到分布式事務(wù)、分布式鎖、ZooKeeper 等知識。

 現(xiàn)在面試,一般都會聊聊分布式系統(tǒng)這塊的東西。通常面試官都會從服務(wù)框架(Spring Cloud、Dubbo)聊起,一路聊到分布式事務(wù)、分布式鎖、ZooKeeper 等知識。

所以咱們就來聊聊分布式鎖這塊的知識,先具體的來看看 Redis 分布式鎖的實現(xiàn)原理。

說實話,如果在公司里落地生產(chǎn)環(huán)境用分布式鎖的時候,一定是會用開源類庫的,比如 Redis 分布式鎖,一般就是用 Redisson 框架就好了,非常的簡便易用。

大家如果有興趣,可以去 Redisson 的官網(wǎng),看看如何在項目中引入 Redisson 的依賴,然后基于 Redis 實現(xiàn)分布式鎖的加鎖與釋放鎖。

下面給大家看一段簡單的使用代碼片段,先直觀的感受一下:

 

怎么樣,上面那段代碼,是不是感覺簡單的不行!此外,人家還支持 Redis 單實例、Redis 哨兵、Redis Cluster、redis master-slave 等各種部署架構(gòu),都可以給你***實現(xiàn)。

Redisson 實現(xiàn) Redis 分布式鎖的底層原理

好的,接下來就通過一張手繪圖,給大家說說 Redisson 這個開源框架對 Redis 分布式鎖的實現(xiàn)原理。

 

加鎖機(jī)制

咱們來看上面那張圖,現(xiàn)在某個客戶端要加鎖。如果該客戶端面對的是一個 Redis Cluster 集群,他首先會根據(jù) Hash 節(jié)點選擇一臺機(jī)器。

這里注意,僅僅只是選擇一臺機(jī)器!這點很關(guān)鍵!緊接著,就會發(fā)送一段 Lua 腳本到 Redis 上,那段 Lua 腳本如下所示:

 

為啥要用 Lua 腳本呢?因為一大坨復(fù)雜的業(yè)務(wù)邏輯,可以通過封裝在 Lua 腳本中發(fā)送給 Redis,保證這段復(fù)雜業(yè)務(wù)邏輯執(zhí)行的原子性。

那么,這段 Lua 腳本是什么意思呢?這里 KEYS[1] 代表的是你加鎖的那個 Key,比如說:RLock lock = redisson.getLock("myLock");這里你自己設(shè)置了加鎖的那個鎖 Key 就是“myLock”。

ARGV[1] 代表的就是鎖 Key 的默認(rèn)生存時間,默認(rèn) 30 秒。ARGV[2] 代表的是加鎖的客戶端的 ID,類似于下面這樣:8743c9c0-0795-4907-87fd-6c719a6b4586:1。

給大家解釋一下,***段 if 判斷語句,就是用“exists myLock”命令判斷一下,如果你要加鎖的那個鎖 Key 不存在的話,你就進(jìn)行加鎖。如何加鎖呢?很簡單,用下面的命令:hset myLock。

8743c9c0-0795-4907-87fd-6c719a6b4586:1 1,通過這個命令設(shè)置一個 Hash 數(shù)據(jù)結(jié)構(gòu),這行命令執(zhí)行后,會出現(xiàn)一個類似下面的數(shù)據(jù)結(jié)構(gòu):

 

上述就代表“8743c9c0-0795-4907-87fd-6c719a6b4586:1”這個客戶端對“myLock”這個鎖 Key 完成了加鎖。

接著會執(zhí)行“pexpire myLock 30000”命令,設(shè)置 myLock 這個鎖 Key 的生存時間是 30 秒。好了,到此為止,加鎖完成了。

鎖互斥機(jī)制

那么在這個時候,如果客戶端 2 來嘗試加鎖,執(zhí)行了同樣的一段 Lua 腳本,會咋樣呢?

很簡單,***個 if 判斷會執(zhí)行“exists myLock”,發(fā)現(xiàn) myLock 這個鎖 Key 已經(jīng)存在了。

接著第二個 if 判斷,判斷一下,myLock 鎖 Key 的 Hash 數(shù)據(jù)結(jié)構(gòu)中,是否包含客戶端 2 的 ID,但是明顯不是的,因為那里包含的是客戶端 1 的 ID。

所以,客戶端 2 會獲取到 pttl myLock 返回的一個數(shù)字,這個數(shù)字代表了 myLock 這個鎖 Key 的剩余生存時間。

比如還剩 15000 毫秒的生存時間。此時客戶端 2 會進(jìn)入一個 while 循環(huán),不停的嘗試加鎖。

watch dog 自動延期機(jī)制

客戶端 1 加鎖的鎖 Key 默認(rèn)生存時間才 30 秒,如果超過了 30 秒,客戶端 1 還想一直持有這把鎖,怎么辦呢?

簡單!只要客戶端 1 一旦加鎖成功,就會啟動一個 watch dog 看門狗,他是一個后臺線程,會每隔 10 秒檢查一下,如果客戶端 1 還持有鎖 Key,那么就會不斷的延長鎖 Key 的生存時間。

可重入加鎖機(jī)制

那如果客戶端 1 都已經(jīng)持有了這把鎖了,結(jié)果可重入的加鎖會怎么樣呢?比如下面這種代碼:

 

這時我們來分析一下上面那段 Lua 腳本。***個if判斷肯定不成立,“exists myLock”會顯示鎖 Key 已經(jīng)存在了。

第二個 if 判斷會成立,因為 myLock 的 Hash 數(shù)據(jù)結(jié)構(gòu)中包含的那個 ID,就是客戶端 1 的那個 ID,也就是“8743c9c0-0795-4907-87fd-6c719a6b4586:1”。

此時就會執(zhí)行可重入加鎖的邏輯,他會用:incrby myLock 8743c9c0-0795-4907-87fd-6c71a6b4586:1 1,通過這個命令,對客戶端 1 的加鎖次數(shù),累加 1。

此時 myLock 數(shù)據(jù)結(jié)構(gòu)變?yōu)橄旅孢@樣:

 

大家看到了吧,那個 myLock 的 Hash 數(shù)據(jù)結(jié)構(gòu)中的那個客戶端 ID,就對應(yīng)著加鎖的次數(shù)。

釋放鎖機(jī)制

如果執(zhí)行 lock.unlock(),就可以釋放分布式鎖,此時的業(yè)務(wù)邏輯也是非常簡單的。其實說白了,就是每次都對 myLock 數(shù)據(jù)結(jié)構(gòu)中的那個加鎖次數(shù)減 1。

如果發(fā)現(xiàn)加鎖次數(shù)是 0 了,說明這個客戶端已經(jīng)不再持有鎖了,此時就會用:“del myLock”命令,從 Redis 里刪除這個 Key。

然后呢,另外的客戶端 2 就可以嘗試完成加鎖了。這就是所謂的分布式鎖的開源 Redisson 框架的實現(xiàn)機(jī)制。

一般我們在生產(chǎn)系統(tǒng)中,可以用 Redisson 框架提供的這個類庫來基于 Redis 進(jìn)行分布式鎖的加鎖與釋放鎖。

上述 Redis 分布式鎖的缺點

上面那種方案***的問題,就是如果你對某個 Redis Master 實例,寫入了 myLock 這種鎖 Key 的 Value,此時會異步復(fù)制給對應(yīng)的 Master Slave 實例。

但是這個過程中一旦發(fā)生 Redis Master 宕機(jī),主備切換,Redis Slave 變?yōu)榱?Redis Master。

接著就會導(dǎo)致,客戶端 2 來嘗試加鎖的時候,在新的 Redis Master 上完成了加鎖,而客戶端 1 也以為自己成功加了鎖。

此時就會導(dǎo)致多個客戶端對一個分布式鎖完成了加鎖。這時系統(tǒng)在業(yè)務(wù)語義上一定會出現(xiàn)問題,導(dǎo)致各種臟數(shù)據(jù)的產(chǎn)生。

所以這個就是 Redis Cluster,或者是 redis master-slave 架構(gòu)的主從異步復(fù)制導(dǎo)致的 Redis 分布式鎖的***缺陷:在 Redis Master 實例宕機(jī)的時候,可能導(dǎo)致多個客戶端同時完成加鎖。

七張圖徹底講清楚 ZooKeeper 分布式鎖的實現(xiàn)原理

下面再給大家聊一下 ZooKeeper 實現(xiàn)分布式鎖的原理。同理,我是直接基于比較常用的 Curator 這個開源框架,聊一下這個框架對 ZooKeeper(以下簡稱 ZK)分布式鎖的實現(xiàn)。

一般除了大公司是自行封裝分布式鎖框架之外,建議大家用這些開源框架封裝好的分布式鎖實現(xiàn),這是一個比較快捷省事兒的方式。

ZooKeeper 分布式鎖機(jī)制

接下來我們一起來看看,多客戶端獲取及釋放 ZK 分布式鎖的整個流程及背后的原理。

首先大家看看下面的圖,如果現(xiàn)在有兩個客戶端一起要爭搶 ZK 上的一把分布式鎖,會是個什么場景?

 

如果大家對 ZK 還不太了解的話,建議先自行百度一下,簡單了解點基本概念,比如 ZK 有哪些節(jié)點類型等等。

參見上圖。ZK 里有一把鎖,這個鎖就是 ZK 上的一個節(jié)點。然后呢,兩個客戶端都要來獲取這個鎖,具體是怎么來獲取呢?

咱們就假設(shè)客戶端 A 搶先一步,對 ZK 發(fā)起了加分布式鎖的請求,這個加鎖請求是用到了 ZK 中的一個特殊的概念,叫做“臨時順序節(jié)點”。

簡單來說,就是直接在"my_lock"這個鎖節(jié)點下,創(chuàng)建一個順序節(jié)點,這個順序節(jié)點有 ZK 內(nèi)部自行維護(hù)的一個節(jié)點序號。

比如說,***個客戶端來搞一個順序節(jié)點,ZK 內(nèi)部會給起個名字叫做:xxx-000001。

然后第二個客戶端來搞一個順序節(jié)點,ZK 可能會起個名字叫做:xxx-000002。

大家注意一下,***一個數(shù)字都是依次遞增的,從 1 開始逐次遞增。ZK 會維護(hù)這個順序。

所以這個時候,假如說客戶端 A 先發(fā)起請求,就會搞出來一個順序節(jié)點,大家看下面的圖,Curator 框架大概會弄成如下的樣子:

 

大家看,客戶端 A 發(fā)起一個加鎖請求,先會在你要加鎖的 node 下搞一個臨時順序節(jié)點,這一大坨長長的名字都是 Curator 框架自己生成出來的。

然后,那個***一個數(shù)字是"1"。大家注意一下,因為客戶端 A 是***個發(fā)起請求的,所以給他搞出來的順序節(jié)點的序號是"1"。

接著客戶端 A 創(chuàng)建完一個順序節(jié)點。還沒完,他會查一下"my_lock"這個鎖節(jié)點下的所有子節(jié)點,并且這些子節(jié)點是按照序號排序的,這個時候他大概會拿到這么一個集合:

 

接著客戶端 A 會走一個關(guān)鍵性的判斷,就是說:唉!兄弟,這個集合里,我創(chuàng)建的那個順序節(jié)點,是不是排在***個啊?

如果是的話,那我就可以加鎖了啊!因為明明我就是***個來創(chuàng)建順序節(jié)點的人,所以我就是***個嘗試加分布式鎖的人啊!

Bingo!加鎖成功!大家看下面的圖,再來直觀的感受一下整個過程:

 

接著假如說,客戶端 A 都加完鎖了,客戶端 B 過來想要加鎖了,這個時候他會干一樣的事兒:先是在"my_lock"這個鎖節(jié)點下創(chuàng)建一個臨時順序節(jié)點,此時名字會變成類似于:

 

大家看看下面的圖:

 

客戶端 B 因為是第二個來創(chuàng)建順序節(jié)點的,所以 ZK 內(nèi)部會維護(hù)序號為"2"。

接著客戶端 B 會走加鎖判斷邏輯,查詢"my_lock"鎖節(jié)點下的所有子節(jié)點,按序號順序排列,此時他看到的類似于:

 

同時檢查自己創(chuàng)建的順序節(jié)點,是不是集合中的***個?明顯不是啊,此時***個是客戶端 A 創(chuàng)建的那個順序節(jié)點,序號為"01"的那個。所以加鎖失敗!

加鎖失敗了以后,客戶端 B 就會通過 ZK 的 API 對他的順序節(jié)點的上一個順序節(jié)點加一個監(jiān)聽器。ZK 天然就可以實現(xiàn)對某個節(jié)點的監(jiān)聽。

如果大家還不知道 ZK 的基本用法,可以百度查閱,非常的簡單。客戶端 B 的順序節(jié)點是:

 

他的上一個順序節(jié)點,不就是下面這個嗎?

 

即客戶端 A 創(chuàng)建的那個順序節(jié)點!所以,客戶端 B 會對

 

這個節(jié)點加一個監(jiān)聽器,監(jiān)聽這個節(jié)點是否被刪除等變化!大家看下面的圖:

接著,客戶端 A 加鎖之后,可能處理了一些代碼邏輯,然后就會釋放鎖。那么,釋放鎖是個什么過程呢?

其實很簡單,就是把自己在 ZK 里創(chuàng)建的那個順序節(jié)點,也就是:

這個節(jié)點給刪除。刪除了那個節(jié)點之后,ZK 會負(fù)責(zé)通知監(jiān)聽這個節(jié)點的監(jiān)聽器,也就是客戶端 B 之前加的那個監(jiān)聽器,說:兄弟,你監(jiān)聽的那個節(jié)點被刪除了,有人釋放了鎖。

此時客戶端 B 的監(jiān)聽器感知到了上一個順序節(jié)點被刪除,也就是排在他之前的某個客戶端釋放了鎖。

此時,就會通知客戶端 B 重新嘗試去獲取鎖,也就是獲取"my_lock"節(jié)點下的子節(jié)點集合,此時為:

集合里此時只有客戶端 B 創(chuàng)建的唯一的一個順序節(jié)點了!然后呢,客戶端 B 判斷自己居然是集合中的***個順序節(jié)點,Bingo!可以加鎖了!直接完成加鎖,運(yùn)行后續(xù)的業(yè)務(wù)代碼即可,運(yùn)行完了之后再次釋放鎖。

其實如果有客戶端 C、客戶端 D 等 N 個客戶端爭搶一個 ZK 分布式鎖,原理都是類似的:

  • 大家都是上來直接創(chuàng)建一個鎖節(jié)點下的一個接一個的臨時順序節(jié)點。
  • 如果自己不是***個節(jié)點,就對自己上一個節(jié)點加監(jiān)聽器。
  • 只要上一個節(jié)點釋放鎖,自己就排到前面去了,相當(dāng)于是一個排隊機(jī)制。

而且用臨時順序節(jié)點的另外一個用意就是,如果某個客戶端創(chuàng)建臨時順序節(jié)點之后,不小心自己宕機(jī)了也沒關(guān)系,ZK 感知到那個客戶端宕機(jī),會自動刪除對應(yīng)的臨時順序節(jié)點,相當(dāng)于自動釋放鎖,或者是自動取消自己的排隊。

***,咱們來看下用 Curator 框架進(jìn)行加鎖和釋放鎖的一個過程:

其實用開源框架就是這點好,方便。這個 Curator 框架的 ZK 分布式鎖的加鎖和釋放鎖的實現(xiàn)原理,就是上面我們說的那樣子。

但是如果你要手動實現(xiàn)一套那個代碼的話。還是有點麻煩的,要考慮到各種細(xì)節(jié),異常處理等等。所以大家如果考慮用 ZK 分布式鎖,可以參考下本文的思路。

每秒上千訂單場景下的分布式鎖高并發(fā)優(yōu)化實踐

接著就給大家聊一個有意思的話題:每秒上千訂單場景下,如何對分布式鎖的并發(fā)能力進(jìn)行優(yōu)化?

首先,我們一起來看看這個問題的背景?前段時間有個朋友在外面面試,然后有一天找我聊說:有一個國內(nèi)不錯的電商公司,面試官給他出了一個場景題:

假如下單時,用分布式鎖來防止庫存超賣,但是是每秒上千訂單的高并發(fā)場景,如何對分布式鎖進(jìn)行高并發(fā)優(yōu)化來應(yīng)對這個場景?

他說他當(dāng)時沒答上來,因為沒做過沒什么思路。其實我當(dāng)時聽到這個面試題心里也覺得有點意思,因為如果是我來面試候選人的話,應(yīng)該會給的范圍更大一些。

比如,讓面試的同學(xué)聊一聊電商高并發(fā)秒殺場景下的庫存超賣解決方案,各種方案的優(yōu)缺點以及實踐,進(jìn)而聊到分布式鎖這個話題。

因為庫存超賣問題是有很多種技術(shù)解決方案的,比如悲觀鎖,分布式鎖,樂觀鎖,隊列串行化,Redis 原子操作,等等吧。

但是既然那個面試官兄弟限定死了用分布式鎖來解決庫存超賣,我估計就是想問一個點:在高并發(fā)場景下如何優(yōu)化分布式鎖的并發(fā)性能。

我覺得,面試官提問的角度還是可以接受的,因為在實際落地生產(chǎn)的時候,分布式鎖這個東西保證了數(shù)據(jù)的準(zhǔn)確性,但是他天然并發(fā)能力有點弱。

剛好我之前在自己項目的其他場景下,確實是做過高并發(fā)場景下的分布式鎖優(yōu)化方案,因此正好是借著這個朋友的面試題,把分布式鎖的高并發(fā)優(yōu)化思路,給大家來聊一聊。

庫存超賣現(xiàn)象是怎么產(chǎn)生的?

先來看看如果不用分布式鎖,所謂的電商庫存超賣是啥意思?大家看看下面的圖:

這個圖,其實很清晰了,假設(shè)訂單系統(tǒng)部署在兩臺機(jī)器上,不同的用戶都要同時買 10 臺 iPhone,分別發(fā)了一個請求給訂單系統(tǒng)。

接著每個訂單系統(tǒng)實例都去數(shù)據(jù)庫里查了一下,當(dāng)前 iPhone 庫存是 12 臺。倆大兄弟一看,樂了,12 臺庫存大于了要買的 10 臺數(shù)量啊!

于是乎,每個訂單系統(tǒng)實例都發(fā)送 SQL 到數(shù)據(jù)庫里下單,然后扣減了 10 個庫存,其中一個將庫存從 12 臺扣減為 2 臺,另外一個將庫存從 2 臺扣減為 -8 臺。

現(xiàn)在完了,庫存出現(xiàn)了負(fù)數(shù)!淚奔啊,沒有 20 臺 iPhone 發(fā)給兩個用戶啊!這可如何是好。

用分布式鎖如何解決庫存超賣問題?

我們用分布式鎖如何解決庫存超賣問題呢?其實很簡單,回憶一下上次我們說的那個分布式鎖的實現(xiàn)原理:

同一個鎖 Key,同一時間只能有一個客戶端拿到鎖,其他客戶端會陷入***的等待來嘗試獲取那個鎖,只有獲取到鎖的客戶端才能執(zhí)行下面的業(yè)務(wù)邏輯。

代碼大概就是上面那個樣子,現(xiàn)在我們來分析一下,為啥這樣做可以避免庫存超賣?

大家可以順著上面的那個步驟序號看一遍,馬上就明白了。

從上圖可以看到,只有一個訂單系統(tǒng)實例可以成功加分布式鎖,然后只有他一個實例可以查庫存、判斷庫存是否充足、下單扣減庫存,接著釋放鎖。

釋放鎖之后,另外一個訂單系統(tǒng)實例才能加鎖,接著查庫存,一下發(fā)現(xiàn)庫存只有 2 臺了,庫存不足,無法購買,下單失敗。不會將庫存扣減為 -8 的。

有沒其他方案解決庫存超賣問題?

當(dāng)然有啊!比如悲觀鎖,分布式鎖,樂觀鎖,隊列串行化,異步隊列分散,Redis 原子操作,等等,很多方案,我們對庫存超賣有自己的一整套優(yōu)化機(jī)制。

但是前面說過了,這篇文章就聊一個分布式鎖的并發(fā)優(yōu)化,不是聊庫存超賣的解決方案,所以庫存超賣只是一個業(yè)務(wù)場景而已。

分布式鎖的方案在高并發(fā)場景下

好,現(xiàn)在我們來看看,分布式鎖的方案在高并發(fā)場景下有什么問題?

問題很大啊!兄弟,不知道你看出來了沒有。分布式鎖一旦加了之后,對同一個商品的下單請求,會導(dǎo)致所有客戶端都必須對同一個商品的庫存鎖 Key 進(jìn)行加鎖。

比如,對 iPhone 這個商品的下單,都必對“iphone_stock”這個鎖 Key 來加鎖。這樣會導(dǎo)致對同一個商品的下單請求,就必須串行化,一個接一個的處理。

大家再回去對照上面的圖反復(fù)看一下,應(yīng)該能想明白這個問題。

假設(shè)加鎖之后,釋放鎖之前,查庫存→創(chuàng)建訂單→扣減庫存,這個過程性能很高吧,算他全過程 20 毫秒,這應(yīng)該不錯了。

那么 1 秒是 1000 毫秒,只能容納 50 個對這個商品的請求依次串行完成處理。

比如一秒鐘來 50 個請求,都是對 iPhone 下單的,那么每個請求處理 20 毫秒,一個一個來,*** 1000 毫秒正好處理完 50 個請求。

大家看一眼下面的圖,加深一下感覺。


 

所以看到這里,大家起碼也明白了,簡單的使用分布式鎖來處理庫存超賣問題,存在什么缺陷。

缺陷就是同一個商品多用戶同時下單的時候,會基于分布式鎖串行化處理,導(dǎo)致沒法同時處理同一個商品的大量下單的請求。

這種方案,要是應(yīng)對那種低并發(fā)、無秒殺場景的普通小電商系統(tǒng),可能還可以接受。

因為如果并發(fā)量很低,每秒就不到 10 個請求,沒有瞬時高并發(fā)秒殺單個商品的場景的話,其實也很少會對同一個商品在 1 秒內(nèi)瞬間下 1000 個訂單,因為小電商系統(tǒng)沒那場景。

如何對分布式鎖進(jìn)行高并發(fā)優(yōu)化?

好了,終于引入正題了,那么現(xiàn)在怎么辦呢?

面試官說,我現(xiàn)在就卡死,庫存超賣就是用分布式鎖來解決,而且一秒對一個 iPhone 下上千訂單,怎么優(yōu)化?

現(xiàn)在按照剛才的計算,你 1 秒鐘只能處理針對 iPhone 的 50 個訂單。其實說出來也很簡單,相信很多人看過 Java 里的 ConcurrentHashMap 的源碼和底層原理,應(yīng)該知道里面的核心思路,就是分段加鎖!

把數(shù)據(jù)分成很多個段,每個段是一個單獨(dú)的鎖,所以多個線程過來并發(fā)修改數(shù)據(jù)的時候,可以并發(fā)的修改不同段的數(shù)據(jù)。不至于說,同一時間只能有一個線程獨(dú)占修改 ConcurrentHashMap 中的數(shù)據(jù)。

另外,Java 8 中新增了一個 LongAdder 類,也是針對 Java 7 以前的 AtomicLong 進(jìn)行的優(yōu)化,解決的是 CAS 類操作在高并發(fā)場景下,使用樂觀鎖思路,會導(dǎo)致大量線程長時間重復(fù)循環(huán)。

LongAdder 中也是采用了類似的分段 CAS 操作,失敗則自動遷移到下一個分段進(jìn)行 CAS 的思路。

其實分布式鎖的優(yōu)化思路也是類似的,之前我們是在另外一個業(yè)務(wù)場景下落地了這個方案到生產(chǎn)中,不是在庫存超賣問題里用的。

但是庫存超賣這個業(yè)務(wù)場景不錯,很容易理解,所以我們就用這個場景來說一下。

大家看看下面的圖:

這就是分段加鎖。假如你現(xiàn)在 iPhone 有 1000 個庫存,那么你完全可以給拆成 20 個庫存段。

要是你愿意,可以在數(shù)據(jù)庫的表里建 20 個庫存字段,比如 stock_01,stock_02,類似這樣的,也可以在 Redis 之類的地方放 20 個庫存 Key。

總之,就是把你的 1000 件庫存給他拆開,每個庫存段是 50 件庫存,比如 stock_01 對應(yīng) 50 件庫存,stock_02 對應(yīng) 50 件庫存。

接著,每秒 1000 個請求過來了,好!此時其實可以是自己寫一個簡單的隨機(jī)算法,每個請求都是隨機(jī)在 20 個分段庫存里,選擇一個進(jìn)行加鎖。

Bingo!這樣就好了,同時可以有最多 20 個下單請求一起執(zhí)行,每個下單請求鎖了一個庫存分段,然后在業(yè)務(wù)邏輯里面,就對數(shù)據(jù)庫或者是 Redis 中的那個分段庫存進(jìn)行操作即可,包括查庫存→判斷庫存是否充足→扣減庫存。

這相當(dāng)于什么呢?相當(dāng)于一個 20 毫秒,可以并發(fā)處理掉 20 個下單請求,那么 1 秒,也就可以依次處理掉 20 * 50 = 1000 個對 iPhone 的下單請求了。

一旦對某個數(shù)據(jù)做了分段處理之后,有一個坑大家一定要注意:就是如果某個下單請求,咔嚓加鎖,然后發(fā)現(xiàn)這個分段庫存里的庫存不足了,此時咋辦?

這時你得自動釋放鎖,然后立馬換下一個分段庫存,再次嘗試加鎖后嘗試處理。這個過程一定要實現(xiàn)。

分布式鎖并發(fā)優(yōu)化方案有什么不足?

不足肯定是有的,***的不足,很不方便,實現(xiàn)太復(fù)雜了:

  • 首先,你得對一個數(shù)據(jù)分段存儲,一個庫存字段本來好好的,現(xiàn)在要分為 20 個庫存字段。
  • 其次,你在每次處理庫存的時候,還得自己寫隨機(jī)算法,隨機(jī)挑選一個分段來處理。
  • ***,如果某個分段中的數(shù)據(jù)不足了,你還得自動切換到下一個分段數(shù)據(jù)去處理。

這個過程都是要手動寫代碼實現(xiàn)的,還是有點工作量,挺麻煩的。

不過我們確實在一些業(yè)務(wù)場景里,因為用到了分布式鎖,然后又必須要進(jìn)行鎖并發(fā)的優(yōu)化,又進(jìn)一步用到了分段加鎖的技術(shù)方案,效果當(dāng)然是很好的了,一下子并發(fā)性能可以增長幾十倍。

該優(yōu)化方案的后續(xù)改進(jìn):以我們本文所說的庫存超賣場景為例,你要是這么玩,會把自己搞的很痛苦!再次強(qiáng)調(diào),我們這里的庫存超賣場景,僅僅只是作為演示場景而已。

作者:中華石杉

中華石杉:十余年 BAT 架構(gòu)經(jīng)驗,一線互聯(lián)網(wǎng)公司技術(shù)總監(jiān)。帶領(lǐng)上百人團(tuán)隊開發(fā)過多個億級流量高并發(fā)系統(tǒng)。現(xiàn)將多年工作中積累下的研究手稿、經(jīng)驗總結(jié)整理成文,傾囊相授。微信公眾號:石杉的架構(gòu)筆記(ID:shishan100)。

 

責(zé)任編輯:武曉燕 來源: 石杉的架構(gòu)筆記
相關(guān)推薦

2018-08-07 16:01:32

synchronizevolatilefinal

2022-09-26 10:09:08

MVCC控制并發(fā)

2020-12-11 08:23:06

JavaMemory Mode內(nèi)存模型

2018-07-03 14:54:25

Java內(nèi)存模型

2021-05-31 09:42:48

MySQL隔離級別

2022-11-08 09:33:36

訂單系統(tǒng)電商

2021-02-22 13:32:19

MySQLSQL索引

2022-05-23 09:41:27

分庫分表數(shù)據(jù)庫算法

2019-11-05 14:06:07

MySQLB+索引

2019-11-04 15:00:50

MySQL索引B+樹

2022-10-21 16:39:56

JDK優(yōu)化

2021-03-08 12:47:42

MySQL查詢數(shù)據(jù)

2021-03-08 10:25:37

MySQL數(shù)據(jù)庫索引

2019-12-10 09:08:29

分布式開源RocketMQ

2023-12-11 08:32:58

數(shù)據(jù)庫DruidDBA

2020-04-20 13:11:21

HashMap底層存儲

2020-04-28 09:15:58

HashMapJava數(shù)組

2019-09-19 14:03:32

B樹節(jié)點數(shù)據(jù)結(jié)構(gòu)

2018-10-12 09:42:00

分布式鎖 Java多線

2020-12-21 14:58:25

分布式性能系統(tǒng)
點贊
收藏

51CTO技術(shù)棧公眾號

主站蜘蛛池模板: 免费视频中文字幕 | 欧美精品乱码久久久久久按摩 | 日本亚洲精品成人欧美一区 | 国产露脸国语对白在线 | 中文字幕国产在线 | 成人免费网站 | 国产精品久久久久久亚洲调教 | 欧美激情在线精品一区二区三区 | 欧美aaaaaaaaaa | 中文字幕一区二区三区四区 | 精品视频一区二区 | 欧美综合一区二区 | 精品国产乱码久久久久久88av | 欧美精品二区 | 成人精品鲁一区一区二区 | 在线欧美亚洲 | 国产在线www | 97av在线| 久久久一区二区 | 91久久国产综合久久 | 中文字幕在线网 | 欧美激情一区二区三级高清视频 | 在线91| 91久久精品一区二区二区 | 久久久精品 | 国产精品一区一区 | 国产aⅴ | 天天射夜夜操 | 欧美久久久久久久久 | 欧美日韩精品在线免费观看 | 视频一区二区三区四区五区 | 韩日在线观看视频 | 久久伊人操| www.久草| 亚洲伊人a| 蜜桃视频一区二区三区 | 国产亚韩 | 秋霞国产 | 国产日韩欧美在线观看 | 九色在线| www.国产精|