dubbox源碼分析(一)-服務的啟動與初始化

来源:http://www.cnblogs.com/syjkfind/archive/2016/10/13/5957510.html
-Advertisement-
Play Games

程式猿成長之路少不了要學習和分析源碼的。最近難得能靜得下心來,就針對dubbox為目標開始進行源碼分析。 【服務提供方】 com.alibaba.dubbo.container.Main.main(args);dubbo.properties -> dubbo.container -> contai ...


程式猿成長之路少不了要學習和分析源碼的。最近難得能靜得下心來,就針對dubbox為目標開始進行源碼分析。

【服務提供方】

步驟 調用順序 備註
容器啟動

com.alibaba.dubbo.container.Main.main(args);
dubbo.properties -> dubbo.container -> container.start()
container -> spring, log4j, jetty...

[dubbo-container-spring] SpringContainer.java -> [服務提供方]classpath*:META-INF/spring/*.xml -> dubbo.xsd

spring的 ApplicationContext介紹

bean初始化

<dubbo:service>等自定義標簽 -> [dubbo-config-spring] DubboNamespaceHandler.java
 -> new DubboBeanDefinitionParser(ServiceBean.class, true)

spring對bean的初始化操作

[dubbo-config-spring] ServiceBean.java -> afterPropertiesSet()
-> setProvider(), setApplication(), setModule(), setRegistries, setMonitor(), setProtocols, setPath() -> export()

自定義標簽的解析和初始化
連接註冊中心

ServiceBean.export() -> ServiceConfig.java -> doExportUrlsFor1Protocol() -> 暴露協議protocol.export()

protocol=ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension()---Protocol$Adaptive.java
-> ExtensionLoader.loadExtensionClasses() -> loadFile()
-> META-INF/dubbo/internal/,META-INF/dubbo/,META-INF/services/
-> [舉例dubbo-rpc-api] 配置文件com.alibaba.dubbo.rpc.Protocol
-> filter,listener,mock -> 各類的export()

protocol.export()調用鏈 -> [dubbo-registry-api] RegistryProtocol.export()
-> getRegistry()---(ZookeeperRegistry.java -> 擴展的ZookeeperClient)
-> registry.subscribe()加入監聽列表

註冊到註冊中心,
並加入監聽列表監聽註冊中心的消息通知。
啟動協議伺服器 protocol.export()調用鏈 -> [dubbo-rpc-rest] RestProtocol.export()
-> doExport() -> server.start(), server.deploy()
根據相應協議啟動相應伺服器

【服務使用方】

步驟 調用順序 備註
容器啟動 參考服務提供方  同provider
bean初始化

<dubbo:reference>等自定義標簽 -> [dubbo-config-spring] DubboNamespaceHandler.java
-> new DubboBeanDefinitionParser(ReferenceBean.class, false)

 同provider
連接註冊中心

ReferenceBean.java -> afterPropertiesSet() -> ReferenceConfig.init() -> createProxy() -> refprotocol.refer()

refprotocol=ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension()---Protocol$Adaptive.java
-> ExtensionLoader.loadExtensionClasses() -> loadFile()
-> META-INF/dubbo/internal/,META-INF/dubbo/,META-INF/services/
-> [舉例dubbo-rpc-api] com.alibaba.dubbo.rpc.Protocol -> filter,listener,mock -> 各類的refer()

protocol.refer()調用鏈 -> [dubbo-registry-api] RegistryProtocol.refer()
-> getRegistry()---(ZookeeperRegistry.java -> 擴展的ZookeeperClient) -> doRefer()
-> RegistryDirectory.subscribe() -> registry.subscribe()

 同provider
服務介面初始化

ReferenceConfig.init() -> createProxy()
-> AbstractProxyFactory.getProxy() -> JavassistProxyFactory.getProxy()

service介面在實際運行時是 com.alibaba.dubbo.common.bytecode.Proxy 類的實例

 同provider

總結與收穫

很多細節由於時間關係沒有展開,比如重試機制,比如比較重要的類的整理。整個分析的過程還是很多收穫與啟發的。

比如url.putParameter()每次設置參數卻返回了一個新的對象,算是一種copyOnWrite的簡單實現。

又比如幾個比較重要的類都通過ExtensionLoader實現了動態擴展,可以理解為一種引擎或一種類載入器擴展,啟動時動態掃描@Adaptive註解和配置文件,所以各個模塊只要修改配置就可以實現filter, listener和mock的擴展。

再比如,典型的代理模式的應用,consumer都是通過反射生成服務介面的代理實例,實現遠程調用provider,而調用的協議都是可變可擴展的。觀察者模式就更隨處可見了。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 本來嘛,說好了要寫Selenium自動化搜電影的筆記的,然後正好今天上課無聊玩陰陽師開了個SSR,發現還有600體!準備怒刷之,但是又肝不動了。打算嘗試用Python寫個腳本來代替我自動點擊(PC端,安卓模擬器) 大家放心我沒寫出來 寫好在測試的時候,發現一到安卓模擬器就丟失焦點(也可能是點不了), ...
  • 密碼密文 passwd.py import getpass _username='sunny' password='000000' username=input("username:") password=getpass.getpass("password:") if _username == us ...
  • 閑來無事,寫了個swing界面,運行後看到當點擊按鈕時,中間文字會出現一個剛好把文字圍住的小方框,這是按鈕獲得焦點的標誌,我是覺得一個字:醜!怎麼去掉呢?萬能的度娘告訴我,設置下button的setFocusPainted為false,我試了一下,果然ok,下麵將代碼分享給大家,可以將設置屬性的那句 ...
  • I Hate It Time Limit: 9000/3000 MS (Java/Others) Memory Limit: 32768/32768 K (Java/Others)Total Submission(s): 66742 Accepted Submission(s): 25969 Pro ...
  • 【Python練習題 009】 列印出所有的“水仙花數”,所謂“水仙花數”是指一個三位數,其各位數字立方和等於該數本身。例如:153是一個“水仙花數”,因為153=1的三次方+5的三次方+3的三次方。 這題也是送分題,只要能把任意三位數的百位、十位、個位拆解出來就好辦了。思路:將任意3位數除以100 ...
  • 最近工作需要用到對硬碟進行shell腳本自動化分區和mount的操作,google了一些資料,下麵做個總結。 如果硬碟沒有進行分區(邏輯分區或者擴展分區,關於兩者概念,自行google),我們將無法將使用該硬碟來進行讀寫。我們要使用一塊硬碟需要進行下麵三步: 本筆記會著重講一下第一步中涉及的fdis ...
  • 記得兩年前實習的時候,繼哥說,一個程式員如果把一些範疇內的事情做得完美,其他人會少很多事情,包括測試,運維,方便自己,方便大家。。這次有機會將一個項目進行重構,併進行前後端分離,分析了一些需求和後期的規劃後,決定放棄以前“肥大”的springMVC那一套東西,採用近兩年越來越火的微服務架構試一試,當 ...
  • 【Python練習題 008】判斷101-200之間有多少個素數,並輸出所有素數。 這題算是送分題吧,據說解法很多。我的思路是:先建立101-200的整數列表,再進行判斷,如果某個數字能被“從2至這個數字前一位”整除,則將這個數字從列表剔除。挨個走一遍後,剩下的就都是素數了。代碼如下: 輸出結果如下 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...