[發明專利]一種用于并行系統的監測方法

在審

• 申請號: 201410412938.4
• 申請日: 2014-08-21
• 公開（公告）號: CN104156299A
• 公開（公告）日: 2014-11-19
• 發明（設計）人: 王峰
• 申請（專利權）人: 江蘇惠居樂信息科技有限公司
• 主分類號: G06F11/32
• 分類號: G06F11/32
• 代理公司: 蘇州廣正知識產權代理有限公司 32234
• 代理人: 徐萍

技術領域

本發明涉及計算機的領域，尤其涉及一種用于并行系統的監測方法。

背景技術

在大數據分析等并行系統中，系統的穩定性、系統各個進程的運行狀態以及數據處理狀態一般很難進行計算與統計，這樣就不能實時知道整個并行系統的運行、處理情況，基于這種現狀，當發現并行系統出現問題時，往往已經造成了較嚴重的后果，尤其是基于實時大數據處理的并行系統而言，造成的損失更大。

發明內容

本發明主要解決的技術問題是提供一種用于并行系統的監測方法，在并行系統中增加一個監測進程，通過這個監測進程實時收集、監測并行系統中的各個進程的狀態，根據收集到的狀態對并行系統進行狀態統計，一旦發現并行系統中進程異常以及進程處理業務出現異常，馬上進行告警處理，把異常信息輸出到指定桌面系統，嚴重信息通過電話或短信直接通知到負責人，使得問題能夠得到及時發現，減少系統出現異常時帶來的損失，通過監測進程定時統計監測并進行告警，能夠實時掌握并行系統的進程狀態，對整個并行系統維護帶來方便。

為解決上述技術問題，本發明采用的一個技術方案是：提供了一種用于并行系統的監測方法，包括以下步驟：

a、在分布式主機部署監測進程，各個分布式進程啟動時，獲取分布式進程的唯一標識號；

b、分布式進程啟動時，向分布式主機中的監測進程注冊，分布式主機中的監測進程收到注冊信息后，把請求注冊信息與請求進程的主機IP地址對應起來保存在內存M中；

c、分布式主機中的監測進程定時輪詢M，向各個分布式進程發送握手信息，分布式進程收到握手信息后，把各自進程所在機器的情況信息反饋給分布式主機中的監測進程，監測進程統計收到的各個分布式進程的反饋信息，發現異常進行告警處理；

d、分布式進程向監測進程注冊成功后，動分布式進程與監測進程之間保活的心跳線程，定時向主機監測進程發送心跳消息，主機監測進程及時響應分布式進程的心跳消息，一旦心跳消息出現異常后，分布式進程定時向主機監測進程重新注冊，直到注冊成功。

在本發明一個較佳實施例中，所述的步驟a中唯一標識號的構成為：進程所在機器的MAC地址+進程名稱。

在本發明一個較佳實施例中，所述的步驟b中注冊信息的格式構成：進程唯一標識號&&進程類型。

在本發明一個較佳實施例中，所述的步驟c中的情況信息包括cpu利用率、進程占用內存大小以及進程空閑時間信息。

在本發明一個較佳實施例中，所述的步驟d中心跳消息出現異常的情況為連續3次沒有收到心跳消息的響應。

在本發明一個較佳實施例中，所述的監測方法采用雙輪詢機制。

本發明的有益效果是：本發明的用于并行系統的監測方法，在并行系統中增加一個監測進程，通過這個監測進程實時收集、監測并行系統中的各個進程的狀態，根據收集到的狀態對并行系統進行狀態統計，一旦發現并行系統中進程異常以及進程處理業務出現異常，馬上進行告警處理，把異常信息輸出到指定桌面系統，嚴重信息通過電話或短信直接通知到負責人，使得問題能夠得到及時發現，減少系統出現異常時帶來的損失，通過監測進程定時統計監測并進行告警，能夠實時掌握并行系統的進程狀態，對整個并行系統維護帶來方便。

附圖說明

為了更清楚地說明本發明實施例中的技術方案，下面將對實施例描述中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖僅僅是本發明的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其它的附圖，其中：

圖1?是本發明用于并行系統的監測方法的一較佳實施例的流程圖；

圖2?主機監測進程流程圖；

圖3分布式進程注冊與保活流程圖。

具體實施方式

下面將對本發明實施例中的技術方案進行清楚、完整地描述，顯然，所描述的實施例僅是本發明的一部分實施例，而不是全部的實施例。基于本發明中的實施例，本領域普通技術人員在沒有做出創造性勞動前提下所獲得的所有其它實施例，都屬于本發明保護的范圍。

如圖1至圖3所示，本發明實施例包括：

一種用于并行系統的監測方法，包括以下步驟：

a、在分布式主機部署監測進程，各個分布式進程啟動時，獲取分布式進程的唯一標識號；

b、分布式進程啟動時，向分布式主機中的監測進程注冊，分布式主機中的監測進程收到注冊信息后，把請求注冊信息與請求進程的主機IP地址對應起來保存在內存M中；