本文主要基於 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
為唯一。
朋友會在“發現-看一看”看到你“在看”的內容