[發明專利]一種分布式數據存儲的方法、裝置、服務器及介質

在審

• 申請號: 202210867106.6
• 申請日: 2022-07-22
• 公開（公告）號: CN115114376A
• 公開（公告）日: 2022-09-27
• 發明（設計）人: 孫偉源
• 申請（專利權）人: 濟南浪潮數據技術有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/242;G06F16/25
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 薛嬌

1.一種分布式數據存儲的方法，其特征在于，包括：

獲取上層應用的SQL請求；

通過HA Agent發送所述SQL請求至HA Manager；其中，所述HA Manager與所述HA Agent通過Zookeeper提供統一的訪問接口；

通過所述HA Manager接收并處理所述SQL請求；

通過數據庫響應處理后的所述SQL請求。

2.根據權利要求1所述的分布式數據存儲的方法，其特征在于，在所述通過HA Agent發送上層應用的SQL請求至HA Manager之前，還包括：

通過所述HA Agent按照固定頻率從所述Zookeeper中獲取各所述HA Manager節點的狀態信息；

在各所述HA Manager節點的負載滿足第一預設要求或所述HA Manager節點未出現故障的情況下，則進入所述通過HA Agent發送上層應用的SQL請求至HA Manager的步驟；

反之，則進入所述獲取上層應用的SQL請求的步驟。

3.根據權利要求1或2所述的分布式數據存儲的方法，其特征在于，所述HA Manager接收并處理所述SQL請求包括：

接收所述SQL請求并對所述SQL請求進行解析；

獲取解析后的所述SQL請求的類型；

根據所述SQL請求的類型處理所述SQL請求。

4.根據權利要求3所述的分布式數據存儲的方法，其特征在于，所述根據所述SQL請求的類型處理所述SQL請求包括：

在所述SQL請求為寫操作的情況下，獲取所述寫操作的相關參數；其中，所述寫操作的相關參數至少包括本地節點ID、事務ID、事務類型、寫操作類型的標識、數據操作對象；

將所述寫操作的相關參數以及所述SQL請求組合成新的消息；

將所述新的消息置于消息總線spread上；

通過所述消息總線spread轉發并接收各所述HA Manager節點的信息；

對各所述HA Manager節點的信息全局排序并解析出所述SQL請求；

執行所述SQL請求；

在所述SQL請求為只讀操作的情況下，執行所述SQL請求。

5.根據權利要求4所述的分布式數據存儲的方法，其特征在于，在所述接收所述SQL請求之后，所述對所述SQL請求進行解析之前，所述方法還包括：

對所述SQL請求進行校驗并獲取校驗結果；

在所述校驗結果滿足第二預設要求的情況下，進入所述對所述SQL請求進行解析的步驟。

6.根據權利要求4所述的分布式數據存儲的方法，其特征在于，在所述接收所述SQL請求之后，所述對所述SQL請求進行解析之前，所述方法還包括：

獲取所述SQL請求的相關參數；其中，所述SQL請求的相關參數至少包括所述SQL請求的請求來源、請求時間、請求參數；

將所述SQL請求的相關參數記錄至日志中；

對應地，在所述執行所述SQL請求之前，所述方法還包括：

更新所述日志。

7.根據權利要求6所述的分布式數據存儲的方法，其特征在于，所述方法還包括：

獲取更新后的所述日志的信息；

根據所述日志的信息分析新加入的所述HA Manager節點的信息或待恢復的所述HAManager節點的信息與正常的所述HA Manager節點的信息的差異；

根據差異程度同步各所述HA Manager節點的信息。

8.一種分布式數據存儲的裝置，其特征在于，包括：

獲取模塊，用于獲取上層應用的SQL請求；

發送模塊，用于通過HA Agent發送所述SQL請求至HA Manager；其中，所述HA Manager與所述HA Agent通過Zookeeper提供統一的訪問接口；

接收及處理模塊，用于通過所述HA Manager接收并處理所述SQL請求；

響應模塊，用于通過數據庫響應處理后的所述SQL請求。