Dubbo實現(xiàn)的原理分析上課講義

1、Good is good, but better carries it.精益求精，善益求善。Dubbo實現(xiàn)的原理分析-Dubbo實現(xiàn)原理的概述Dubbo是阿里巴巴開源出來的一個分布式服務(wù)框架，致力于提供高性能和透明化的HYPERLINK/wiki/Remote_procedure_callRPC遠程服務(wù)調(diào)用方案，以及作為HYPERLINK/wiki/Service-oriented_architectureSOA服務(wù)治理的方案。它的核心功能包括：remoting:遠程通訊基礎(chǔ)，提供對多種NIO框架抽象封裝，包括“同步轉(zhuǎn)異步”和“請求-響應(yīng)”模式的信息交換方式。Cluster:服務(wù)框架核心，提供

2、基于接口方法的遠程過程調(diào)用，包括多協(xié)議支持，并提供軟負載均衡和容錯機制的集群支持。registry:服務(wù)注冊中心，使服務(wù)消費方能動態(tài)的查找服務(wù)提供方，使地址透明，使服務(wù)提供方可以平滑增加或減少機器。由于Dubbo團隊的文檔和代碼都非常優(yōu)秀，所以更多關(guān)于dubbo的方方面面請參考網(wǎng)站HYPERLINK/wiki/display/dubbo/Home-zh/wiki/display/dubbo/Home-zh。這里我們只是補充一下從源碼具體實現(xiàn)角度來看的某些細節(jié)方面，包括Invoker、ExtensionLoader等方面。任何官方已經(jīng)介紹過的細節(jié)，我們不做畫蛇添足，官方文檔已經(jīng)足夠詳實了，這篇文

3、檔的定位是補充實現(xiàn)的相關(guān)細節(jié)。服務(wù)提供者暴露一個服務(wù)的詳細過程上圖是服務(wù)提供者暴露服務(wù)的主過程：首先ServiceConfig類拿到對外提供服務(wù)的實際類ref(如：HelloWorldImpl),然后通過ProxyFactory類的getInvoker方法使用ref生成一個AbstractProxyInvoker實例，到這一步就完成具體服務(wù)到Invoker的轉(zhuǎn)化。接下來就是Invoker轉(zhuǎn)換到Exporter的過程。Dubbo處理服務(wù)暴露的關(guān)鍵就在Invoker轉(zhuǎn)換到Exporter的過程(如上圖中的紅色部分)，下面我們以Dubbo和RMI這兩種典型協(xié)議的實現(xiàn)來進行說明：Dubbo的實現(xiàn)Dub

4、bo協(xié)議的Invoker轉(zhuǎn)為Exporter發(fā)生在DubboProtocol類的export方法，它主要是打開socket偵聽服務(wù)，并接收客戶端發(fā)來的各種請求，通訊細節(jié)由Dubbo自己實現(xiàn)。RMI的實現(xiàn)RMI協(xié)議的Invoker轉(zhuǎn)為Exporter發(fā)生在RmiProtocol類的export方法，它通過Spring或Dubbo或JDK來實現(xiàn)RMI服務(wù)，通訊細節(jié)這一塊由JDK底層來實現(xiàn)，這就省了不少工作量。服務(wù)消費者消費一個服務(wù)的詳細過程上圖是服務(wù)消費的主過程：首先ReferenceConfig類的init方法調(diào)用Protocol的refer方法生成Invoker實例(如上圖中的紅色部分)，這是

5、服務(wù)消費的關(guān)鍵。接下來把Invoker轉(zhuǎn)換為客戶端需要的接口(如：HelloWorld)。關(guān)于每種協(xié)議如RMI/Dubbo/Webservice等它們在調(diào)用refer方法生成Invoker實例的細節(jié)和上一章節(jié)所描述的類似。滿眼都是Invoker由于Invoker是Dubbo領(lǐng)域模型中非常重要的一個概念，很多設(shè)計思路都是向它靠攏。這就使得Invoker滲透在整個實現(xiàn)代碼里，對于剛開始接觸Dubbo的人，確實容易給搞混了。下面我們用一個精簡的圖來說明最重要的兩種Invoker：服務(wù)提供Invoker和服務(wù)消費Invoker：為了更好的解釋上面這張圖，我們結(jié)合服務(wù)消費和提供者的代碼示例來進行說明：服

6、務(wù)消費者代碼publicclassDemoClientActionprivateDemoServicedemoService;publicvoidsetDemoService(DemoServicedemoService)this.demoService=demoService;publicvoidstart()Stringhello=demoService.sayHello(world+i);上面代碼中的DemoService就是上圖中服務(wù)消費端的proxy，用戶代碼通過這個proxy調(diào)用其對應(yīng)的Invoker(DubboInvoker、HessianRpcInvoker、InjvmInvo

7、ker、RmiInvoker、WebServiceInvoker中的任何一個)，而該Invoker實現(xiàn)了真正的遠程服務(wù)調(diào)用。服務(wù)提供者代碼publicclassDemoServiceImplimplementsDemoServicepublicStringsayHello(Stringname)throwsRemoteExceptionreturnHello+name;上面這個類會被封裝成為一個AbstractProxyInvoker實例，并新生成一個Exporter實例。這樣當(dāng)網(wǎng)絡(luò)通訊層收到一個請求后，會找到對應(yīng)的Exporter實例，并調(diào)用它所對應(yīng)的AbstractProxyInvoker

8、實例，從而真正調(diào)用了服務(wù)提供者的代碼。Dubbo里還有一些其他的Invoker類，但上面兩種是最重要的。ExtensionLoader的完整分析ExtensionLoader是Dubbo中一個非常重要的類，剛接觸Dubbo源碼的人看這個類的時候也多少會有點困惑，這個類非常重要，它就像是廚房里的“大廚”，按照用戶的隨時需要把各種“食材”烹調(diào)出來。我們結(jié)合具體代碼詳細說一下ExtensionLoader的實現(xiàn)，下面是ServiceConfig類里的一行代碼：privatestaticfinalProtocolprotocol=ExtensionLoader.getExtensionLoader(P

9、rotocol.class).getAdaptiveExtension();上面代碼的程序流程圖如下所示(假定是第一次執(zhí)行這行代碼)：在這個過程中最重要的兩個方法是getExtensionClasses和createAdaptiveExtensionClass(圖中紅色部分)，下面詳細對這兩個方法進行分析：getExtensionClasses這個方法主要讀取META-INF/services/目錄下對應(yīng)文件內(nèi)容，在本示例代碼中，是讀取META-INF/services/com.alibaba.dubbo.rpc.Protocol文件中的內(nèi)容，具體內(nèi)容如下：com.alibaba.dubbo.

10、registry.support.RegistryProtocoltocol.ProtocolFilterWrappertocol.ProtocolListenerWrappertocol.dubbo.DubboProtocoltocol.injvm.InjvmProtocoltocol.rmi.RmiProtocoltocol.hessian.HessianProtocoltocol.webservice.WebServiceProtocol它分析該文件中的每一行(每一行對應(yīng)一個類)，分析這些類，如果發(fā)現(xiàn)有哪個類的Annotation是Adaptive，則找到對應(yīng)的AdaptiveClass了，但由于Protocol文件里沒有哪個類的Annotation是Adaptive，所以在這個例子中該方法沒找到對應(yīng)的AdaptiveClass。createAdaptiveExtensionClass該方法是在getExtensionClasses方法找不到Adaptive