[發(fā)明專利]一種基于ZooKeeper的分布式服務(wù)狀態(tài)一致性維護(hù)方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202010102586.8
• 申請(qǐng)日: 2020-02-19
• 公開（公告）號(hào): CN111552672B
• 公開（公告）日: 2023-09-15
• 發(fā)明（設(shè)計(jì)）人: 張哲;衛(wèi)寧;江向東
• 申請(qǐng)（專利權(quán)）人: 中國(guó)船舶工業(yè)系統(tǒng)工程研究院
• 主分類號(hào): G06F16/178
• 分類號(hào): G06F16/178;G06F16/182
• 代理公司: 中國(guó)航天科技專利中心 11009
• 代理人: 陳鵬

本發(fā)明提供了一種基于ZooKeeper的分布式服務(wù)狀態(tài)一致性維護(hù)方法及裝置，實(shí)現(xiàn)過(guò)程為：服務(wù)注冊(cè)中心在ZooKeeper集群上創(chuàng)建全局?jǐn)?shù)據(jù)空間的根節(jié)點(diǎn)；當(dāng)執(zhí)行服務(wù)注冊(cè)操作時(shí)，服務(wù)注冊(cè)中心根據(jù)服務(wù)的命名空間、版本號(hào)信息在ZooKeeper集群的根節(jié)點(diǎn)下創(chuàng)建命名空間節(jié)點(diǎn)、服務(wù)名節(jié)點(diǎn)、版本號(hào)節(jié)點(diǎn)、和實(shí)例節(jié)點(diǎn)；服務(wù)提供者和服務(wù)消費(fèi)者在服務(wù)運(yùn)行的初始化階段在ZooKeeper集群全局?jǐn)?shù)據(jù)空間的實(shí)例節(jié)點(diǎn)下創(chuàng)建服務(wù)提供者節(jié)點(diǎn)和服務(wù)消費(fèi)者節(jié)點(diǎn)。本發(fā)明利用ZooKeeper的持久節(jié)點(diǎn)特性，可以高效、全局一致地維護(hù)服務(wù)的靜態(tài)基本信息，實(shí)時(shí)獲取服務(wù)提供者的存活情況以及服務(wù)消費(fèi)者對(duì)服務(wù)實(shí)例的訪問(wèn)情況，為實(shí)現(xiàn)服務(wù)的動(dòng)態(tài)綁定、服務(wù)請(qǐng)求負(fù)載均衡、系統(tǒng)實(shí)時(shí)監(jiān)控等提供基礎(chǔ)。

技術(shù)領(lǐng)域

本發(fā)明屬于計(jì)算機(jī)技術(shù)領(lǐng)域，涉及一種服務(wù)負(fù)載均衡技術(shù)，特別涉及一種基于ZooKeeper的分布式服務(wù)狀態(tài)一致性維護(hù)方法及裝置。

背景技術(shù)

在服務(wù)集成框架應(yīng)用的早期階段，服務(wù)注冊(cè)中心采用單機(jī)集中式的架構(gòu)，由于服務(wù)規(guī)模較小，框架基本能夠滿足應(yīng)用需求。但隨著服務(wù)化實(shí)踐的深入，越來(lái)越多的應(yīng)用集成進(jìn)來(lái)，單機(jī)集中式的服務(wù)注冊(cè)中心在性能、容錯(cuò)能力、可擴(kuò)展性方面的不足逐漸暴露出來(lái)。

為了解決單機(jī)集中式的服務(wù)注冊(cè)中心存在的問(wèn)題，需要將原有的服務(wù)注冊(cè)中心改為分布式集群的架構(gòu)。由于分布式的服務(wù)注冊(cè)中心集群需要共享數(shù)據(jù)，因此需要一種高效的數(shù)據(jù)同步方案用于維護(hù)服務(wù)注冊(cè)中心集群之間的數(shù)據(jù)一致性。

發(fā)明內(nèi)容

