當前位置:首頁 » 編程軟體 » dubbo源碼編譯

dubbo源碼編譯

發布時間: 2023-06-07 06:12:03

⑴ Dubbo啟動源碼解析一

這次講 bbo-spring-boot-starter 啟動方式,所以入口就是Spring的SPI機制;
首先在META-INF/spring.factories配置下,配置了org.apache.bbo.spring.boot.autoconfigure.DubboAutoConfiguration類,在啟動時,則會把DubboAutoConfiguration類注冊到spring容器中;
我們來看下DubboAutoConfiguration
先看啟動流程

我們先看下生產者端的啟動流程,首先是在Spring中注冊類

該類實現了介面,則在Spring容器初始化時,會調用方法

我們會看到,這個時候會去注冊類,這個類我們等流程到了在分析,我們先按啟動流程看過去;resolvePackagesToScan方法先獲取到需要掃描的包 ,然後再調用registerServiceBeans去注冊相關實例,我們重點來看下registerServiceBeans方法

接下來,我們主要去看下registerServiceBean方法

接下來,我們來看下buildServiceBeanDefinition方法

到這,ServiceBean注冊成功,ServiceBean類很重要,每個Dubbo service實例都對應一個ServiceBean,相關配置都在ServiceBean中;我們再回到開始注冊的類

類繼承了,實現了ApplicationListener,主要監聽了Spring容器生命周期,我們看下onApplicationContextEvent方法

我們可以看到,當Spring容器啟動成功時,會調用bboBootstrap.start();

接下來,主要邏輯在ServiceBean中,這個export方法在其父類ServiceConfig中,我們下一篇主要講ServiceConfig邏輯;

⑵ Dubbo之服務導出源碼分析

要了解服務導出做了什麼,需要了解導出的目的是什麼?
bbo是一款面向介面代理的高性能RPC調用,說白了就是提供遠程服務。

服務導出需要做的:簡單說就是根據服務參數、服務協議構建服務URL,注冊到注冊中心,並啟動Server。其中服務參數可以動態配置也需要監聽。

1、onApplicationEvent
org.apache.bbo.config.spring.ServiceBean#onApplicationEvent
發布ContextRefreshedEvent,進行導出服務

2、export
org.apache.bbo.config.spring.ServiceBean#export
調用父類ServiceConfig導出,之後發布一個ServiceBeanExportedEvent

②、shouldExport檢查服務是否需要導出
org.apache.bbo.config.ServiceConfig#shouldExport

org.apache.bbo.config.ServiceConfig#checkAndUpdateSubConfigs

1、completeCompoundConfigs
ServiceConfig中的某些屬性如果是空的,那麼就從ProviderConfig、MoleConfig、ApplicationConfig中獲取
①、如果配置了ProviderConfig provider,如果application、mole、registries、monitor、protocols、configCenter這些屬性為空的情況下,可以從provider中獲取信息並賦值

③、如果ApplicationConfig application不為空,可以為registries、monitor為空的賦值
2、startConfigCenter
從配置中心獲取配置,包括應用配置和全局配置

SystemConfiguration:是系統環境變數,可以在服務啟動時通過-D指定參數
AbstractConfig:是通過@Service註解配置的參數
PropertiesConfiguration:是bbo.properties文件配置的
AppExternalConfiguration和ExternalConfiguration:是在配置中心Dubbo-Admin中配置的,AppXxx是應用級別
配置優先順序是:SystemConfiguration -> AppExternalConfiguration -> ExternalConfiguration -> AbstractConfig -> PropertiesConfiguration
如果放到第二個位置優先順序是:SystemConfiguration -->AbstractConfig -> AppExternalConfiguration -> ExternalConfiguration -> -> PropertiesConfiguration
c、根據setXX()方法和setParameters()方法進行參數值覆蓋

②、prepareEnvironment
管理台上的動態配置中心,如果是zookeeper,獲取的就是/bbo/config/bbo/bbo.properties節點中的內容。如果是應用級別的則獲取的就是/bbo/config/bbo-demo-consumer-application/bbo.properties節點中的內容(bbo-demo-consumer-application應用名,這里是以bbo-demo為例)

4、checkProtocol 從配置中心設置Protocol配置

10、Local、Stub、Mock
local和stub一樣,不建議使用了。如果Local存根為true,則存根類為interfaceName + "Local"。如果Stub本地存根為true,則存根類為interfaceName + "Stub"

