[發(fā)明專利]云平臺(tái)上節(jié)點(diǎn)間進(jìn)行服務(wù)通信的方法

無(wú)效

• 申請(qǐng)?zhí)枺?/td>: 201310090505.7
• 申請(qǐng)日: 2013-03-19
• 公開(kāi)（公告）號(hào): CN103152428A
• 公開(kāi)（公告）日: 2013-06-12
• 發(fā)明（設(shè)計(jì)）人: 王鵬
• 申請(qǐng)（專利權(quán)）人: 漢柏科技有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08
• 代理公司: 北京路浩知識(shí)產(chǎn)權(quán)代理有限公司 11002
• 代理人: 王瑩

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

本發(fā)明涉及分布式服務(wù)技術(shù)領(lǐng)域，特別涉及一種云平臺(tái)上節(jié)點(diǎn)間進(jìn)行服務(wù)通信的方法。

背景技術(shù)

伴隨著云平臺(tái)的發(fā)展，分布式系統(tǒng)或分布式服務(wù)越來(lái)越成為業(yè)界研究的重點(diǎn)。目前，云平臺(tái)中不同節(jié)點(diǎn)上的服務(wù)間通信，通常是服務(wù)端通過(guò)偵聽(tīng)TCP/UDP端口的方式等待客戶端的連接，一旦建立連接后開(kāi)始發(fā)送消息。但是這種通信方式，不利于實(shí)現(xiàn)一個(gè)消息被多個(gè)節(jié)點(diǎn)上的服務(wù)同時(shí)接收。比如，云平臺(tái)上的一個(gè)節(jié)點(diǎn)a，運(yùn)行服務(wù)A；另外一個(gè)節(jié)點(diǎn)b，運(yùn)行服務(wù)B；還有一個(gè)節(jié)點(diǎn)c，運(yùn)行服務(wù)C。現(xiàn)在節(jié)點(diǎn)a要完成一項(xiàng)任務(wù)，這項(xiàng)任務(wù)需要同時(shí)運(yùn)行服務(wù)A、B和C。那么，如何讓各個(gè)節(jié)點(diǎn)上的服務(wù)來(lái)協(xié)同完成這項(xiàng)任務(wù)呢？

zookeeper是Hadoop的一個(gè)子項(xiàng)目，它是一個(gè)針對(duì)大型分布式系統(tǒng)的可靠協(xié)調(diào)系統(tǒng)，也可以看成是一種分布式服務(wù)框架。它主要用來(lái)解決分布式應(yīng)用中經(jīng)常遇到的一些數(shù)據(jù)管理問(wèn)題，如：統(tǒng)一命名服務(wù)、狀態(tài)同步服務(wù)、集群管理、分布式應(yīng)用配置項(xiàng)的管理等。zookeeper的目標(biāo)就是封裝好復(fù)雜易出錯(cuò)的關(guān)鍵服務(wù)，將簡(jiǎn)單易用的接口和性能高效、功能穩(wěn)定的系統(tǒng)提供給用戶。

如果能夠利用zookeeper來(lái)完成集群中不同節(jié)點(diǎn)間的服務(wù)通信，便可有效解決上述不同服務(wù)來(lái)協(xié)同完成一項(xiàng)任務(wù)的問(wèn)題。

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

（一）所要解決的技術(shù)問(wèn)題

本發(fā)明的目的在于提供一種基于zookeeper的云平臺(tái)上節(jié)點(diǎn)間進(jìn)行服務(wù)通信的方法，從而使得集群中多個(gè)節(jié)點(diǎn)上的不同服務(wù)能夠協(xié)同完成同一項(xiàng)任務(wù)。

（二）技術(shù)方案

為了解決上述技術(shù)問(wèn)題，本發(fā)明提出了一種云平臺(tái)上節(jié)點(diǎn)間進(jìn)行服務(wù)通信的方法，所述方法包括以下步驟：

S1、利用zookeeper在任務(wù)發(fā)起端與任務(wù)接收端之間建立znode路徑，其中，所述任務(wù)接收端有多個(gè)；

