[發明專利]分布式主從系統中主節點的切換方法、裝置和計算機設備

有效

• 申請號: 201911183863.6
• 申請日: 2019-11-27
• 公開（公告）號: CN112865992B
• 公開（公告）日: 2022-10-14
• 發明（設計）人: 韓志華
• 申請（專利權）人: 上海嗶哩嗶哩科技有限公司
• 主分類號: H04L41/0663
• 分類號: H04L41/0663
• 代理公司: 北京英特普羅知識產權代理有限公司 11015
• 代理人: 程超

1.一種分布式主從系統中主節點的切換方法，其特征在于，所述分布式主從系統包括多個從節點和多個主節點，所述主節點的狀態包括工作狀態、休息狀態和選舉狀態，其中，處于所述工作狀態的主節點每間隔預設時長向處于所述休息狀態的主節點發送心跳信息，所述切換方法包括：

當監測到所述心跳信息超時時，由所述休息狀態進入所述選舉狀態，并發送選舉請求，其中，接收到所述選舉請求的主節點用于返回選舉投票；

當接收到的所述選舉投票的數量大于第一閾值時，由所述選舉狀態進入所述工作狀態；

接收客戶端發送的任務請求；

建立所述任務請求對應的任務條目，其中，所述任務條目包括任務標識和任務狀態；

將所述任務條目寫入本地日志；

將所述本地日志中未完成的所述任務條目對應的任務分配至所述從節點，并根據所述從節點返回的執行進度更新對應的所述任務狀態；

當所述本地日志被修改時，將修改信息攜帶至所述心跳信息，其中，接收到所述修改信息的所述主節點用于根據所述修改信息修改自身的日志。

2.根據權利要求1所述的分布式主從系統中主節點的切換方法，其特征在于，在由所述休息狀態進入所述選舉狀態之后，發送選舉請求之前，所述切換方法還包括：

將所述本地日志中最新的所述任務條目中的任務標識作為檢測標識攜帶至所述選舉請求；

其中，接收到所述選舉請求的主節點還用于比對所述檢測標識和自身日志中的任務標識，并當自身日志中不包括所述檢測標識，或者自身日志中最新的所述任務條目中的任務標識與所述檢測標識相同，返回所述選舉投票。

3.根據權利要求1所述的分布式主從系統中主節點的切換方法，其特征在于，各所述主節點分別維護自身的周期序號，所述切換方法還包括：

在由所述休息狀態進入所述選舉狀態之后，發送選舉請求之前，將自身的周期序號更新，并將更新后的所述周期序號作為檢測序號攜帶至所述選舉請求，其中，接收到所述選舉請求的主節點用于比對所述檢測序號和自身的周期序號，并當自身的周期序號不新于所述檢測序號時，返回所述選舉投票；以及

在由所述選舉狀態進入所述工作狀態后，將被選舉信息攜帶至所述心跳信息，其中，接收到所述被選舉信息的主節點將自身的周期序號更新。

4.根據權利要求3所述的分布式主從系統中主節點的切換方法，其特征在于，所述主節點的狀態還包括預選舉狀態，由所述休息狀態進入所述選舉狀態的步驟包括：

由所述休息狀態進入所述預選舉狀態，并發送預選舉請求，其中，接收到所述預選舉請求的主節點判斷當前是否存在處于所述工作狀態且正常的主節點，若不存在處于所述工作狀態且正常的主節點，返回預選舉投票；

當接收到的所述預選舉投票的數量大于第二閾值時，由所述預選舉狀態進入所述選舉狀態。

5.根據權利要求3所述的分布式主從系統中主節點的切換方法，其特征在于，接收到所述選舉請求的主節點還用于在一個所述周期序號內僅能發送一次所述選舉投票，且當接收到兩個或兩個以上所述選舉請求時，向先發送所述選舉請求的主節點返回所述選舉投票。

6.根據權利要求1所述的分布式主從系統中主節點的切換方法，其特征在于，

在接收客戶端發送的任務請求之后，所述切換方法還包括：將所述任務請求對應的任務數據寫入數據庫，其中，所述任務數據包括所述任務標識、任務命令和任務參數；

所述本地日志中的所述任務條目按順序排列，將所述本地日志中未完成的所述任務條目對應的任務分配至所述從節點的步驟包括：查詢所述本地日志中未完成的所述任務條目；獲取多個未完成的所述任務條目中的任務標識；根據獲取到的多個所述任務標識批量讀取所述數據庫中的任務數據；根據獲取到的所述任務數據分配任務至所述從節點。

7.根據權利要求6所述的分布式主從系統中主節點的切換方法，其特征在于，根據獲取到的所述任務數據分配任務至所述從節點的步驟包括：

將任務命令相同的任務分配至同一從節點。