[發(fā)明專利]高可用性集群系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201811585276.5
• 申請(qǐng)日: 2018-12-24
• 公開(kāi)（公告）號(hào): CN109660428B
• 公開(kāi)（公告）日: 2020-08-28
• 發(fā)明（設(shè)計(jì)）人: 唐千;孫凱;黨楊軍;蔡鵬飛;王鵬飛
• 申請(qǐng)（專利權(quán)）人: 航天信息股份有限公司
• 主分類號(hào): H04L12/26
• 分類號(hào): H04L12/26;H04L29/08;H04W76/19;G06K17/00
• 代理公司: 北京英創(chuàng)嘉友知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11447
• 代理人: 魏嘉熹;南毅寧

1.一種高可用性集群系統(tǒng)，其特征在于，包括：管理節(jié)點(diǎn)、多個(gè)工作節(jié)點(diǎn)和多個(gè)讀寫(xiě)器，

所述管理節(jié)點(diǎn)，與所述多個(gè)工作節(jié)點(diǎn)分別連接，用于管理所述多個(gè)工作節(jié)點(diǎn)；

所述讀寫(xiě)器，與所述多個(gè)工作節(jié)點(diǎn)中的相應(yīng)工作節(jié)點(diǎn)連接，用于讀取數(shù)據(jù)，并將所述數(shù)據(jù)傳輸至所述相應(yīng)工作節(jié)點(diǎn)；

所述工作節(jié)點(diǎn)，用于在與該工作節(jié)點(diǎn)相應(yīng)的任一讀寫(xiě)器處于斷開(kāi)狀態(tài)時(shí)，向所述處于斷開(kāi)狀態(tài)的讀寫(xiě)器發(fā)送恢復(fù)連接請(qǐng)求，以恢復(fù)與所述處于斷開(kāi)狀態(tài)的讀寫(xiě)器通信；

其中，所述多個(gè)工作節(jié)點(diǎn)的每個(gè)工作節(jié)點(diǎn)還用于：

向所述管理節(jié)點(diǎn)發(fā)送第一通信請(qǐng)求，所述第一通信請(qǐng)求用于請(qǐng)求與所述管理節(jié)點(diǎn)通信，且所述第一通信請(qǐng)求包括所述工作節(jié)點(diǎn)的通信地址和所述工作節(jié)點(diǎn)當(dāng)前連接的讀寫(xiě)器信息；

所述管理節(jié)點(diǎn)還用于：

在接收到所述第一通信請(qǐng)求時(shí)，與所述工作節(jié)點(diǎn)建立通信連接，并保存所述工作節(jié)點(diǎn)的通信地址和所述工作節(jié)點(diǎn)當(dāng)前連接的讀寫(xiě)器信息。

2.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述工作節(jié)點(diǎn)還用于：在與該工作節(jié)點(diǎn)相應(yīng)的任一讀寫(xiě)器處于斷開(kāi)狀態(tài)時(shí)，建立一定時(shí)任務(wù)，根據(jù)所述定時(shí)任務(wù)周期性地向所述處于斷開(kāi)狀態(tài)的讀寫(xiě)器發(fā)送恢復(fù)連接請(qǐng)求。

3.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述讀寫(xiě)器還用于：向所述多個(gè)工作節(jié)點(diǎn)中的相應(yīng)工作節(jié)點(diǎn)發(fā)送心跳包，以使所述工作節(jié)點(diǎn)根據(jù)是否接收到所述心跳包來(lái)確定所述讀寫(xiě)器是否處于斷開(kāi)狀態(tài)。

4.根據(jù)權(quán)利要求3所述的系統(tǒng)，其特征在于，所述工作節(jié)點(diǎn)還用于：在確定所述讀寫(xiě)器處于斷開(kāi)狀態(tài)時(shí)，將所述讀寫(xiě)器的狀態(tài)更新為斷開(kāi)狀態(tài)。

5.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，

所述管理節(jié)點(diǎn)還用于：

在接收到用戶終端發(fā)送的第一添加讀寫(xiě)器請(qǐng)求時(shí)，統(tǒng)計(jì)所述多個(gè)工作節(jié)點(diǎn)中每個(gè)工作節(jié)點(diǎn)當(dāng)前連接的讀寫(xiě)器數(shù)量；

將當(dāng)前連接的讀寫(xiě)器數(shù)量最少的工作節(jié)點(diǎn)確定為第一目標(biāo)工作節(jié)點(diǎn)，并將所述第一添加讀寫(xiě)器請(qǐng)求發(fā)送至所述第一目標(biāo)工作節(jié)點(diǎn)；