S2、所述任務(wù)發(fā)起端將任務(wù)消息寫入所述znode路徑；

S3、所述任務(wù)接收端從所述znode路徑中讀取所述任務(wù)消息。

可選的，步驟S3之前還包括：所述任務(wù)接收端一直監(jiān)視所述znode路徑。

可選的，步驟S2具體包括：

S2-1、在所述znode路徑中建立任務(wù)發(fā)送目錄節(jié)點(diǎn)，所述任務(wù)發(fā)送目錄節(jié)點(diǎn)用于保存所述任務(wù)發(fā)起端發(fā)送的任務(wù)消息，

S2-2、所述任務(wù)發(fā)起端將任務(wù)消息寫入所述任務(wù)發(fā)送目錄節(jié)點(diǎn)；

步驟S3具體包括：所述任務(wù)接收端從所述任務(wù)發(fā)送目錄節(jié)點(diǎn)中讀取所述任務(wù)消息。

可選的，步驟S3之后還包括步驟：

S4、所述任務(wù)接收端根據(jù)所述任務(wù)消息執(zhí)行完相應(yīng)的任務(wù)后，將任務(wù)反饋消息寫入所述znode路徑；

S5、所述任務(wù)發(fā)起端從所述znode路徑中讀取所述任務(wù)反饋消息。

可選的，步驟S5之前還包括：所述任務(wù)發(fā)起端一直監(jiān)視所述znode路徑。

可選的，步驟S4之前還包括：在所述znode路徑中建立任務(wù)反饋目錄節(jié)點(diǎn)，所述任務(wù)反饋目錄節(jié)點(diǎn)用于保存所述任務(wù)接收端發(fā)送的任務(wù)反饋消息；

步驟S4具體包括：所述任務(wù)接收端根據(jù)所述任務(wù)消息執(zhí)行完相應(yīng)的任務(wù)后，將任務(wù)反饋消息寫入所述任務(wù)反饋目錄節(jié)點(diǎn)；

步驟S5具體包括：所述任務(wù)發(fā)起端從所述任務(wù)反饋目錄節(jié)點(diǎn)中讀取所述任務(wù)反饋消息。

（三）有益效果

與現(xiàn)有技術(shù)相比，本發(fā)明提出的技術(shù)方案具有如下優(yōu)點(diǎn)：

1、在集群中可以將一個(gè)大的計(jì)算任務(wù)分配到多個(gè)物理機(jī)（節(jié)點(diǎn)）上進(jìn)行計(jì)算，從而節(jié)約了計(jì)算時(shí)間；

2、在集群中可以協(xié)同多個(gè)物理機(jī)上的多個(gè)服務(wù)共同完成一件事情；

3、能夠在集群中實(shí)現(xiàn)消息的并發(fā)。

附圖說(shuō)明

圖1是本發(fā)明所述方法的一種具體實(shí)施方式的基本流程圖。

圖2是本發(fā)明一個(gè)實(shí)施例中實(shí)現(xiàn)消息并發(fā)的示意圖。

圖3是本發(fā)明一個(gè)實(shí)施例中實(shí)現(xiàn)消息反饋的示意圖。

具體實(shí)施方式

下面結(jié)合附圖和實(shí)施例，對(duì)本發(fā)明的具體實(shí)施方式作進(jìn)一步詳細(xì)描述。

如圖1所示，本發(fā)明提出的云平臺(tái)上節(jié)點(diǎn)間進(jìn)行服務(wù)通信的方法，包括以下步驟：

S1、利用zookeeper在任務(wù)發(fā)起端與任務(wù)接收端之間建立znode路徑，其中，所述任務(wù)接收端有多個(gè)；

S2、所述任務(wù)發(fā)起端將任務(wù)消息寫入所述znode路徑；

S3、所述任務(wù)接收端從所述znode路徑中讀取所述任務(wù)消息。

步驟S3之前還包括：所述任務(wù)接收端一直監(jiān)視所述znode路徑。

步驟S3之后還包括步驟：