歡迎光臨
每天分享高質量文章

鏈路追蹤 SkyWalking 原始碼分析 —— Collector Jetty Server Manager

本文主要基於 SkyWalking 3.2.6 正式版

  • 1. 概述
  • 2. JettyManagerModule
  • 3. JettyManagerProvider
  • 4. JettyManagerService
  • 666. 彩蛋

1. 概述

本文主要分享 Collector Jetty Server Manager。Collector 透過該管理器,管理啟動的多個 Jetty Server,例如 Agent Jetty Server、Naming Jetty Server、UI Jetty Server。

友情提示:建議胖友已經讀過 《SkyWalking 原始碼分析 —— Collector Server Component 伺服器元件》

Jetty Server Manager 在 SkyWalking 架構圖處於如下位置( 紅框 ) :

FROM https://github.com/apache/incubating-skywalking

下麵我們來看看整體的專案結構,如下圖所示 :

? 程式碼量非常少,考慮到這是個單獨的專案,所以單獨成文。

2. JettyManagerModule

org.skywalking.apm.collector.jetty.manager.JettyManagerModule ,實現 Module 抽象類,Jetty 管理器 Module 。

#name() 實現方法,傳回模組名為 "jetty_manager" 。

#services() 實現方法,傳回 Service 類名:JettyManagerService 。

3. JettyManagerProvider

org.skywalking.apm.collector.jetty.manager.JettyManagerProvider ,實現 ModuleProvider 抽象類,Jetty 管理器元件服務提供者。

#name() 實現方法,傳回元件服務提供者名為 "jetty" 。

module() 實現方法,傳回元件類為 JettyManagerModule 。

#requiredModules() 實現方法,傳回依賴元件為空。


#prepare(Properties) 實現方法,執行準備階段邏輯。

  • 第 55 行 :建立 JettyManagerServiceImpl 物件,並呼叫 #registerServiceImplementation(…) 父類方法,註冊到 services 。

#start() 實現方法,執行啟動階段邏輯。目前是個空方法

#notifyAfterCompleted() 實現方法,執行啟動完成邏輯。

  • 第 63 至 69 行 :遍歷註冊的伺服器串列,逐個呼叫 JettyServer#start() 方法,進行啟動。

4. JettyManagerService

org.skywalking.apm.collector.jetty.manager.service.JettyManagerService ,繼承 Service 介面,Jetty 管理器服務介面

#createIfAbsent(host, port, contextPath) 介面方法,建立 Jetty Server ,若不存在。

#addHandler(host, port, serverHandler) 介面方法,新增 Jetty Server 請求處理器。

4.1 JettyManagerServiceImpl

org.skywalking.apm.collector.jetty.manager.service.JettyManagerServiceImpl ,Jetty 管理器服務實現類

構造方法 ,使用來自 JettyManagerProvider 的 servers 伺服器陣列。這是為什麼 JettyManagerProvider 沒有對 servers 做新增操作,結果裡面有資料的原因

#createIfAbsent(host, port, contextPath) 實現方法,建立 Jetty Server ,若不存在。判斷方式為 host + port 為唯一。

#addHandler(host, port, serverHandler) 實現方法,新增 Jetty Server 請求處理器。判斷方式為 host + port 為唯一。

已同步到看一看
贊(0)

分享創造快樂