[發(fā)明專利]一種鎖資源遷移方法、節(jié)點(diǎn)及分布式系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 201410677166.7
• 申請(qǐng)日: 2014-11-21
• 公開(kāi)（公告）號(hào): CN104486373A
• 公開(kāi)（公告）日: 2015-04-01
• 發(fā)明（設(shè)計(jì)）人: 王勛;范超;陳光
• 申請(qǐng)（專利權(quán)）人: 華為技術(shù)有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L12/18
• 代理公司: 北京同達(dá)信恒知識(shí)產(chǎn)權(quán)代理有限公司 11291
• 代理人: 馮艷蓮

技術(shù)領(lǐng)域

本發(fā)明涉及電子技術(shù)領(lǐng)域，尤其涉及一種鎖資源遷移方法、節(jié)點(diǎn)及分布式系統(tǒng)。

背景技術(shù)

分布式系統(tǒng)中有多個(gè)節(jié)點(diǎn)，當(dāng)多個(gè)節(jié)點(diǎn)中有至少兩個(gè)節(jié)點(diǎn)同時(shí)對(duì)同一文件分別進(jìn)行寫(xiě)操作，或者同時(shí)對(duì)同一文件分別進(jìn)行寫(xiě)操作和讀操作，就會(huì)產(chǎn)生沖突。例如：A節(jié)點(diǎn)對(duì)一個(gè)文件進(jìn)行寫(xiě)操作時(shí)，B節(jié)點(diǎn)也對(duì)相同的文件進(jìn)行寫(xiě)操作，那么文件操作就會(huì)產(chǎn)生沖突。又例如：A節(jié)點(diǎn)對(duì)一個(gè)文件進(jìn)行寫(xiě)操作時(shí)，B節(jié)點(diǎn)也對(duì)相同的文件進(jìn)行讀操作，文件操作也會(huì)產(chǎn)生沖突。還例如：A節(jié)點(diǎn)對(duì)一個(gè)文件的[0,100]區(qū)間進(jìn)行讀操作，節(jié)點(diǎn)B也對(duì)相同文件的[50，100]區(qū)間進(jìn)行寫(xiě)操作，文件操作也會(huì)產(chǎn)生沖突。由于一個(gè)文件有多個(gè)區(qū)間，所以不同節(jié)點(diǎn)對(duì)同一文件的兩個(gè)區(qū)間分別進(jìn)行讀操作和寫(xiě)操作，且兩個(gè)區(qū)間有重疊部分時(shí)，文件操作就會(huì)產(chǎn)生大量的沖突。

為了避免分布式系統(tǒng)中的各個(gè)節(jié)點(diǎn)在操作文件時(shí)產(chǎn)生沖突，一般會(huì)在各個(gè)節(jié)點(diǎn)上都存儲(chǔ)有一個(gè)文件或者多個(gè)文件的鎖資源，用于記錄一個(gè)或者多個(gè)文件中的每一文件被哪些節(jié)點(diǎn)加鎖以及鎖的權(quán)限是讀權(quán)限還是寫(xiě)權(quán)限。節(jié)點(diǎn)在對(duì)文件進(jìn)行讀操作或者寫(xiě)操作之前，需要向存儲(chǔ)有該文件的鎖資源的節(jié)點(diǎn)發(fā)送加鎖請(qǐng)求，請(qǐng)求對(duì)該文件進(jìn)行加鎖，以獲取讀權(quán)限或者寫(xiě)權(quán)限，然后再對(duì)該文件進(jìn)行讀操作或者寫(xiě)操作，以保證文件操作不會(huì)產(chǎn)生沖突。

現(xiàn)有技術(shù)中，當(dāng)分布式系統(tǒng)中有節(jié)點(diǎn)上線或者下線時(shí)，為實(shí)現(xiàn)鎖資源在分布式系統(tǒng)中均衡分布，需要將其他節(jié)點(diǎn)上的鎖資源遷移到上線節(jié)點(diǎn)，或者需要將下線節(jié)點(diǎn)上的鎖資源遷移到其他節(jié)點(diǎn)。具體的遷移方法為：首先遷移源節(jié)點(diǎn)將需要遷移的鎖資源的狀態(tài)設(shè)置為停止服務(wù)狀態(tài)，然后遷移源節(jié)點(diǎn)將需要遷移的鎖資源整體遷移到遷移目的節(jié)點(diǎn)上，最后遷移目的節(jié)點(diǎn)將已遷移過(guò)來(lái)的鎖資源的狀態(tài)設(shè)置為服務(wù)狀態(tài)。

由于需要遷移的鎖資源量大，所以在較長(zhǎng)一段時(shí)間內(nèi)，其他節(jié)點(diǎn)都無(wú)法使用遷移鎖資源的鎖服務(wù)，對(duì)分布式系統(tǒng)的運(yùn)行效率影響較大。

