[發(fā)明專利]一種適應(yīng)私有云環(huán)境的通信平臺和通信方法

有效

• 申請?zhí)枺?/td>: 201110273176.0
• 申請日: 2011-09-15
• 公開（公告）號: CN102291467A
• 公開（公告）日: 2011-12-21
• 發(fā)明（設(shè)計）人: 趙太銀;陳慧楠;胡光岷
• 申請（專利權(quán)）人: 電子科技大學(xué)
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 電子科技大學(xué)專利中心 51203
• 代理人: 周永宏

1.一種適應(yīng)私有云環(huán)境下的通信平臺，所述通信平臺至少包括兩個計算節(jié)點和一個服務(wù)器節(jié)點，所述計算節(jié)點和服務(wù)器節(jié)點通過網(wǎng)絡(luò)互相連接成分布式集群系統(tǒng)，每個計算節(jié)點表示系統(tǒng)中的一臺主機，主機中包含了許多的應(yīng)用進程，其特征在于，每個節(jié)點上掛載一個通信代理，所述節(jié)點內(nèi)所有應(yīng)用進程通過通信平臺提供的標(biāo)準(zhǔn)API接口與本地通信代理連接，以實現(xiàn)應(yīng)用進程間的點對點通信，并且通過在服務(wù)器節(jié)點掛載消息服務(wù)器應(yīng)用進程，以實現(xiàn)應(yīng)用進程間的一對多通信。

2.一種適應(yīng)私有云環(huán)境下的通信方法，其特征在于，包括如下步驟：

步驟1.應(yīng)用進程通過API接口發(fā)送數(shù)據(jù)到網(wǎng)絡(luò)；

步驟2.通信代理獲取網(wǎng)絡(luò)數(shù)據(jù)；

步驟3.通信代理處理消息數(shù)據(jù)；

步驟4.消息服務(wù)器獲取并處理發(fā)布/訂閱消息；

步驟5.應(yīng)用進程通過API接口從網(wǎng)絡(luò)接收消息。

3.根據(jù)權(quán)利要求2所述的一種適應(yīng)私有云環(huán)境下的通信方法，其特征在于，所述步驟1的具體過程為：應(yīng)用進程首先向本地節(jié)點上的通信代理發(fā)起網(wǎng)絡(luò)連接請求，應(yīng)用進程與通信代理連接成功后應(yīng)用進程使用注冊API函數(shù)向通信代理發(fā)送應(yīng)用進程信息，通信代理完成應(yīng)用進程信息的維護；根據(jù)目的進程信息和應(yīng)用進程的通信需求設(shè)置通信選項，通信需求包括發(fā)送的數(shù)據(jù)類型是消息或是文件，通信方式是點對點通信或發(fā)布訂閱通信；設(shè)置好通信選項后，使用相應(yīng)的API函數(shù)，將按一定規(guī)則和協(xié)議序列化后的消息到發(fā)送到網(wǎng)絡(luò)中。

4.根據(jù)權(quán)利要求2所述的一種適應(yīng)私有云環(huán)境下的通信方法，其特征在于，所述步驟2的具體過程為：應(yīng)用進程可將需要通信的數(shù)據(jù)通過API接口發(fā)送至網(wǎng)絡(luò)中，具體的數(shù)據(jù)轉(zhuǎn)發(fā)過程由通信代理完成；在獲取網(wǎng)絡(luò)數(shù)據(jù)之前，通過代理完成與應(yīng)用進程之間的交互完成接收會話連接的建立；首先通信代理啟動后綁定固定端口號，然后開始監(jiān)聽該端口以等待網(wǎng)絡(luò)連接請求；收到新的連接請求后，建立接收會話連接等待接收LAN數(shù)據(jù)，并將新連接添加至接收會話連接信息表中，統(tǒng)一管理方便查詢。

5.根據(jù)權(quán)利要求2所述的一種適應(yīng)私有云環(huán)境下的通信方法，其特征在于，所述步驟3的具體過程為：信代理獲取到應(yīng)用進程的通信數(shù)據(jù)，并將消息存放到接收隊列后通信代理開始處理消息數(shù)據(jù)；首先通信代理開啟消息處理線程循環(huán)處理接收隊列中的消息；其次，通信代理查詢發(fā)送會話連接信息表，查看通信代理與目的進程之間是否存在發(fā)送會話連接。如果通信代理與目的進程已建立發(fā)送會話連接，則將消息通過發(fā)送會話連接發(fā)送至網(wǎng)絡(luò)中；如果沒有與目的進程之間建立發(fā)送會話連接，則根據(jù)步驟1中設(shè)置的通信選項判斷通信類型，若通信類型是發(fā)布/訂閱，則通信代理向服務(wù)器節(jié)點的通信代理發(fā)起發(fā)送會話連接請求；若通信類型是點對點通信，再通過判定目的進程IP與通信代理IP是否相同，相同則為節(jié)點內(nèi)進程通信，通信代理向目的進程發(fā)起發(fā)送會話連接請求，若不同則為節(jié)點間進程通信，通信代理向目的進程所在通信代理發(fā)起發(fā)送會話連接請求。連接請求若失敗，則該消息存放至消息失敗隊列中；連接成功后將新連接添加至發(fā)送會話連接信息表中，再將消息通過發(fā)送會話連接發(fā)送至網(wǎng)絡(luò)中。

6.根據(jù)權(quán)利要求2所述的一種適應(yīng)私有云環(huán)境下的通信方法，其特征在于，所述步驟4的具體過程為：通過步驟3，若通信類型是點對點通信則轉(zhuǎn)到步驟5；若通信類型是發(fā)布/訂閱則消息發(fā)送至消息服務(wù)器節(jié)點的通信代理上，然后服務(wù)器節(jié)點的通信代理再將消息轉(zhuǎn)發(fā)至消息服務(wù)器，此處服務(wù)器節(jié)點的通信代理獲取并處理數(shù)據(jù)與步驟2和步驟3相同，消息服務(wù)器獲取消息與步驟5相同；消息服務(wù)器在收到消息后判斷在步驟1中設(shè)置的消息類型，若是控制消息，采取取消主題消息或者取消訂閱消息的操作；若是主題消息則將消息添加至發(fā)布主題映射表；若是訂閱消息則將消息添加至訂閱主題映射表。

7.根據(jù)權(quán)利要求2所述的一種適應(yīng)私有云環(huán)境下的通信方法，其特征在于，所述步驟5的具體過程為：應(yīng)用進程在啟動后綁定固定端口號，然后開始監(jiān)聽該端口以等待網(wǎng)絡(luò)連接請求，收到新的連接請求后，建立應(yīng)用進程的接收會話連接等待接收LAN數(shù)據(jù)。當(dāng)通信代理向應(yīng)用進程發(fā)送數(shù)據(jù)時，應(yīng)用進程的接收會話連接調(diào)用通信平臺提供的同步或異步接收API函數(shù)獲取網(wǎng)絡(luò)中數(shù)據(jù)，然后再將數(shù)據(jù)按一定的規(guī)則和協(xié)議反序列化為消息。