所述第一目標(biāo)工作節(jié)點(diǎn)用于：

根據(jù)所述第一添加讀寫(xiě)器請(qǐng)求包括的第一待加入讀寫(xiě)器的信息，向所述第一待加入讀寫(xiě)器發(fā)送第二通信請(qǐng)求，所述第二通信請(qǐng)求用于請(qǐng)求與所述第一待加入讀寫(xiě)器通信；

接收所述第一待加入讀寫(xiě)器針對(duì)所述第二通信請(qǐng)求的反饋信息，之后，向所述管理節(jié)點(diǎn)發(fā)送添加結(jié)果信息。

6.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述多個(gè)工作節(jié)點(diǎn)，還用于向所述管理節(jié)點(diǎn)發(fā)送心跳包；

所述管理節(jié)點(diǎn)，還用于在未接收到任一工作節(jié)點(diǎn)發(fā)送的所述心跳包時(shí)，確定相應(yīng)的工作節(jié)點(diǎn)處于異常狀態(tài)。

7.根據(jù)權(quán)利要求6所述的系統(tǒng)，其特征在于，所述管理節(jié)點(diǎn)還用于將處于異常狀態(tài)的工作節(jié)點(diǎn)當(dāng)前連接的讀寫(xiě)器分配至其他工作節(jié)點(diǎn)，所述其他工作節(jié)點(diǎn)為與所述管理節(jié)點(diǎn)處于通信連接的工作節(jié)點(diǎn)。

8.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，

所述管理節(jié)點(diǎn)還用于：

確定其他工作節(jié)點(diǎn)中每個(gè)工作節(jié)點(diǎn)當(dāng)前連接的讀寫(xiě)器數(shù)量，將當(dāng)前連接的讀寫(xiě)器數(shù)量最少的工作節(jié)點(diǎn)確定為第二目標(biāo)工作節(jié)點(diǎn)，并向所述第二目標(biāo)工作節(jié)點(diǎn)發(fā)送第二添加讀寫(xiě)器請(qǐng)求；

所述第二目標(biāo)工作節(jié)點(diǎn)，用于：

接收所述第二添加讀寫(xiě)器請(qǐng)求；

根據(jù)所述第二添加讀寫(xiě)器請(qǐng)求包括的第二待加入讀寫(xiě)器的信息，向所述第二待加入讀寫(xiě)器發(fā)送第三通信請(qǐng)求，所述第三通信請(qǐng)求用于請(qǐng)求與所述第二待加入讀寫(xiě)器通信；

接收所述第二待加入讀寫(xiě)器針對(duì)所述第三通信請(qǐng)求的反饋信息；

向所述管理節(jié)點(diǎn)發(fā)送添加結(jié)果信息；

觸發(fā)所述管理節(jié)點(diǎn)確定其他工作節(jié)點(diǎn)中每個(gè)工作節(jié)點(diǎn)當(dāng)前連接的讀寫(xiě)器數(shù)量，將當(dāng)前連接的讀寫(xiě)器數(shù)量最少的工作節(jié)點(diǎn)確定為第二目標(biāo)工作節(jié)點(diǎn)，并將第二添加讀寫(xiě)請(qǐng)求發(fā)送至所述第二目標(biāo)工作節(jié)點(diǎn)，直到所述處于異常狀態(tài)工作節(jié)點(diǎn)當(dāng)前連接的讀寫(xiě)器均連接至所述其他工作節(jié)點(diǎn)為止。

9.根據(jù)權(quán)利要求1-8任一項(xiàng)所述的系統(tǒng)，其特征在于，

所述管理節(jié)點(diǎn)還用于：

在接收到用戶終端發(fā)送的配置讀寫(xiě)器請(qǐng)求時(shí)，根據(jù)所述配置讀寫(xiě)器請(qǐng)求包含的待配置讀寫(xiě)器的信息，確定該待配置讀寫(xiě)器對(duì)應(yīng)的第三目標(biāo)工作節(jié)點(diǎn)；

將所述第三目標(biāo)工作節(jié)點(diǎn)的信息反饋至所述用戶終端，以使所述用戶終端向所述第三目標(biāo)工作節(jié)點(diǎn)發(fā)送所述配置讀寫(xiě)器請(qǐng)求；

所述第三目標(biāo)工作節(jié)點(diǎn)用于：

接收所述配置讀寫(xiě)器請(qǐng)求，并根據(jù)所述配置讀寫(xiě)器請(qǐng)求，對(duì)所述待配置讀寫(xiě)器進(jìn)行配置。