[發明專利]一種分布式通訊系統及對應的分布式通訊方法

在審

• 申請號: 201610232818.5
• 申請日: 2016-04-15
• 公開（公告）號: CN105791419A
• 公開（公告）日: 2016-07-20
• 發明（設計）人: 韓宇峰
• 申請（專利權）人: 北京思特奇信息技術股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京輕創知識產權代理有限公司 11212
• 代理人: 楊立

技術領域

本發明涉及分布式通訊技術領域，具體一種分布式通訊系統及采用該分 布式通訊系統進行分布式通訊的方法。

背景技術

隨著業務數據交換平臺的業務規模擴大，單主機單節點部署已經無法滿 足業務需求。消息量的大量增長導致我們必須采取集群模式進行處理，分布 式通訊是完成多主機之間信息交換的基礎，技術方面一般有2種選擇：開源 /商用的分布式通訊框架，自主開發分布式通訊框架。

對于開源/商用的分布式通訊框架，主要有以下幾個問題：

1、需要獨立主機進行部署，增加項目和維護成本；

2、API接口較多，開發人員需要進行大量培訓；

對于自主開發的分布式通訊框架，主要有以下幾個問題：

1、傳統的socket連接模式僅支持端到端連接，對于集群模式需要管理 多個socket描述符，增加開發難度和邏輯復雜度；

2、傳統的socket處理需要顯示地建立連接、監聽端口、處理異常，開 發復雜度大大增加。

發明內容

本發明所要解決的技術問題是提供一種分布式通訊系統及對應的分布 式通訊方法，能夠克服現有技術的不足。

本發明解決上述技術問題的技術方案如下：

一方面，本發明提供了一種分布式通訊系統，包括接口機集群和業務機 集群，所述接口機集群包括多個接口主機，所述業務機集群包括多個業務主 機；

每一個接口主機，用于從接口主機本地獲取任務配置信息，并將獲取的 任務配置信息廣播給對應的多個業務主機；還用于從本地獲取待處理任務， 并將獲取的待處理任務分發給對應的業務主機；

每一個業務主機，用于接收對應的接口主機廣播的任務配置信息，并根 據接收的任務配置信息，更新本地的任務配置信息，且向對應的接口主機發 送信息接收響應；還用于獲取對應的接口主機發送的待處理任務，并根據本 地的任務配置信息對待處理任務進行處理，且向對應的接口主機發送任務接 收響應。

另一方面，本發明提供了一種采用分布式通訊系統進行分布式通訊的方 法，所述分布式通訊系統包括接口機集群和業務機集群，所述接口機集群包 括多個接口主機，所述業務及集群包括多個業務主機，包括：

每一個接口主機從接口主機本地獲取任務配置信息，并將獲取的任務配 置信息廣播給對應的多個業務主機；以及從本地獲取待處理任務，并將獲取 的待處理任務分發給對應的業務主機；

每一個業務主機接收對應的接口主機廣播的任務配置信息，并根據接收 的任務配置信息，更新本地的任務配置信息，且向對應的接口主機發送信息 接收響應；以及獲取對應的接口主機發送的待處理任務，并根據本地的任務 配置信息對待處理任務進行處理，且向對應的接口主機發送任務接收響應。

本發明提供的一種分布式通訊系統及采用分布式通訊系統進行分布式 通訊的方法，接口機集群與業務機集群可支持1：N的連接模式，也可支持 M：N的連接模式，無需獨立的主機單獨部署，沒有中心的概念，避免單節 點故障；支持M：N的連接模式，減少端口數量，提高整個系統的利用效率； 可支持橫向擴展，可以任意擴展接口主機的數量和業務主機的數量，相比傳 統socket的端到端的連接更具有擴展性；本方案采取模塊化開發，代碼復用 度高，可以適用各種業務處理場景。

附圖說明

圖1為本發明實施例一的一種分布式通訊系統示意圖；

圖2為任務配置信息廣播示意圖；

圖3為接口主機中的pub組件與業務主機中的sub組件之間的通訊示意 圖；

圖4為任務下發示意圖；

圖5為任務接收反饋示意圖；

圖6為push組件與pull組件之間的通訊示意圖；

圖7為廣播任務配置信息流程圖；

圖8為任務下發流程圖。

具體實施方式

以下結合附圖對本發明的原理和特征進行描述，所舉實例只用于解釋本 發明，并非用于限定本發明的范圍。

實施例一、一種分布式通訊系統。下面結合圖1至圖6對本實施例提供 的消息發布系統進行說明。

參見圖1，本實施例提供的分布式通訊系統包括接口機集群和業務機集 群，所述接口機集群包括多個接口主機，所述業務機集群包括多個業務主機。