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

鏈路追蹤 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)

分享創造快樂