org.apache.bbo.config.ServiceConfig#doExport

unexported表示:當前服務已經被取消了,就不需要再導出了
exported表示:已經導出了,就不再重復導出了
1、doExportUrls
org.apache.bbo.config.ServiceConfig#doExportUrls

②、遍歷protocols協議
pathKey = group/應用名/path服務名:version
例如:mygroup/bbo-demo/org.apache.bbo.demo.DemoService:1.0.1
ProviderMethodModel表示某一個方法、方法名所屬的服務的,包含實現類,介面,以及介面中的各個方法

ApplicationModel表示應用中有哪些服務提供者和引用了哪些服務
每種協議都會導出一個單獨的服務,並注冊到各個注冊中心
2、doExportUrlsFor1Protocol
org.apache.bbo.config.ServiceConfig#doExportUrlsFor1Protocol

③、methods方法參數處理

⑦、scope導出方式(scope=null進行遠程導出)

生成的注冊服務URL是在registryURL和export參數是服務url的拼裝
b、也表示服務提供者,包括了Invoker和服務的配置。是對Invoker的包裹
c、protocol.export(wrapperInvoker)這是導出的核心,使用了SPI。
使用特定的協議來對服務進行導出,這里的協議是registry,導出成功後得到一個Exporter
由於注冊地址也是服務,所以會先使用RegistryProtocol進行服務注冊(服務導出),然後注冊(服務導出)完了之後,再使用DubboProtocol進行導出
自適應SPI會獲取url
org.apache.bbo.config.invoker.#getUrl

⑩、當存在注冊中心時,是先使用Registy協議注冊服務,然後在使用Http協議導出服務。而沒有注冊中心時,是直接使用Http協議導出服務。根據服務url,講服務的元信息存入元數據中心MetadataReportService

RegistryProtocol被ProtocolFilterWrapper包裹,ProtocolFilterWrapper被ProtocolListenerWrapper包裹(SPI原理)

1、export
org.apache.bbo.rpc.protocol.ProtocolListenerWrapper#export
如果協議是REGISTRY_PROTOCOL(registry)則會直接走到下一個protocol實現類ProtocolFilterWrapper。
如果不是則會使用ListenerExporterWrapper處理

②、獲取providerUrl 服務提供者url

③、生成overrideSubscribeUrl,與監聽有關
在服務提供者url的基礎上,生成一個overrideSubscribeUrl,協議為provider://,增加參數category=configurators&check=false
overrideSubscribeUrl是用來對動態配置監聽的,需要監聽的服務和監聽的類型(configurators, 老版本)
一個overrideSubscribeUrl對應一個OverrideListener,用來監聽overrideSubscribeUrl變化事件

④、doLocalExport導出
此時服務協議是bbo,DubboProtocol被ProtocolFilterWrapper包裹,ProtocolFilterWrapper被ProtocolListenerWrapper包裹

1、export
org.apache.bbo.rpc.protocol.ProtocolListenerWrapper#export
返回結果被ListenerExporterWrapper包裹

2、export
org.apache.bbo.rpc.protocol.ProtocolFilterWrapper#export

EchoFilter、ClassLoaderFilter、GenericFilter、ContextFilter、TraceFilter、TimeoutFilter、MonitorFilter、ExceptionFilter
返回包裹了Filter的CallbackRegistrationInvoker
3、export
org.apache.bbo.rpc.protocol.bbo.DubboProtocol#export

②、register
org.apache.bbo.registry.support.FailbackRegistry#register

