【正文】 通信，獲取應(yīng)用實例狀態(tài)信息。每個應(yīng)用實例含有一個或者多個HAWK Agent。 服務(wù)監(jiān)控模塊設(shè)計服務(wù)信息監(jiān)測模塊服務(wù)監(jiān)控主程序服務(wù)控制模塊基礎(chǔ)功能模塊日志模塊 線程管理模塊R V 消息收發(fā)模塊H A W K 應(yīng)用模塊配置項讀取模塊程序終止資源釋放初始化資源創(chuàng)建服務(wù)調(diào)用信息獲取模塊服務(wù)自動監(jiān)控模塊數(shù)據(jù)庫操作管理模塊服務(wù)調(diào)用信息存儲模塊服務(wù)狀態(tài)信息獲取模塊圖 4 服務(wù)監(jiān)控模塊層次結(jié)構(gòu)圖? 服務(wù)監(jiān)控程序主線程負(fù)責(zé)讀取配置項，初始化創(chuàng)建資源，結(jié)束程序釋放資源。? 服務(wù)監(jiān)控程序執(zhí)行兩個主要的工作任務(wù)：獲取服務(wù)調(diào)用信息并存庫，獲取服務(wù)狀態(tài)信息根據(jù)預(yù)定義策略進(jìn)行服務(wù)控制。各個任務(wù)由預(yù)先配置的一個或者多個線程運行。? 使用 HAWK 來獲取服務(wù)運行狀態(tài)信息和控制服務(wù)運行。? 服務(wù)的調(diào)用信息使用消息機(jī)制，調(diào)用信息按定義的格式序列化和反序列化。 服務(wù)信息監(jiān)測模塊服務(wù)內(nèi)部流程的實現(xiàn)如圖 6 所示。記錄服務(wù)接口調(diào)用執(zhí)行的相關(guān)信息，以26 / 38消息的形式發(fā)送到消息中間件的隊列上。服務(wù)信息監(jiān)控程序循環(huán)地從隊列上接收這些消息。隊列的默認(rèn)名稱為：Application instance name.Invokation record。圖 5 服務(wù)內(nèi)部發(fā)送服務(wù)信息示意圖承載服務(wù)調(diào)用執(zhí)行相關(guān)信息支持復(fù)雜類型，調(diào)用信息的類型定義如下：圖 6 服務(wù)調(diào)用執(zhí)行信息類型定義如果需要記錄服務(wù)調(diào)用的輸入和輸出，可以按以下的序列化格式，將各種不同類型的輸入數(shù)據(jù)和輸出數(shù)據(jù)序列化為字符串。表 2 服務(wù)調(diào)用報文結(jié)構(gòu)序號 命名 參數(shù)類型 說明 約束條件 是否必輸1instancename STRING 服務(wù)流程號 參見編碼規(guī)則Y2 starttime DATETIME 流程開始時間 Y27 / 383 endtime DATETIME 流程結(jié)束時間 Y4inovker STRING 系統(tǒng)調(diào)用方 參見編碼規(guī)則Y5 input STRING 服務(wù)調(diào)用的輸入 N6 output STRING 服務(wù)調(diào)用的輸出 N7success STRING 服務(wù)調(diào)用是否成功 1/成功 9/失敗Y8 errorcode STRING 服務(wù)調(diào)用發(fā)生異常時的異常碼N服務(wù)監(jiān)控程序接收到消息后，將消息內(nèi)容讀取處理并插入數(shù)據(jù)庫中對應(yīng)的表中。在上文中提到每個應(yīng)用實例中所有服務(wù)實例的調(diào)用記錄存放在一個表中。表名為： SERVICEINVOKE。同時將服務(wù)實例的一部分調(diào)用記錄信息記錄在內(nèi)存里，供服務(wù)控制使用。 服務(wù)控制模塊服務(wù)監(jiān)控程序執(zhí)行三種控制策略的服務(wù)控制操作。程序使用 HAWK API循環(huán)獲取服務(wù)實例的狀態(tài)信息，同時使用在內(nèi)存中的服務(wù)調(diào)用記錄信息，來進(jìn)行狀態(tài)判斷，執(zhí)行相應(yīng)的控制操作。 —服務(wù)宕機(jī)監(jiān)測服務(wù)運行狀態(tài)，當(dāng)發(fā)現(xiàn)服務(wù)宕機(jī)時，通知運維人員或者自動重啟服務(wù)。每個應(yīng)用實例都有一個 HAWK Agent，當(dāng)服務(wù)監(jiān)控程序通過 HAWK API 連接一個 HAWK Agent 失敗，就可知道該 HAWK Agent 對應(yīng)的服務(wù)應(yīng)用已經(jīng)宕機(jī)。28 / 38—服務(wù)調(diào)用失敗統(tǒng)計服務(wù)調(diào)用處理成功失敗次數(shù)，當(dāng)最近一段時間內(nèi)(比如最近 1 小時內(nèi))失敗次數(shù)占總次數(shù)的百分比超過控制策略中的設(shè)置值時，通知運維人員。服務(wù)監(jiān)控程序在內(nèi)存中保存每個服務(wù)實例的服務(wù)調(diào)用成功與失敗的次數(shù)，程序循環(huán)進(jìn)行判斷。 —服務(wù)負(fù)載過大根據(jù)服務(wù)實例當(dāng)前的排隊請求數(shù)，歷史平均單次處理時間，最近 1 分鐘或者 5 分鐘的服務(wù)請求數(shù)來判斷服務(wù)是否負(fù)載過大。通知運維人員，同時把該服務(wù)忙的信息以主題消息的形式發(fā)布出去。服務(wù)調(diào)用者可以主動訂閱服務(wù)狀態(tài)事件消息，調(diào)整服務(wù)調(diào)用的時機(jī)和頻率；或者服務(wù)應(yīng)用實例訂閱服務(wù)狀態(tài)事件消息后，按既定的服務(wù)調(diào)用規(guī)范，服務(wù)直接給服務(wù)調(diào)用方返回服務(wù)忙的應(yīng)答。判斷負(fù)載過大策略規(guī)則如下：(1)IF (排隊請求數(shù) 排隊請求數(shù)閥值) THEN {IF(最近 1 分鐘或者 5 分鐘的服務(wù)請求數(shù) 0 ) THEN 服務(wù)負(fù)載過大。ELSE IF(排隊請求數(shù) *歷史平均單次處理時間 =1 分鐘或者 5 分鐘) THEN 服務(wù)負(fù)載過大。ELSE 服務(wù)負(fù)載正常。 }(2)IF(最近 1 分鐘或者 5 分鐘的服務(wù)請求數(shù) 服務(wù)請求數(shù)閥值)THEN { IF (排隊請求數(shù) 0) THEN { IF(最近 1 分鐘或者 5 分鐘的服務(wù)請求數(shù)*歷史平均單次處理時間 =1 分鐘或者 5 分鐘) THEN 服務(wù)負(fù)載過大。 ELSE 服務(wù)負(fù)載正常。 } ELSE 服務(wù)負(fù)載正常。 }服務(wù)監(jiān)控程序在內(nèi)存中保存每個服務(wù)實例的最近一段時間的服務(wù)調(diào)用請求29 / 38次數(shù)，同時程序循環(huán)更新每個服務(wù)實例的當(dāng)前排隊請求數(shù)，來進(jìn)行服務(wù)負(fù)載是否過大的判斷。 服務(wù)監(jiān)控主程序服務(wù)監(jiān)控主程序使用 BW 實現(xiàn), 主要邏輯使用 Java 程序?qū)崿F(xiàn)。(1) —domain1,domian2,domain3(2) (3) (4) (5) (6) (7) (8) 30 / 38 一 一 一 一 一 一一 一 一 一 一 一 一 一 一 一 一一 一 一一 一 一 一 一 一 一 一 一 一 一一 一 一 一 一一 一 一 一 一 一 一 一 一 一 一一 一 一 一 一 一一 一 一 一 一 一 一 一 一 一 一一 一 一 一 一 一 一 一 一 一 一一 一 一 一 一一 一 一 一 一 一 一 一一 一 一 HAWK一 一 一 一 一一 一 一 一 一 一 一 一 HAWK Agent一 一 一 一 一 一 一 一 一 一 一一一 一 一 一 一 一 一 一一 一 一 一 一 一一 一 一 一 一 一圖 7 服務(wù)監(jiān)控程序主流程圖 服務(wù)監(jiān)控任務(wù)主程序創(chuàng)建多個線程來運行工作任務(wù)。工作任務(wù)有兩個：服務(wù)調(diào)用信息接收存儲任務(wù)和服務(wù)控制任務(wù)。31 / 38 一 一 一 一一 一 一 一 一 一 一 一 一 一 一一一 一 一 一 一 一 一 一 一 一 一圖 8 服務(wù)調(diào)用信息接收存儲流程圖服務(wù)調(diào)用信息獲取任務(wù)循環(huán)判斷程序是否關(guān)閉，如果沒有關(guān)閉，則從消息中間件上接收服務(wù)調(diào)用消息，更新內(nèi)存中服務(wù)實例的相關(guān)信息，然后將調(diào)用信息寫入數(shù)據(jù)庫的相應(yīng)表單。32 / 38 一 一 一 一 一 一 一 一 一 一 一一 一 一一 一 一 一 一 一一 一 一 一 一 一 一 一 一圖 9 服務(wù)控制流程圖服務(wù)控制任務(wù)循環(huán)判斷程序是否關(guān)閉，如果沒有關(guān)閉，根據(jù)內(nèi)存中應(yīng)用實例和服務(wù)實例的狀態(tài)信息，判斷是否符合服務(wù)控制策略的條件，滿足條件時通知運維人員，并做相應(yīng)的服務(wù)控制操作。 服務(wù)監(jiān)控基礎(chǔ)功能模塊基礎(chǔ)功能模塊包括配置文件讀取，日志，線程創(chuàng)建管理，Hawk 訪問，消息收發(fā)，數(shù)據(jù)庫操作六個模塊。 服務(wù)接口規(guī)范 服務(wù)處理成功失敗定義規(guī)范對于封裝已有業(yè)務(wù)應(yīng)用的服務(wù)，接口調(diào)用層次如下(1) 業(yè)務(wù)應(yīng)用的接口，在服務(wù)內(nèi)部被調(diào)用。33 / 38(2) 服務(wù)對外提供的接口，由服務(wù)調(diào)用者調(diào)用。服務(wù)封裝已有應(yīng)用，提供一定的功能。從功能是否可用這個角度，定義服務(wù)接口調(diào)用返回值類別如下：(1) 正常結(jié)果：服務(wù)提供的功能可用，返回業(yè)務(wù)層的正常結(jié)果。(2) 異常結(jié)果：服務(wù)提供的功能可用，但返回業(yè)務(wù)層異常結(jié)果。如輸入值超出范圍。(3) 錯誤：服務(wù)提供的功能不可用，返回服務(wù)錯誤結(jié)果。如已有業(yè)務(wù)應(yīng)用不可連接，調(diào)用已有業(yè)務(wù)應(yīng)用接口超時，服務(wù)忙等。服務(wù)調(diào)用成功定義：調(diào)用服務(wù)接口返回值為以上定義的正常結(jié)果或異常結(jié)果。服務(wù)調(diào)用失敗定義：調(diào)用服務(wù)接口返回值為以上定義的錯誤結(jié)果。服務(wù)調(diào)用成功失敗次數(shù)統(tǒng)計即在一定的服務(wù)調(diào)用次數(shù)范圍內(nèi)，區(qū)別服務(wù)功能可用時的調(diào)用次數(shù)和服務(wù)功能不可用時的調(diào)用次數(shù)。 服務(wù)調(diào)用方規(guī)范服務(wù)調(diào)用請求里需要包含調(diào)用方應(yīng)用系統(tǒng)名。 服務(wù)流量控制規(guī)范服務(wù)負(fù)載過大的事件會在整個系統(tǒng)中發(fā)布，服務(wù)調(diào)用方可以直接接收該信息。同時服務(wù)提供方也會在服務(wù)調(diào)用應(yīng)答里添加服務(wù)負(fù)載過大的輸出項，輸出項包含在 SOAPFault 標(biāo)簽中，服務(wù)調(diào)用方收到此應(yīng)答后，應(yīng)該主動暫停發(fā)送服務(wù)請求。 服務(wù)實現(xiàn)規(guī)范 服務(wù)調(diào)用信息規(guī)范服務(wù)實現(xiàn)內(nèi)部需要記錄服務(wù)調(diào)用處理開始時間，結(jié)束時間，服務(wù)調(diào)用是否成功，調(diào)用輸入輸出等內(nèi)容，在調(diào)用處理結(jié)束后，將此信息以消息的形式發(fā)送給服務(wù)監(jiān)控程序。34 / 38 服務(wù)調(diào)用信息消息規(guī)范服務(wù)調(diào)用信息按定義的格式構(gòu)造成消息。其中調(diào)用輸入，輸出數(shù)據(jù)按定義的格式序列化為字符串。服務(wù)調(diào)用輸入輸出數(shù)據(jù)序列化格式定義：Message Body := {[Field Value。]*}Field value := Scale type value|nested valueScale type value := Integer|Decimal|Char|String|Date|DateTime|TimeNested value := Array value|Class valueArray value := {[Array item。]*}Array item := Scale type value|nested valueClass value := {[Field value。]*}SID := [09]|([19][09]*) . 123456Integer := [+|]?([09]|([19][09]*)) . 123456 +123456 123456Decimal := Integer(.[09]*)? . 123. 123Char := A UNICODE 16 char with UTF8 encoding . 39。A39。 39。中39。 // 假如字符為39。\39。, 39。{39。, 39。39。, 39。}39。，則在前面加上 39。\39。轉(zhuǎn)義String := Char* . A 中39。Date := YYYYMMDD . 20220507 20221211Time := HHmmSS(.SSS)? . 121109DateTime := Date Time . 20220507 35 / 386 編碼規(guī)則 服務(wù)流程調(diào)用號服務(wù)流程調(diào)用號的編碼規(guī)則是：XXXXYYYYZZZZ ，其中第一組四位字符代表監(jiān)控域，第二組四位字符代表服務(wù)應(yīng)用，第三組四位字符代表該服務(wù)應(yīng)用下的服務(wù)。 系統(tǒng)調(diào)用方 應(yīng)用系統(tǒng)模塊中，系統(tǒng)調(diào)用方的編碼規(guī)則是：AAABBB999,其中第一組三位字母代表主系統(tǒng)代碼，第二組三位字母代表子系統(tǒng)代碼，第三組三位數(shù)字代表系統(tǒng)的流水碼。36 / 387 系統(tǒng)安全性和出錯處理設(shè)計 安全性ESB 平臺監(jiān)控系統(tǒng)只是在內(nèi)網(wǎng)運行，并且監(jiān)控系統(tǒng)不會對在 ESB 平臺運行的程序產(chǎn)生實質(zhì)性的影響，所以監(jiān)控系統(tǒng)采用的是用戶名+密碼驗證的方式保證系統(tǒng)的安全。 出錯處理 如果被監(jiān)控的服務(wù)實例發(fā)生異常，會通過郵件的方式發(fā)送給運維人員。37 / 388 參考文檔 Hawk 介紹Hawk 是一個用于監(jiān)控分布式應(yīng)用和操作系統(tǒng)的工具，Hawk 與各監(jiān)控參與方通過 TIBCO 消息機(jī)制進(jìn)行通信。HAWK 作為 ESB 平臺的監(jiān)控工具，能對ESB 平臺進(jìn)行一定程度的監(jiān)控，但是不能滿足 ESB 平臺服務(wù)監(jiān)控的全部需求，而本系統(tǒng)使用 HAWK 和其他定制化程序?qū)崿F(xiàn) ESB 平臺服務(wù)監(jiān)控需求。傳統(tǒng)的監(jiān)控架構(gòu)，采用集中式的單一控制臺管理模式，高度依賴于輪詢，因此占用了大量的網(wǎng)絡(luò)帶寬并且影響了系統(tǒng)的執(zhí)行效率，同時無法對分布式的應(yīng)用進(jìn)行監(jiān)控管理。Hawk 是一種分布式的、自治的和基于規(guī)則的智能代理。Hawk 像一個管理者分布到每一個節(jié)點上，基于事件的觸發(fā)產(chǎn)生消息，不需要進(jìn)行輪詢，不需要中央控制臺，占用較少的網(wǎng)絡(luò)帶寬和系統(tǒng)資源。圖 10 Hawk 架構(gòu)運行在各個物理服務(wù)器上的 Hawk 代理獲得被監(jiān)控對象的信息，通過 TIBCO 消息總線以位置透明和分布式方式將監(jiān)控信息發(fā)送到監(jiān)控管理端。同時 Hawk 提供了控制調(diào)用功能(Invoke)，對服務(wù)的狀態(tài)信息進(jìn)行實時獲取，甚至可以對服務(wù)的運行發(fā)布控制指令。