[發(fā)明專利]節(jié)點切換方法、裝置、設備及計算機可讀存儲介質

有效

• 申請?zhí)枺?/td>: 202010151083.X
• 申請日: 2020-03-06
• 公開（公告）號: CN111459724B
• 公開（公告）日: 2023-08-25
• 發(fā)明（設計）人: 劉震;邵利鐸;鹿慧;何棟;張鵬飛;孟慶峰;劉松;劉皓;王路遠;蔡雨佳;李超;馬南;賈韶光
• 申請（專利權）人: 中國人民財產保險股份有限公司
• 主分類號: G06F11/20
• 分類號: G06F11/20;G06F11/14;G06F16/27
• 代理公司: 北京國昊天誠知識產權代理有限公司 11315
• 代理人: 李瀟

1.一種節(jié)點切換方法，其特征在于，應用于多活容災系統(tǒng)中的數(shù)據(jù)中心，所述多活容災系統(tǒng)包括多個數(shù)據(jù)中心，所述數(shù)據(jù)中心包括一個主節(jié)點以及至少一個從節(jié)點，所述主節(jié)點上創(chuàng)建有復制槽目錄，所述數(shù)據(jù)中心設置有共享目錄，所述主節(jié)點上創(chuàng)建的復制槽目錄鏈接至所述共享目錄中，以使得所述數(shù)據(jù)中心中的主節(jié)點以及從節(jié)點根據(jù)所述復制槽目錄讀取對應的復制槽數(shù)據(jù)，基于讀取的復制槽數(shù)據(jù)不同的主節(jié)點之間進行邏輯數(shù)據(jù)的主主復制，所述方法包括：

當主節(jié)點異常時，從運行正常的從節(jié)點中確定待切換節(jié)點；

將所述待切換節(jié)點切換為主節(jié)點；

對所述復制槽目錄進行重新加載，以使得所述待切換節(jié)點在切換為主節(jié)點后根據(jù)重新加載的所述復制槽目錄讀取對應的目標復制槽數(shù)據(jù)，并基于所述目標復制槽數(shù)據(jù)與所述多活容災系統(tǒng)中的其他主節(jié)點進行邏輯數(shù)據(jù)的主主復制；

其中，所述數(shù)據(jù)中心包括kafka數(shù)據(jù)庫；在所述對所述復制槽目錄進行重新加載之后，所述方法還包括：

將所述復制槽目錄對應的復制槽數(shù)據(jù)傳輸至kafka數(shù)據(jù)庫中，以使得所述多活容災系統(tǒng)中的其他主節(jié)點通過所述kafka數(shù)據(jù)庫獲取所述復制槽目錄對應的復制槽數(shù)據(jù)。

2.根據(jù)權利要求1所述的方法，其特征在于，所述將所述待切換節(jié)點切換為主節(jié)點包括：

通過對所述待切換節(jié)點進行重啟來實現(xiàn)將所述待切換節(jié)點切換為主節(jié)點。

3.根據(jù)權利要求1所述的方法，其特征在于，在所述復制槽目錄進行重新加載之后，所述方法還包括：

確定用于對復制槽目錄對應的復制槽數(shù)據(jù)進行傳輸?shù)倪M程的個數(shù)是否等于預設值；

當所述個數(shù)等于預設值時，重新調起所述用于對復制槽目錄對應的復制槽數(shù)據(jù)進行傳輸?shù)倪M程。

4.根據(jù)權利要求2所述的方法，其特征在于，所述數(shù)據(jù)中心為基于pacemaker的高可用集群，在所述從運行正常的從節(jié)點中確定待切換節(jié)點之后，在所述通過對所述待切換節(jié)點進行重啟來實現(xiàn)將所述待切換節(jié)點切換為主節(jié)點之前，所述方法還包括：

通過安裝pacemaker時的配置腳本來實現(xiàn)對所述待切換節(jié)點的重啟。

5.根據(jù)權利要求4所述的方法，其特征在于，所述通過安裝pacemaker時的配置腳本來實現(xiàn)對所述待切換節(jié)點的重啟，包括：

將安裝pacemaker時的配置腳本中用于將待切換為主節(jié)點的從節(jié)點切換為主節(jié)點的代碼修改為對所述待切換為主節(jié)點的從節(jié)點進行重啟的代碼。

6.根據(jù)權利要求1至5任一所述的方法，其特征在于，所述復制槽目錄為pg_replslot目錄。

7.一種節(jié)點切換裝置，其特征在于，應用于多活容災系統(tǒng)中的數(shù)據(jù)中心，所述多活容災系統(tǒng)包括多個數(shù)據(jù)中心，其中，所述數(shù)據(jù)中心包括kafka數(shù)據(jù)庫；所述數(shù)據(jù)中心包括一個主節(jié)點以及至少一個從節(jié)點，所述主節(jié)點上創(chuàng)建有復制槽目錄，所述數(shù)據(jù)中心設置有共享目錄，所述主節(jié)點上創(chuàng)建的復制槽目錄鏈接至所述共享目錄中，以使得所述數(shù)據(jù)中心中的主節(jié)點以及從節(jié)點根據(jù)所述復制槽目錄讀取對應的復制槽數(shù)據(jù)，基于讀取的復制槽數(shù)據(jù)不同的主節(jié)點之間進行邏輯數(shù)據(jù)的主主復制，所述裝置包括：

確定模塊，用于當主節(jié)點異常時，從運行正常的從節(jié)點中確定待切換節(jié)點；

切換模塊，用于將所述待切換節(jié)點切換為主節(jié)點；

加載模塊，用于對所述復制槽目錄進行重新加載，以使得所述待切換節(jié)點在切換為主節(jié)點后根據(jù)重新加載的所述復制槽目錄讀取對應的目標復制槽數(shù)據(jù)，并基于所述目標復制槽數(shù)據(jù)與所述多活容災系統(tǒng)中的其他主節(jié)點進行邏輯數(shù)據(jù)的主主復制；

其中，在所述對所述復制槽目錄進行重新加載之后，所述裝置還包括：

傳輸模塊，用于將所述復制槽目錄對應的復制槽數(shù)據(jù)傳輸至kafka數(shù)據(jù)庫中，以使得所述多活容災系統(tǒng)中的其他主節(jié)點通過所述kafka數(shù)據(jù)庫獲取所述復制槽目錄對應的復制槽數(shù)據(jù)。

8.一種節(jié)點切換設備，其特征在于，包括：存儲器、處理器及存儲在所述存儲器上并可在所述處理器上運行的計算機程序，所述計算機程序被所述處理器執(zhí)行時實現(xiàn)如權利要求1至6中任一項所述的方法的步驟。

9.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機程序，所述計算機程序被處理器執(zhí)行時實現(xiàn)如權利要求1至6中任一項所述的方法的步驟。