[發明專利]用于在分布式系統中進行檢測的系統和方法

有效

• 申請號: 201310158807.3
• 申請日: 2013-05-02
• 公開（公告）號: CN103236958A
• 公開（公告）日: 2013-08-07
• 發明（設計）人: 吳友強
• 申請（專利權）人: 北京京東尚科信息技術有限公司
• 主分類號: H04L12/26
• 分類號: H04L12/26;H04L29/08
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 李寶泉;周亞榮

技術領域

本發明涉及用于在分布式系統中進行檢測的系統和方法，更具體地涉及在分布式系統中檢測節點是否存活、數據流通狀態、以及網絡延遲的系統和方法。

背景技術

隨著分布式系統的廣泛使用，經常需要檢測成千上萬個客戶端或客戶端程序是否存活。

在現有技術中，通常使用Zookeeper集群來檢測成千上萬個客戶端。然而，當使用Zookeeper集群來檢測成千上萬個客戶端時壓力是非常大的，而且需要動態檢測Zookeeper集群中的臨時節點，并且Zookeeper集群不能檢測是因為網絡不通還是客戶端宕機造成的。而且，因為集群中涉及到大量的數據傳輸，還需要能夠檢測整個分布式集群中的網絡堵塞情況。

因此，期望提供一種改進的用于在分布式系統中進行檢測的系統和方法。

發明內容

為了解決現有技術中的上述缺點和問題中的至少一個而提出本發明。

根據一個方面，本發明提出了一種用于在分布式系統中進行檢測的方法，包括：

數據流檢測集群獲取第一節點集群中的所有第一節點的信息列表；

所述數據流檢測集群根據所獲得的信息列表向所述第一節點集群發送帶有時間戳的信息，基于所述信息是否發送成功來確定所述第一節點集群的存活狀態；

在接收到所述數據流檢測集群發送的信息之后，所述第一節點集群生成時間戳并將帶有該時間戳的信息發送到第二節點集群；

在接收到所述第一節點集群發送的信息之后，所述第二節點集群生成時間戳并將帶有該時間戳的信息發送到第三節點集群；

在接收到所述第二節點集群發送的信息之后，所述第三節點集群生成時間戳并將帶有該時間戳的信息發送到所述數據流檢測集群；以及

所述數據流檢測集群根據信息中的時間戳來計算各節點之間的網絡延遲，并將網絡延遲寫入日志。

可選地，所述第一節點集群是數據收集器集群，所述第二節點集群是數據轉發器集群，以及所述第三節點集群是數據聚合器集群。

可選地，無論信息發送成功或失敗，所述第一節點集群和所述第二節點集群都通知所述數據流檢測集群。

可選地，所述第一節點集群和所述第二節點集群通過調用所述數據流檢測集群提供的遠程過程調用（RPC）服務來通知所述數據流檢測集群。

可選地，所述數據流檢測集群嘗試向所述第一節點集群發送信息多次。

根據另一個方面，本發明提出了一種用于在分布式系統中進行檢測的系統，包括：

統一服務模塊，所述統一服務模塊被配置為提供統一服務；

數據流檢測集群，被配置為通過向第一節點集群發送帶有時間戳的信息并且基于信息是否發送成功來確定第一節點集群的存活狀態，以及根據各節點發送的信息中的時間戳來計算各節點之間的網絡延遲；

第一節點集群，所述第一節點集群被配置為在接收到所述數據流檢測集群發送的信息之后，生成時間戳并將帶有該時間戳的信息發送到第二節點集群；

第二節點集群，所述第二節點集群被配置為在接收到所述第一節點集群發送的信息之后，生成時間戳并將帶有該時間戳的信息發送到第三節點集群250；以及

第三節點集群，所述第三節點集群被配置為在接收到所述第二節點集群發送的信息之后，生成時間戳并將帶有該時間戳的信息發送到數據流檢測集群。

可選地，所述第一節點集群是數據收集器集群，所述第二節點集群是數據轉發器集群，以及所述第三節點集群是數據聚合器集群。

可選地，所述第一節點集群和所述第二節點集群進一步被配置為：無論信息發送成功或失敗，都通知所述數據流檢測集群。

可選地，所述第一節點集群和所述第二節點集群通過調用所述數據流檢測集群提供的遠程過程調用（RPC）服務來通知所述數據流檢測集群。

可選地，所述數據流檢測集群嘗試向所述第一節點集群發送信息多次。

附圖說明

通過下面結合附圖進行的描述，本發明一些示范性實施例的上述和其他方面、特征和優點對于本領域技術人員來說將變得顯而易見，其中：

圖1是圖示用于在分布式系統中進行檢測的方法的流程圖；以及

圖2是圖示根據本發明的用于在分布式系統中進行檢測的系統的框圖。

具體實施方式