為了克服現(xiàn)有技術(shù)的不足，本發(fā)明人進(jìn)行了銳意研究，提供了一種基于ZooKeeper的分布式服務(wù)狀態(tài)一致性維護(hù)方法及裝置，利用ZooKeeper的文件系統(tǒng)構(gòu)造全局?jǐn)?shù)據(jù)空間，從而維護(hù)服務(wù)集成框架中分布式的服務(wù)注冊(cè)中心集群的數(shù)據(jù)一致性；使用ZooKeeper持久節(jié)點(diǎn)維護(hù)不同命名空間下的同名服務(wù)以及同一服務(wù)的不同版本信息，使得系統(tǒng)中可以同時(shí)容納服務(wù)的不同版本并同時(shí)向服務(wù)消費(fèi)者提供服務(wù)；使用臨時(shí)節(jié)點(diǎn)維護(hù)系統(tǒng)中各個(gè)服務(wù)及其服務(wù)消費(fèi)者的存活情況，通過(guò)遍歷該全局?jǐn)?shù)據(jù)空間，系統(tǒng)管理員可以獲得分布于系統(tǒng)中的所有服務(wù)提供者以及相應(yīng)服務(wù)消費(fèi)者的一致性實(shí)時(shí)狀態(tài)信息，從而實(shí)現(xiàn)對(duì)系統(tǒng)的全局實(shí)時(shí)監(jiān)控，完成本發(fā)明。

本發(fā)明的目的在于提供以下技術(shù)方案：

第一方面，一種基于ZooKeeper的分布式服務(wù)狀態(tài)一致性維護(hù)方法，包括：

S100，服務(wù)注冊(cè)中心在ZooKeeper集群上創(chuàng)建全局?jǐn)?shù)據(jù)空間的根節(jié)點(diǎn)；

S200，當(dāng)執(zhí)行服務(wù)注冊(cè)操作時(shí)，服務(wù)注冊(cè)中心根據(jù)服務(wù)的命名空間、版本號(hào)信息在ZooKeeper集群的根節(jié)點(diǎn)下創(chuàng)建命名空間節(jié)點(diǎn)、服務(wù)名節(jié)點(diǎn)、版本號(hào)節(jié)點(diǎn)、和實(shí)例節(jié)點(diǎn)，其中，實(shí)例節(jié)點(diǎn)分為服務(wù)提供者實(shí)例節(jié)點(diǎn)和服務(wù)消費(fèi)者實(shí)例節(jié)點(diǎn)。

進(jìn)一步地，該方法還包括S300，服務(wù)提供者和服務(wù)消費(fèi)者在服務(wù)運(yùn)行的初始化階段在ZooKeeper集群全局?jǐn)?shù)據(jù)空間的實(shí)例節(jié)點(diǎn)下創(chuàng)建服務(wù)提供者節(jié)點(diǎn)和服務(wù)消費(fèi)者節(jié)點(diǎn)，服務(wù)提供者節(jié)點(diǎn)以服務(wù)提供者實(shí)例節(jié)點(diǎn)為父節(jié)點(diǎn)，服務(wù)消費(fèi)者節(jié)點(diǎn)以服務(wù)消費(fèi)者實(shí)例節(jié)點(diǎn)為父節(jié)點(diǎn)。

第二方面，一種基于ZooKeeper的分布式服務(wù)狀態(tài)一致性維護(hù)裝置，包括：服務(wù)注冊(cè)中心，用于在ZooKeeper集群上創(chuàng)建全局?jǐn)?shù)據(jù)空間的根節(jié)點(diǎn)，并根據(jù)服務(wù)的命名空間、版本號(hào)信息在ZooKeeper集群的根節(jié)點(diǎn)下創(chuàng)建命名空間節(jié)點(diǎn)、服務(wù)名節(jié)點(diǎn)、版本號(hào)節(jié)點(diǎn)、和實(shí)例節(jié)點(diǎn)；

其中，實(shí)例節(jié)點(diǎn)分為服務(wù)提供者實(shí)例節(jié)點(diǎn)和服務(wù)消費(fèi)者實(shí)例節(jié)點(diǎn)。

進(jìn)一步地，該裝置還包括：

服務(wù)提供者，用于在服務(wù)運(yùn)行的初始化階段在ZooKeeper集群全局?jǐn)?shù)據(jù)空間的服務(wù)提供者實(shí)例節(jié)點(diǎn)下創(chuàng)建服務(wù)提供者節(jié)點(diǎn)；

服務(wù)消費(fèi)者，用于在服務(wù)運(yùn)行的初始化階段在ZooKeeper集群全局?jǐn)?shù)據(jù)空間的服務(wù)消費(fèi)者實(shí)例節(jié)點(diǎn)下創(chuàng)建服務(wù)消費(fèi)者節(jié)點(diǎn)。