在服務導出過程中,需要對動態配置中心的數據進行監聽。如果發生更改,可以及時做出反映。
這里用到了Zookeeper的Watcher機制。
1、配置中心的路徑與動態配置路徑是不相同的,這里需要區分開來
配置中心的路徑是:
①、應用:/bbo/config/bbo/org.apache.bbo.demo.DemoService/bbo.properties節點的內容
②、全局:/bbo/config/bbo/bbo.properties節點的內容
2、對於動態配置的監聽有版本的差別
在2.7之前,只可以對單個服務進行監聽,不可以對應用監聽
/bbo/org.apache.bbo.demo.DemoService/configurators/* 只對路徑名字監聽,不監聽內容
在2.7之後,服務和應用都可以監聽
服務: /bbo/config/bbo/org.apache.bbo.demo.DemoService.configurators 節點的內容
應用: /bbo/config/bbo/bbo-demo-provider-application.configurators 節點的內容
3、監聽時機RegistryProtocol#export
org.apache.bbo.registry.integration.RegistryProtocol#export

⑶ Dubbo(一)——Dubbo 集成於 Spring 的原理

最近一直在看bbo的源碼部分。在閱讀的時候,需要有一個入手點,才能一點一點的進行下去。自己在研究的時候,發現思緒比較亂,於是就以 芋道源碼 為基礎,一點一點的啃食。芋道源碼是直接從bbo的配置和一些核心的API開始講起,是從bbo已經啟動的過程作為開始節點,而這些核心 API 與 Spring 的之間的關系被省略了,這些東西對我來說屬於前置的知識點,所以花了比較長的時間又從 Dubbo 的核心 API 倒著往前看。

在閱讀 Dubbo 時,發現前置知識越來越多,如:Spring 的 refresh 中的一些核心點,Spring 中 bean 的生命周期,BeanFactory 與 FactoryBean 的區別等。所以這些前置知識花了特別多的時間去補。所幸,雖然補前置知識雖然時間長,但是性價比還是可以的。Dubbo 是依賴於Spring 的上下文環境的框架,其他依賴於 Spring 的框架也是相同的道理。Spring 的一些對外的擴展點,讀過之後也會心中有數。

1、本篇主要是描述了 Dubbo 在 Spring 創建上下文的時候,是如何從創建,到能完整提供一個RPC調用能力的一些相關點。
2、由於源碼比較多,直接貼斷點也太過臃腫,所以僅僅貼一些關鍵點來概括整個流程。
3、本文是依賴於前面的 bbo 項目進行斷點分析,項目結構可以參照這里。項目中 bbo 的配置方式是 xml 文件,所以本篇主要說 xml 配置方式。其他方式道理相同,並不是問題的關鍵點。

4、項目啟動的是 bbo-user 服務,所以 UserService 為 bbo:service,OrderService 為 bbo:reference。

下圖為Spring 啟動時是如何載入 Dubbo 的,其中省略了大量過程,只保留了一些關鍵節點,省略的部分可以略微腦補一下。

整個流程的入口是 Spring 的 refresh 方法。每個方法都有比較深的調用棧。與 Dubbo 有關的入口是 refresh 中的 方法

這個方法是執行 beanFactory 的一些後處理操作,其核心流程為在Spring容器中找出實現了BeanFactoryPostProcessor介面的processor並執行。Spring容器會委託給的方法執行。
是比較核心的類,在這里我們關注一下這個類。它的作用是對項目中配置的類進行處理。具體處理可以分為幾步:

在載入類信息時,spring 會去用各種方式掃到注冊的 bean 信息。我們在 spring 中注冊的 bean,逃不出這個方法的掃描方式。 核心方法是:

掃描之後,會將掃描到的 bean 注冊到 beanDefinitionMap 中

首先是此處 org.springframework.beans.factory.xml.#parseBeanDefinitions,可以看出方法會以配置文件根節點起,遍歷所有子節點。

其次是這里 org.springframework.beans.factory.xml.BeanDefinitionParserDelegate#parseCustomElement(org.w3c.dom.Element, org.springframework.beans.factory.config.BeanDefinition), 此方法會通過解析出來的節點,獲取對應的 Spring 的 namespaceUri ,進而獲取對應的配置文件處理器。
此處 ele 參數實際值為 <bbo:service ... />,namespaceUri 為 http://code.alibabatech.com/schema/bbo

我們看一下 resolve 方法中的細節。因為這個方法內部才是 Dubbo 依賴於 Spring 的關鍵點。

此處的 NamespaceHandler 為 DubboNamespaceHandler,再創建結束之後,進行 init 初始化。

可以看到,DubboNamespaceHandler 在初始化的時候,會創建所有 bbo 標簽對應的Config 類的 DubboBeanDefinitionParser。並將 DubboBeanDefinitionParser 和 對應的 bbo 標簽類注冊到 NamespaceHandlerSupport 的 parsers 中。

最後,會在 com.alibaba.bbo.config.spring.schema.DubboBeanDefinitionParser#parse(org.w3c.dom.Element, org.springframework.beans.factory.xml.ParserContext, java.lang.Class<?>, boolean) 方法中進行處理

Dubbo 服務比較特殊,beanDefinition 跟普通的 bean 不太一樣。在向 beanDefinitionMap 注冊時,普通的 beanDefinition 的 beanName 與 beanClass 是對應的;而 bbo 服務的 beanDefinition 的 beanName 是bbo 服務的名稱,beanClass 為 bbo 對應的 Bean。

普通的 beanDefinition:

bbo 引用的服務的 beanDefinition:

這一步的核心流程是從 beanFactory 中獲取所有的 ApplicationListener,然後注冊到監聽器集合中。它的關鍵點其實是 ServiceBean。因為 ServiceBean 是 ApplicationListener 的實現。

所以 beanFactory 中 ServiceBean 也會被注冊到監聽器集合中。項目中的 ServiceBean 的 beanClass 實際是 UserService。

這一步的核心點,主要是創建剩餘的各類對象,並將其保存到 singletonObjects 中。其中關聯的前置知識為 Spring 中 bean 的生命周期 。它的核心方法是:
org.springframework.beans.factory.support.#doCreateBean

它的具體流程為:

ps:此處並不是只有這一步才會跟 bean 生命周期相關,bean 生命周期貫穿在 refresh 的很多流程中,只要執行doGetBean 方法,都會走這個流程。此處僅僅借樓關聯一下。

這一步的核心點,是通知所有的監聽器上下文刷新結束的事件。在這一步執行時,會通知到 ServiceBean。

此處暴露的是 UserService。

Dubbo 的啟動條件是完全依賴於 Spring 的啟動流程,Spring 的啟動流程中核心的點是 refresh 方法。所以只要搞懂 refresh 方法,其他的拓展框架流程也會明白。只不過關聯的知識點太多了,還是需要時間的積累才能一點一點的搞懂。
如果本篇有描述不清,或者描述有誤的地方,還望在下方留言,大家一起交流,一起學習,一起進步~

⑷ 【bbo源碼】13. 服務消費方之@Reference依賴注入原理

用法 :

當某個主要注冊到spring容器中的bean 的屬性上有@Reference註解時,並且 註解的injvm = false時(默認),表明該屬性會被注入一個遠程介面實例,用作rpc遠程調用。

@Reference不是派生自spring默認支持的@Resource和@Autowired,那麼說明spring是不支持該註解用於依賴注入的,bbo對此進行了支持該注冊的拓展。

在入口@EnableDubbo配置了掃描的包路徑
用於掃描類上含有bbo@Service 和類屬性上含有 @Reference 的bean

@DubboComponentScan 導入了DubboComponentScanRegistrar

DubboComponentScanRegistrar實現Spring的ImportBeanDefinitionRegistrar介面,被調用到實現的registerBeanDefinitions()時,會注冊兩個beanPostProcessor類

實現了和spring中支持@Autowired注冊的一模一樣的介面 :,繼承了。兩者的工作邏輯幾乎一模一樣。

在bean實例化之後,對 bean進行依賴注入

postProcessPropertyValues()

這個方法每個bean實例化都會調到,用的是父類的

判斷方法和類上是否有@Reference註解,並將其包包裝成.AnnotatedInjectionMetadata 對象,進行緩存

判斷屬性是否可以獲取到@Reference,獲取到返回

收集到需要依賴注入的屬性之後,下一步獲取到被依賴的bean實例,進行反射賦值

調用內部類AnnotatedFieldElement中的inject方法

獲取到bbo創建的代理實例,反射設置有@Reference的屬性上

熱點內容
我的世界伺服器崩了重啟 發布:2025-05-14 16:09:37 瀏覽:44
android深拷貝 發布:2025-05-14 16:09:35 瀏覽:153
cf電腦版轉伺服器神器還在嗎 發布:2025-05-14 16:09:02 瀏覽:211
百度文庫伺服器如何搭建 發布:2025-05-14 16:09:00 瀏覽:248
安卓微信刪除的好友怎麼找回 發布:2025-05-14 16:08:56 瀏覽:706
iphone的訪問限制密碼忘記了怎麼辦 發布:2025-05-14 16:08:56 瀏覽:184
php對象轉換成數組 發布:2025-05-14 16:07:55 瀏覽:27
java服務端緩存 發布:2025-05-14 15:53:37 瀏覽:105
php判斷postget 發布:2025-05-14 15:34:24 瀏覽:357
linux查看電腦配置 發布:2025-05-14 15:32:07 瀏覽:317