[發明專利]應用于靜態集群上的分布式通信系統及方法

有效

• 申請號: 201610713201.5
• 申請日: 2016-08-24
• 公開（公告）號: CN106326020B
• 公開（公告）日: 2019-06-18
• 發明（設計）人: 丁康;汪月林
• 申請（專利權）人: 浙江浙大中控信息技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;H04L29/08
• 代理公司: 杭州杭誠專利事務所有限公司 33109
• 代理人: 尉偉敏;閻忠華

1.一種應用于靜態集群上的分布式通信系統的方法，其特征是，應用于靜態集群上的分布式通信系統包括N臺主機（2），m個應用服務進程（23）的靜態集群上，服務于該靜態集群的分布式通信系統包括設于每臺主機上的天使服務進程（21），極速配置庫（22）和m個天使客戶端庫（24）；每個應用服務進程均調用對應的 天使客戶端庫，天使服務進程和各個應用服務進程均與極速配置庫連接，天使服務進程分別與各個應用服務進程連接，N≥1，m≥2；

極速配置庫中設有應用服務進程信息表與天使服務進程信息表；

應用服務進程信息表由4個字段構成，4個字段分別為應用服務進程服務名，應用服務進程編號，應用服務進程對應的天使服務進程編號和應用服務進程在線狀態；其中，應用服務進程服務名是應用服務進程信息表的主鍵；應用服務進程在線狀態字段是動態字段，應用服務進程根據應用服務進程與天使服務進程之間的連接狀態進行更新，其它字段均為靜態字段；

天使服務進程信息表由5個字段構成，5個字段分別為天使服務進程地址信息，天使服務進程編號，天使服務進程附屬應用服務進程起始編號，天使服務進程附屬應用服務進程個數和天使服務進程在線狀態；天使服務進程地址信息是天使服務進程信息表的主鍵，天使服務進程為動態字段，天使服務進程在線狀態根據本地天使服務進程與其它天使服務進程之間的連接狀態進行更新，同時更新的包括天使服務進程附屬的應用服務進程在線狀態；

包括關系表的插入過程：

步驟1：從要插入行的行內容中取出主鍵內容；

步驟2：對主鍵進行哈希計算，得到哈希值；

步驟3：在哈希區尋找與哈希值對應節點的位置，如果該節點沒有被使用，轉入步驟4，如果該節點已經被使用，轉入步驟6；

步驟4：在節點內寫入節點信息，節點信息包括主鍵、行號和下個節點偏移；其中，行號為關系表的表頭中的待插入行號，表頭包括行數目；

步驟5：將行內容寫入待插入行號的行，待插入行號加1；

步驟6：按照節點信息中下一個節點偏移信息，依次尋找下一個節點，直到下一個節點偏移為-1，將-1改為拉鏈區可用節點偏移，在拉鏈區可用偏移的位置上，寫入節點信息，將拉鏈區可用偏移號加1；

步驟7：將行內容寫入待插入行號的行，待插入行號加1；

其中，哈希計算包括如下步驟：

步驟1：采用公用的哈希算法對主鍵進行哈希，得到一個整數；

步驟2：將整數對行數目取余，得到一個哈希值；

還包括應用服務進程登錄過程:

步驟1：在主機i上，應用服務進程j在天使服務進程i上登錄，應用服務進程j調用天使客戶端庫的登錄接口，傳入自己的服務名jX；i=1,2,…,N；j=1,2,…,m；

步驟2：天使服務進程i接到應用服務進程j登錄請求，按照服務名j查詢查詢本地極速配置庫；

如果查到極速配置庫里面存在該服務的配置，返回應用服務進程j的編號及登錄成功的信息，修改極速配置庫內應用服務進程j的登錄狀態為已經登錄，轉入步驟3；

如果沒有查到極速配置庫里面存在該服務的配置，返回-1及登錄失敗的信息；

步驟3：天使服務進程i將應用服務進程j的已登錄狀態廣播發送給天使服務進程2到N；

天使服務進程2至天使服務進程N收到應用服務進程j的已登錄狀態，分別轉入步驟4；

步驟4：天使服務進程2至天使服務進程N將應用服務進程j的已登錄狀態寫入本地極速配置庫；

還包括應用服務進程之間通信過程：

應用服務進程j向應用服務進程k發送一個消息；k=1,2,…,m；k≠j；

步驟1：應用服務進程j通過本地極速配置庫，按照應用服務進程k的服務名，查詢應用服務進程k的編號與在線狀態；若查詢到應用服務進程的編號且應用服務進程的在線狀態為在線，轉入步驟2；反之，返回失敗信息，通信結束；

步驟2：應用服務進程j構建消息包，向天使服務進程i發送該消息包；

步驟3：天使服務進程i收到該消息包，按照該消息包包頭內容，查詢極速配置庫，查出應該轉發的目標天使進程N，并查詢目標天使進程N的在線狀態；

步驟4：天使服務進程i將消息包發送給天使服務進程N；

步驟5：天使服務進程N收到該消息包，按照該消息包包頭內容，查詢極速配置庫，查出應用服務進程k；

步驟6：天使服務進程N將消息包發送給應用服務進程k。