[發明專利]一種基于分片集群擴容的數據平衡方法與設備

在審

• 申請號: 202210146908.8
• 申請日: 2022-02-17
• 公開（公告）號: CN114338692A
• 公開（公告）日: 2022-04-12
• 發明（設計）人: 李峰;張凌嫣;李廣斌
• 申請（專利權）人: 上海玄翎科技有限公司
• 主分類號: H04L67/1008
• 分類號: H04L67/1008;H04L67/1097;H04L67/563;H04L41/0896
• 代理公司: 上海百一領御專利代理事務所(普通合伙) 31243
• 代理人: 王路豐

1.一種基于分片集群擴容的數據平衡方法，其中，所述方法包括：

當接收外部應用發送的外部請求的節點為擴容后產生的第一節點且所述第一節點未保存所述外部請求對應數據時，所述第一節點向分片集群的全部其他節點發送請求信息；

保存有所述外部請求對應數據的第二節點響應所述請求信息，以使所述第一節點及外部應用獲取遷移數據及所述外部請求對應數據，其中，所述遷移數據包括用于實現各個節點間數據平衡的數據；

所述第一節點獲取并保存所述遷移數據后，向所述第二節點發送遷移完成信息，使所述第二節點刪除所述遷移數據。

2.根據權利要求1所述的方法，所述方法還包括在所述分片集群中建立發布訂閱模式的頻道，其中，所述第一節點向分片集群的全部其他節點發送請求信息包括：

所述第一節點向頻道中發送請求信息；

分片集群的全部其他節點作為該頻道的訂閱者，通過該頻道接收所述第一節點發送的請求信息。

3.根據權利要求2所述的方法，其中，所述在所述分片集群中建立發布訂閱模式的頻道包括：

利用Libp2p協議在P2P網絡中建立所述發布訂閱模式的頻道。

4.根據權利要求1至3中任一項所述的方法，其中，所述請求信息包括外部請求對應數據的鍵值及所述第一節點的ID，所述保存有所述外部請求對應數據的第二節點響應所述請求信息，以使所述第一節點及外部應用獲取遷移數據及所述外部請求對應數據包括：

所述第二節點根據所述鍵值在本地查找到所述外部請求對應數據后，按照數據分布算法確定遷移數據；

所述第二節點根據所述第一節點的ID向所述第一節點發送所述第二節點的ID，以使所述第一節點拉取外部請求對應數據及遷移數據；

所述第一節點將拉取到的外部請求對應數據轉發給外部應用。

5.根據權利要求1至3中任一項所述的方法，其中，所述請求信息包括外部請求對應數據的鍵值及所述第一節點的ID，所述保存有所述外部請求對應數據的第二節點響應所述請求信息，以使所述第一節點及外部應用獲取遷移數據及所述外部請求對應數據包括：

所述第二節點根據所述鍵值在本地查找到所述外部請求對應數據后，按照數據分布算法確定遷移數據；

所述第二節點根據所述第一節點的ID向所述第一節點推送所述外部請求對應數據及遷移數據；

所述第一節點將接收到的外部請求對應數據轉發給外部應用。

6.根據權利要求1至3中任一項所述的方法，其中，所述請求信息包括外部請求對應數據的鍵值、所述第一節點的ID及外部應用信息，其中，所述保存有所述外部請求對應數據的第二節點響應所述請求信息，以使所述第一節點及外部應用獲取遷移數據及所述外部請求對應數據包括：

所述第二節點根據所述鍵值在本地查找到所述外部請求對應數據后，按照數據分布算法確定遷移數據；

所述第二節點根據所述外部應用信息向外部應用直接發送所述外部請求對應數據，并根據所述第一節點的ID向所述第一節點推送所述遷移數據。

7.一種計算機可讀介質，其上存儲有計算機可讀指令，所述計算機可讀指令可被處理器執行以實現如權利要求1至6中任一項所述的方法。

8.一種基于分片集群擴容的數據平衡設備，其中，該設備包括：

一個或多個處理器；以及

存儲有計算機可讀指令的存儲器，所述計算機可讀指令在被執行時使所述處理器執行如權利要求1至6中任一項所述方法的操作。