[發(fā)明專利]可重入分布式鎖的實(shí)現(xiàn)方法、裝置、電子設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110735810.1
• 申請(qǐng)日: 2021-06-30
• 公開(kāi)（公告）號(hào): CN113535416A
• 公開(kāi)（公告）日: 2021-10-22
• 發(fā)明（設(shè)計(jì)）人: 張藝?yán)?/a>
• 申請(qǐng)（專利權(quán)）人: 北京百度網(wǎng)訊科技有限公司
• 主分類(lèi)號(hào): G06F9/52
• 分類(lèi)號(hào): G06F9/52;G06F9/54;G06F16/23;G06F16/22;G06F16/25
• 代理公司: 北京柏杉松知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11413
• 代理人: 馬敬;高鶯然

1.一種可重入分布式鎖的實(shí)現(xiàn)方法，應(yīng)用于基于spring框架構(gòu)建的分布式系統(tǒng)中的服務(wù)器，所述分布式系統(tǒng)還包括Mysql數(shù)據(jù)庫(kù)和分布于多個(gè)區(qū)域的多個(gè)主機(jī)的客戶端，所述方法包括：

獲取客戶端發(fā)送的加鎖請(qǐng)求，所述加鎖請(qǐng)求中包含第一區(qū)域標(biāo)識(shí)、第一上鎖鍵值、目標(biāo)主機(jī)標(biāo)識(shí)和加鎖持續(xù)時(shí)間；

查詢所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中是否存在包含所述第一區(qū)域標(biāo)識(shí)和所述第一上鎖鍵值的未過(guò)期表項(xiàng)；

若存在，判斷所述未過(guò)期表項(xiàng)包含的主機(jī)標(biāo)識(shí)是否與所述目標(biāo)主機(jī)標(biāo)識(shí)一致，若是，則基于所述加鎖持續(xù)時(shí)間更新所述未過(guò)期表項(xiàng)的過(guò)期時(shí)間，并通知所述客戶端加鎖成功。

2.根據(jù)權(quán)利要求1所述的方法，還包括：

若所述未過(guò)期表項(xiàng)包含的主機(jī)標(biāo)識(shí)與所述目標(biāo)主機(jī)標(biāo)識(shí)不一致，則通知所述客戶端加鎖失敗。

3.根據(jù)權(quán)利要求1所述的方法，還包括：

若所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中不存在包含所述第一區(qū)域標(biāo)識(shí)和所述第一上鎖鍵值的未過(guò)期表項(xiàng)，向所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中添加包含所述第一區(qū)域標(biāo)識(shí)、第一上鎖鍵值、目標(biāo)主機(jī)標(biāo)識(shí)和加鎖持續(xù)時(shí)間的表項(xiàng)；若成功添加該表項(xiàng)，則通知所述客戶端加鎖成功；若未成功添加該表項(xiàng)，則通知所述客戶端加鎖失敗。

4.根據(jù)權(quán)利要求1所述的方法，還包括：

獲取客戶端發(fā)送的解鎖請(qǐng)求，所述解鎖請(qǐng)求中包含第二區(qū)域標(biāo)識(shí)和第二上鎖鍵值；

查詢所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中包含所述第二區(qū)域標(biāo)識(shí)和所述第二上鎖鍵值的表項(xiàng)，刪除該表項(xiàng)。

5.根據(jù)權(quán)利要求1所述的方法，還包括：

當(dāng)達(dá)到定時(shí)時(shí)刻，查詢所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中過(guò)期時(shí)間小于所述定時(shí)時(shí)刻的表項(xiàng)并刪除；其中，所述定時(shí)時(shí)刻是基于預(yù)先設(shè)置的定時(shí)清理任務(wù)確定的。

6.一種可重入分布式鎖的實(shí)現(xiàn)裝置，應(yīng)用于基于spring框架構(gòu)建的分布式系統(tǒng)中的服務(wù)器，所述分布式系統(tǒng)還包括Mysql數(shù)據(jù)庫(kù)和分布于多個(gè)區(qū)域的多個(gè)主機(jī)的客戶端，所述裝置包括：

第一獲取模塊，用于獲取客戶端發(fā)送的加鎖請(qǐng)求，所述加鎖請(qǐng)求中包含第一區(qū)域標(biāo)識(shí)、第一上鎖鍵值、目標(biāo)主機(jī)標(biāo)識(shí)和加鎖持續(xù)時(shí)間；

第一查詢模塊，用于查詢所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中是否存在包含所述第一區(qū)域標(biāo)識(shí)和所述第一上鎖鍵值的未過(guò)期表項(xiàng)；若存在，觸發(fā)判斷模塊；

所述判斷模塊，用于判斷所述未過(guò)期表項(xiàng)包含的主機(jī)標(biāo)識(shí)是否與所述目標(biāo)主機(jī)標(biāo)識(shí)一致，若是，觸發(fā)加鎖模塊；

所述加鎖模塊，用于基于所述加鎖持續(xù)時(shí)間更新所述未過(guò)期表項(xiàng)的過(guò)期時(shí)間，并通知所述客戶端加鎖成功。

7.根據(jù)權(quán)利要求6所述的裝置，若所述判斷模塊的判斷結(jié)果為否，觸發(fā)加鎖失敗模塊；

所述加鎖失敗模塊，用于通知所述客戶端加鎖失敗。

8.根據(jù)權(quán)利要求6所述的裝置，若所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中不存在包含所述第一區(qū)域標(biāo)識(shí)和所述第一上鎖鍵值的未過(guò)期表項(xiàng)，觸發(fā)添加模塊；

所述添加模塊，用于向所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中添加包含所述第一區(qū)域標(biāo)識(shí)、第一上鎖鍵值、目標(biāo)主機(jī)標(biāo)識(shí)和加鎖持續(xù)時(shí)間的表項(xiàng)；若成功添加該表項(xiàng)，則通知所述客戶端加鎖成功；若未成功添加該表項(xiàng)，則通知所述客戶端加鎖失敗。

9.根據(jù)權(quán)利要求6所述的裝置，還包括：

第二獲取模塊，用于獲取客戶端發(fā)送的解鎖請(qǐng)求，所述解鎖請(qǐng)求中包含第二區(qū)域標(biāo)識(shí)和第二上鎖鍵值；

第二查詢模塊，用于查詢所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中包含所述第二區(qū)域標(biāo)識(shí)和所述第二上鎖鍵值的表項(xiàng)，刪除該表項(xiàng)。

10.根據(jù)權(quán)利要求6所述的裝置，還包括：

定時(shí)清理模塊，用于當(dāng)達(dá)到定時(shí)時(shí)刻，查詢所述Mysql數(shù)據(jù)庫(kù)的分布式鎖表中過(guò)期時(shí)間小于所述定時(shí)時(shí)刻的表項(xiàng)并刪除；其中，所述定時(shí)時(shí)刻是基于預(yù)先設(shè)置的定時(shí)清理任務(wù)確定的。