架構(gòu)圖
????????不貼架構(gòu)圖的源碼分析沒(méi)有靈魂漱牵，所以，架構(gòu)圖在此酣胀。不過(guò)個(gè)人感覺(jué)，架構(gòu)圖的作用在于源碼看的七七八八的時(shí)候甚脉，通過(guò)架構(gòu)圖將其串成一個(gè)整體，并理解其設(shè)計(jì)思路狡耻，官網(wǎng)網(wǎng)架構(gòu)圖如下：
????????Dubbo架構(gòu)一共分了10層猴凹，各層均為單向依賴。
????????????服務(wù)接口層（Service）：該層是與實(shí)際業(yè)務(wù)邏輯相關(guān)孵淘，根據(jù)服務(wù)提供者和服務(wù)消費(fèi)者的業(yè)務(wù)設(shè)計(jì)對(duì)應(yīng)接口和實(shí)現(xiàn)歹篓。
????????????配置層（Config）：對(duì)外的配置接口，以ServiceConfig和ReferenceConfig為中心背捌。
????????????服務(wù)代理層（Proxy）：服務(wù)接口的透明代理，生成服務(wù)的客戶端Stub和服務(wù)端Skeleton毡庆，以ServiceProxy為中心么抗，擴(kuò)展接口為ProxyFactory亚铁。
????????????服務(wù)注冊(cè)層（Registry）：封裝服務(wù)地址的注冊(cè)發(fā)現(xiàn)，以服務(wù)URL為中心徘溢，擴(kuò)展接口為RegistryFactory、Registry和RegistryService站粟，可能沒(méi)有服務(wù)注冊(cè)中心曾雕，此時(shí)服務(wù)提供者直接暴露服務(wù)。
????????????集群層（Cluster）：封裝多個(gè)提供者的路由及負(fù)載均衡缸沃，并橋接注冊(cè)中心，以Invoker為中心检盼，擴(kuò)展接口為Cluster翘单、Directory、Router和LoadBalance貌亭。將多個(gè)服務(wù)提供者組合成一個(gè)服務(wù)提供者认臊，實(shí)現(xiàn)對(duì)服務(wù)消費(fèi)者透明，只需與一個(gè)服務(wù)提供者進(jìn)行交互失晴。
????????????監(jiān)控層（Monitor）：RPC調(diào)用次數(shù)和調(diào)用時(shí)間監(jiān)控，以Statistics為中心涂屁，擴(kuò)展接口為MonitorFactory、Monitor和MonitorService拆又。
????????????遠(yuǎn)程調(diào)用層（Protocol）：封裝RPC調(diào)用，以Invocation和Result為中心栈源，擴(kuò)展接口為Protocol竖般、Invoker和Exporter。Protocol是服務(wù)域捻激，它是Invoker暴露和引用的主功能入口胞谭，負(fù)責(zé)Invoker的聲明周期管理男杈。Invoker是實(shí)體域，是Dubbo的核心模型旺垒，其他模型都向它靠攏或轉(zhuǎn)換成它。它代表一個(gè)可執(zhí)行體骇钦，可向它發(fā)起Invoke調(diào)用竞漾。
????????????信息交換層（Exchange）：封裝請(qǐng)求響應(yīng)模式业岁，同步轉(zhuǎn)異步，以Request和Response為中心笔时，擴(kuò)展接口為Exchanger、ExchangeChannel借笙、ExchangeClient和ExchangeServer右犹。
????????????網(wǎng)絡(luò)傳輸層（Transport）：首相mina和netty為統(tǒng)一接口，以Message為中心盼忌，擴(kuò)展接口為Channel掂墓、Transporter、Client跨嘉、Server和Codec祠乃。
????????????數(shù)據(jù)序列化層（Serialize）：可復(fù)用一些工具兑燥，擴(kuò)展接口為Serialization、ObjectInput嘱支、ObjectOutput和ThreadPool。
服務(wù)調(diào)用源碼分析
????????在上文的ReferenceBean服務(wù)發(fā)現(xiàn)過(guò)程中的值除师，消費(fèi)端的接口都會(huì)被封裝成代理類，我們調(diào)用的接口的方法其實(shí)執(zhí)行的是InvokerInvocationHandler#invoke方法锹安。從這個(gè)方法開(kāi)始贞岭，調(diào)用鏈還是有點(diǎn)長(zhǎng)的：
InvokerInvocationHandler#invoke(Object, Method, Object[])
??-> MockClusterInvoker#invoke(Invocation) //服務(wù)降級(jí)相關(guān)操作
????-> AbstractClusterInvoker#invoke(Invocation) //列舉可用服務(wù)以及初始化負(fù)載均衡對(duì)象
??????-> FailoverClusterInvoker#doInvoke(Invocation, List<Invoker<T>>, LoadBalance) //Failover模式的集群容錯(cuò)
????????-> ListenerInvokerWrapper#invoke(Invocation)
??????????-> Filter#invoke(Invoker, Invocation) // 包含多個(gè) Filter 調(diào)用
????????????-> AsyncToSyncInvoker#invoker //異步轉(zhuǎn)同步
??????????????-> AbstractInvoker#invoke(Invocation) // 設(shè)置上下文參數(shù)
????????????????-> DubboInvoker#doInvoke(Invocation) // 設(shè)置客戶端以及發(fā)送請(qǐng)求
??????????????????-> ReferenceCountExchangeClient#request(Object, int) // 記錄該client使用次數(shù)
????????????????????-> HeaderExchangeClient#request(Object, int) // 執(zhí)行心跳任務(wù)和連接超時(shí)重連任務(wù)
??????????????????????-> HeaderExchangeChannel#request(Object, int) // 設(shè)置請(qǐng)求參數(shù)
????????????????????????-> AbstractPeer#send(Object) // 檢查chaneel是否關(guān)閉
??????????????????????????-> AbstractClient#send(Object, boolean) // 獲取NettyChannel發(fā)送請(qǐng)求
????????????????????????????-> NettyChannel#send(Object, boolean) // 發(fā)送請(qǐng)求瞄桨，觸發(fā)writeAndFlush事件在pipeline中傳播
????????從InvokerInvocationHandler#invoke方法開(kāi)始，代碼實(shí)現(xiàn)如下：
????????對(duì)toString泊交、hashCode廓俭、equals方法進(jìn)行特殊處理唉工，繼續(xù)向下調(diào)用進(jìn)入MockClusterInvoker#invoke方法如下：
????????主要處理Mock服務(wù)降級(jí)的調(diào)用，主要有沒(méi)有mock（默認(rèn)）雹熬，強(qiáng)制mock降級(jí)竿报，以及調(diào)用失敗拋出RpcException后mock降級(jí)三種方式继谚。此處為默認(rèn)方式，下一步進(jìn)入AbstractClusterInvoker#invoke方法芽世，實(shí)現(xiàn)代碼如下：
????????主要將RpcContext上下文中的attachment添加到Invocation中济瓢，然后初始化負(fù)載均衡類欢峰，如果是異步則需要添加自增ID纽帖，然后進(jìn)入FailoverClusterInvoker#doinvoke方法，代碼如下：
????????主要處理集群容錯(cuò)機(jī)制相關(guān)操作扒吁，根據(jù)重試次數(shù)循環(huán)調(diào)用，遠(yuǎn)程調(diào)用的時(shí)候會(huì)根據(jù)負(fù)載均衡策略獲取對(duì)應(yīng)的invoker雕崩，執(zhí)行其invoke方法盼铁，這是會(huì)經(jīng)過(guò)InvokerWrapper#invoke和ListenerInvokerWrapper#invoke尝偎，然后會(huì)調(diào)用ProtocolFilterWrapper構(gòu)建的Fliter鏈，包括ConsumerContextFilter肤寝、FutureFilter、MonitorFilter等抖僵，下一步就會(huì)進(jìn)入AsyncToSyncInvoker#invoke方法鲤看，實(shí)現(xiàn)如下：
????????根據(jù)其名稱就可以看出，這個(gè)類的作用就是異步轉(zhuǎn)同步耍群，因?yàn)镹etty是基于異步事件驅(qū)動(dòng)的义桂，讀寫(xiě)均為異步，需要做同步處理的時(shí)候世吨，就主動(dòng)調(diào)用AsyncRpcResult#get方法阻塞等待異步執(zhí)行結(jié)果澡刹。
????????然后接下來(lái)進(jìn)入AbstractInvoker#invoke方法，代碼如下：
????????添加信息到 RpcInvocation#attachment 變量中耘婚，添加完畢后罢浇，調(diào)用 doInvoke 執(zhí)行后續(xù)的調(diào)用，此處是DubboInvoker#doInvoke方法沐祷，實(shí)現(xiàn)如下：
????????設(shè)置參數(shù)胞锰，然后根據(jù)是否需要返回值判斷嗅榕，然后開(kāi)始進(jìn)入Exchange層開(kāi)始發(fā)送請(qǐng)求，一串流轉(zhuǎn)之后進(jìn)入HeaderExchangeChannel#request方法兼雄，實(shí)現(xiàn)代碼如下：
????????構(gòu)建request對(duì)象赦肋，創(chuàng)建DefaultFuture，交由NettyClient發(fā)送請(qǐng)求驹尼，然后流轉(zhuǎn)進(jìn)入AbstractClient#send方法鹅巍，代碼如下：
????????交由NettyChannel#send方法繼續(xù)執(zhí)行：
????????這里，終于看到了觸發(fā)writeAndFlush事件髓绽，在pipeline中傳播顺呕，接下來(lái)就進(jìn)入了handler的處理過(guò)程来涨，包括我們上文分析的編解碼handler以及業(yè)務(wù)handler蹦掐。
????????但到這里一次遠(yuǎn)程服務(wù)調(diào)用并沒(méi)有真正的完成僵闯，還差服務(wù)端的請(qǐng)求響應(yīng)社裆，以及消費(fèi)端異步寫(xiě)回響應(yīng)結(jié)果泳秀，其具體分析在下一篇文章服務(wù)端請(qǐng)求響應(yīng)與消費(fèi)端異步寫(xiě)回
中詳細(xì)介紹。