因此，現(xiàn)有技術(shù)存在的技術(shù)問(wèn)題是：遷移鎖資源對(duì)分布式系統(tǒng)的運(yùn)行效率影響較大。

發(fā)明內(nèi)容

本發(fā)明實(shí)施例提供一種鎖資源遷移方法、節(jié)點(diǎn)及分布式系統(tǒng)，用于解決現(xiàn)有技術(shù)中存在的遷移鎖資源對(duì)分布式系統(tǒng)的運(yùn)行效率影響較大的技術(shù)問(wèn)題，實(shí)現(xiàn)了減小遷移鎖資源對(duì)分布式系統(tǒng)的運(yùn)行效率的影響的技術(shù)效果。

本發(fā)明實(shí)施例第一方面提供了一種鎖資源遷移方法，所述方法包括：

遷移源節(jié)點(diǎn)接收通知消息，所述通知消息用于通知分布式系統(tǒng)中有節(jié)點(diǎn)上線或者離線；

所述遷移源節(jié)點(diǎn)將鎖資源的全量遷移數(shù)據(jù)發(fā)送給遷移目的節(jié)點(diǎn)，所述全量遷移數(shù)據(jù)為所述遷移源節(jié)點(diǎn)自開(kāi)始提供鎖服務(wù)的時(shí)刻起至接收到所述通知消息的時(shí)刻所述遷移源節(jié)點(diǎn)中的鎖資源數(shù)據(jù)；

所述遷移源節(jié)點(diǎn)在所述遷移目的節(jié)點(diǎn)接收所述全量遷移數(shù)據(jù)之后，設(shè)置所述鎖資源的狀態(tài)為停止服務(wù)狀態(tài)；

所述遷移源節(jié)點(diǎn)將增量遷移數(shù)據(jù)發(fā)送給所述遷移目的節(jié)點(diǎn)，所述增量遷移數(shù)據(jù)為所述遷移源節(jié)點(diǎn)自接收到所述通知消息的時(shí)刻起至設(shè)置所述鎖資源的狀態(tài)為停止服務(wù)狀態(tài)的時(shí)刻所述遷移源節(jié)點(diǎn)中的鎖資源數(shù)據(jù)。

結(jié)合第一方面，在第一種可能的實(shí)現(xiàn)方式中，在所述遷移源節(jié)點(diǎn)將增量遷移數(shù)據(jù)發(fā)送給所述遷移目的節(jié)點(diǎn)之后，所述方法還包括：

所述遷移源節(jié)點(diǎn)在接收到所述遷移目的節(jié)點(diǎn)發(fā)送的遷移完成廣播信息后，更新目錄信息，所述目錄信息記錄所有鎖資源在所述分布式系統(tǒng)中的分布情況。

結(jié)合第一種可能的實(shí)現(xiàn)方式，在第二種可能的實(shí)現(xiàn)方式中，在所述遷移源節(jié)點(diǎn)在接收到所述遷移目的節(jié)點(diǎn)發(fā)送的遷移完成廣播信息后，所述方法還包括：

所述遷移源節(jié)點(diǎn)刪除所述全量遷移數(shù)據(jù)及所述增量遷移數(shù)據(jù)。

本發(fā)明實(shí)施例第二方面提供了一種鎖資源遷移方法，所述方法包括：

遷移目的節(jié)點(diǎn)接收遷移源節(jié)點(diǎn)發(fā)送的鎖資源的全量遷移數(shù)據(jù)，所述全量遷移數(shù)據(jù)為所述遷移源節(jié)點(diǎn)自開(kāi)始提供鎖服務(wù)的時(shí)刻起至接收到通知消息的時(shí)刻所述遷移源節(jié)點(diǎn)中的鎖資源數(shù)據(jù)，所述通知消息用于通知分布式系統(tǒng)中有節(jié)點(diǎn)上線或者離線；

所述遷移目的節(jié)點(diǎn)接收所述遷移源節(jié)點(diǎn)發(fā)送的增量遷移數(shù)據(jù)，所述增量遷移數(shù)據(jù)為所述遷移源節(jié)點(diǎn)自接收到所述通知消息的時(shí)刻起至所述鎖資源的狀態(tài)為停止服務(wù)狀態(tài)的時(shí)刻所述遷移源節(jié)點(diǎn)中的鎖資源數(shù)據(jù)；

所述遷移目的節(jié)點(diǎn)在接收所述增量遷移數(shù)據(jù)之后，設(shè)置所述鎖資源的狀態(tài)為服務(wù)狀態(tài)。

結(jié)合第二方面，在第一種可能的實(shí)現(xiàn)方式中，在所述遷移目的節(jié)點(diǎn)設(shè)置所述鎖資源的狀態(tài)為服務(wù)狀態(tài)之后，所述方法還包括：

所述遷移目的節(jié)點(diǎn)向所述分布式系統(tǒng)中的所有節(jié)點(diǎn)發(fā)送遷移完成廣播信息。