[發(fā)明專利]時序時空數(shù)據(jù)庫系統(tǒng)的分布式架構(gòu)的構(gòu)建方法、裝置

在審

• 申請?zhí)枺?/td>: 202011566367.1
• 申請日: 2020-12-25
• 公開（公告）號: CN112559498A
• 公開（公告）日: 2021-03-26
• 發(fā)明（設(shè)計）人: 張韋亮;沈達(dá)宇
• 申請（專利權(quán)）人: 北京百度網(wǎng)訊科技有限公司
• 主分類號: G06F16/21
• 分類號: G06F16/21;G06F16/27
• 代理公司: 北京市漢坤律師事務(wù)所 11602
• 代理人: 姜浩然;吳麗麗

1.一種時序時空數(shù)據(jù)庫系統(tǒng)的分布式架構(gòu)的構(gòu)建方法，其中，所述方法包括：

將多個客戶端連接到分布式鍵值數(shù)據(jù)庫，并且，為所述多個客戶端中的至少兩個客戶端分別創(chuàng)建對應(yīng)的鍵，并且在所述分布式鍵值數(shù)據(jù)庫中保存所述鍵；

響應(yīng)于所述時序時空數(shù)據(jù)庫系統(tǒng)處于無主狀態(tài)，確定所述鍵中滿足第一預(yù)設(shè)條件的鍵為第一鍵，并且，為與所述第一鍵所對應(yīng)的第一客戶端分配鎖，使得所述時序時空數(shù)據(jù)庫系統(tǒng)進(jìn)入有主狀態(tài)；

響應(yīng)于所述時序時空數(shù)據(jù)庫系統(tǒng)處于所述有主狀態(tài)，以及所述第一客戶端不滿足第二預(yù)設(shè)條件，由所述第一客戶端執(zhí)行接收到的業(yè)務(wù)代碼；以及

從所述分布式鍵值數(shù)據(jù)庫中刪除所述第一客戶端對應(yīng)的所述第一鍵，使得所述時序時空數(shù)據(jù)庫系統(tǒng)進(jìn)入無主狀態(tài)。

2.根據(jù)權(quán)利要求1所述的方法，其中，在所述分布式鍵值數(shù)據(jù)庫中保存的所述鍵中的每一個鍵分別具有對應(yīng)的版本值；并且其中，所述鍵中的對應(yīng)的所述版本值最小的鍵，滿足第一預(yù)設(shè)條件。

3.根據(jù)權(quán)利要求2所述的方法，其中，所述版本值的初始值基于所述鍵在所述分布式鍵值數(shù)據(jù)庫中保存的先后順序確定。

4.根據(jù)權(quán)利要求3所述的方法，其中，每執(zhí)行一次所述接收到的業(yè)務(wù)代碼，所述版本值均相應(yīng)增加1。

5.根據(jù)權(quán)利要求1所述的方法，其中，所述鍵中的每一個鍵分別具有對應(yīng)的生存時間；并且其中，響應(yīng)于所述第一鍵或其對應(yīng)的所述版本值發(fā)生變化，向所述時序時空數(shù)據(jù)庫系統(tǒng)發(fā)送通知，若從上一次發(fā)送所述通知起計算，在所述生存時間內(nèi)沒有向所述時序時空數(shù)據(jù)庫系統(tǒng)發(fā)送新的通知，則所述第一客戶端滿足所述第二預(yù)設(shè)條件。

6.根據(jù)權(quán)利要求5所述的方法，其中，響應(yīng)于所述第一鍵或其對應(yīng)的所述版本值發(fā)生變化，向所述時序時空數(shù)據(jù)庫系統(tǒng)發(fā)送通知，包括：

利用所述分布式鍵值數(shù)據(jù)庫的監(jiān)聽機制監(jiān)聽所述分布式鍵值數(shù)據(jù)庫中的第一鍵，響應(yīng)于所述第一鍵或其對應(yīng)的所述版本值發(fā)生變化，向所述時序時空數(shù)據(jù)庫系統(tǒng)發(fā)送通知。

7.根據(jù)權(quán)利要求1所述的方法，其中，所述第一客戶端的參數(shù)中的至少一個參數(shù)超過相應(yīng)的預(yù)設(shè)閾值時，所述第一客戶端滿足第二預(yù)設(shè)條件。

8.根據(jù)權(quán)利要求7所述的方法，其中，所述參數(shù)包括：

內(nèi)存占用、網(wǎng)絡(luò)占用、磁盤讀寫以及CPU消耗中的一個或多個。

9.根據(jù)權(quán)利要求1所述的方法，其中，未獲得所述鎖的所述客戶端包括故障客戶端和候選客戶端，其中，所述故障客戶端為未獲得所述鎖的所述客戶端中發(fā)生故障的一個或多個客戶端，

其中，由所述第一客戶端執(zhí)行接收到的業(yè)務(wù)代碼包括：

響應(yīng)于接收到故障通知，將所述故障客戶端的數(shù)據(jù)備份至所述候選客戶端中的一個。

10.根據(jù)權(quán)利要求1所述的方法，其中，由所述第一客戶端執(zhí)行接收到的業(yè)務(wù)代碼包括：

響應(yīng)于接收到寫入請求，在所述第一客戶端執(zhí)行寫入操作。

11.根據(jù)權(quán)利要求1所述的方法，其中，在所述分布式鍵值數(shù)據(jù)庫中保存的所述鍵具有固定的前綴和不同的后綴。

12.根據(jù)權(quán)利要求11所述的方法，其中，在所述分布式鍵值數(shù)據(jù)庫中保存的所述鍵中的每一個鍵的后綴和與其相鄰的上一個鍵的值的后綴之間按照預(yù)設(shè)間隔值遞增。

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

獲取查詢請求；

輸出同步信號；

基于所述查詢請求與所述滿足第三預(yù)設(shè)條件的同步信號，將所述第一客戶端的數(shù)據(jù)同步至未獲得所述鎖的所述客戶端。