日后再完善
基本流程
Dubbo服務(wù)導(dǎo)出過程始于Spring容器發(fā)布刷新事件，Dubbo在接收到事件后绑警，會立即執(zhí)行服務(wù)導(dǎo)出邏輯求泰。整個(gè)邏輯大致可分為三個(gè)部分：
- 第一部分是前置工作，主要用于檢查參數(shù)计盒，組裝URL渴频。
- 第二部分是導(dǎo)出服務(wù)，包含導(dǎo)出服務(wù)到本地 (JVM)北启，和導(dǎo)出服務(wù)到遠(yuǎn)程兩個(gè)過程卜朗。
- 第三部分是向注冊中心注冊服務(wù)，用于服務(wù)發(fā)現(xiàn)咕村。
詳細(xì)流程
入口
- 服務(wù)導(dǎo)出的入口方法：[dubbo-config-spring] ServiceBean#onApplicationEvent
- 可以延時(shí)導(dǎo)出场钉，配置項(xiàng) service.delay
配置檢查
在導(dǎo)出服務(wù)之前，Dubbo需要檢查用戶的配置是否合理懈涛，或者為用戶補(bǔ)充缺省配置惹悄。
- 源碼：[dubbo-config-api] ServiceConfig#checkAndUpdateSubConfigs
多協(xié)議多注冊中心
Dubbo允許我們使用不同的協(xié)議導(dǎo)出服務(wù)，也允許我們向多個(gè)注冊中心注冊服務(wù)肩钠。遍歷ProtocolConfig集合導(dǎo)出每個(gè)服務(wù)泣港。并在導(dǎo)出服務(wù)的過程中，將服務(wù)注冊到注冊中心价匠。
- 多協(xié)議配置項(xiàng) dubbo.protocol
- 多注冊中心配置項(xiàng) dubbo.registry
- 源碼：[dubbo-config-api] ServiceConfig#doExportUrls
URL組裝
配置檢查完成后当纱，接下來需要根據(jù)這些配置組裝URL。
- 首先是將一些信息踩窖，比如版本坡氯、時(shí)間戳、方法名以及各種配置對象的字段信息放入到map中，map 中的內(nèi)容將作為URL的查詢字符串箫柳。
- 構(gòu)建好map后手形，緊接著是獲取上下文路徑、主機(jī)名以及端口號等信息悯恍。
- 最后將map和主機(jī)名等數(shù)據(jù)傳給 URL 構(gòu)造方法創(chuàng)建 URL 對象库糠。
- 源碼：[dubbo-config-api] ServiceConfig#doExportUrlsFor1Protocol
創(chuàng)建Invoker
Invoker 是由 ProxyFactory 創(chuàng)建而來，Dubbo 默認(rèn)的 ProxyFactory 實(shí)現(xiàn)類是 JavassistProxyFactory涮毫。
- 源碼：[dubbo-rpc-api] JavassistProxyFactory#getInvoker
- JavassistProxyFactory 創(chuàng)建了一個(gè)繼承自 AbstractProxyInvoker 類的匿名對象沈自，并覆寫了抽象方法 doInvoke朗恳。覆寫后的 doInvoke 邏輯比較簡單谋币，僅是將調(diào)用請求轉(zhuǎn)發(fā)給了 Wrapper 類的 invokeMethod 方法棺克。
- Wrapper 用于“包裹”目標(biāo)類，Wrapper 是一個(gè)抽象類咒吐，僅可通過 getWrapper(Class) 方法創(chuàng)建子類野建。在創(chuàng)建 Wrapper 子類的過程中，子類代碼生成邏輯會對 getWrapper 方法傳入的 Class 對象進(jìn)行解析恬叹，拿到諸如類方法贬墩，類成員變量等信息。以及生成 invokeMethod 方法代碼和其他一些方法代碼妄呕。代碼生成完畢后陶舞，通過 Javassist 生成 Class 對象，最后再通過反射創(chuàng)建 Wrapper 實(shí)例绪励。
- AbstractProxyInvoker 包含一個(gè) Proxy 實(shí)例肿孵，代理了具體的服務(wù)類。
- Proxy 用于代理目標(biāo)類疏魏，Proxy 是一個(gè)抽象類停做，僅可以通過 getProxy(ClassLoader, Class[]) 方法創(chuàng)建子類〈竽可以通過 newInstance(InvocationHandler) 來創(chuàng)建代理實(shí)例蛉腌。
- 服務(wù)類 --> Proxy --> Wrapper --> Invoker
導(dǎo)出到本地JVM
- 源碼：[dubbo-rpc-injvm] InjvmProtocol#export
- 首先根據(jù) URL 協(xié)議頭決定是否導(dǎo)出服務(wù)。若需導(dǎo)出只厘，則創(chuàng)建一個(gè)新的 URL 并將協(xié)議頭烙丛、主機(jī)名以及端口設(shè)置成新的值。
- 然后創(chuàng)建 Invoker羔味，并調(diào)用 InjvmProtocol 的 export 方法導(dǎo)出服務(wù)河咽。
- InjvmProtocol 的 export 方法僅創(chuàng)建了一個(gè) InjvmExporter，無其他邏輯赋元。
導(dǎo)出到遠(yuǎn)程
- 源碼：[dubbo-registry-api] RegistryProtocol#export
- 調(diào)用 doLocalExport 導(dǎo)出服務(wù)忘蟹，調(diào)用 Protocol 的 export 方法
- 向注冊中心注冊服務(wù)
- 向注冊中心進(jìn)行訂閱 override 數(shù)據(jù)
- 創(chuàng)建并返回 DestroyableExporter
dubbo協(xié)議導(dǎo)出服務(wù)
默認(rèn)使用dubbo協(xié)議導(dǎo)出服務(wù)飒房。
- 源碼：[dubbo-rpc-dubbo] DubboProtocol#export
- 源碼：[dubbo-rpc-dubbo] DubboProtocol#openServer
- 源碼：[dubbo-rpc-dubbo] DubboProtocol#createServer
- createServer 包含三個(gè)核心的邏輯。第一是檢測是否存在 server 參數(shù)所代表的 Transporter 拓展媚值，不存在則拋出異常狠毯。第二是創(chuàng)建服務(wù)器實(shí)例。第三是檢測是否支持 client 參數(shù)所表示的 Transporter 拓展褥芒，不存在也是拋出異常嚼松。
啟動(dòng)服務(wù)器
默認(rèn)使用Netty實(shí)現(xiàn)服務(wù)器。
- 源碼：[dubbo-remoting-api] HeaderExchanger#bind
- getTransporter() 方法獲取的 Transporter 是在運(yùn)行時(shí)動(dòng)態(tài)創(chuàng)建的喂很，類名為 TransporterAdaptive，也就是自適應(yīng)拓展類皆刺。TransporterAdaptive 會在運(yùn)行時(shí)根據(jù)傳入的 URL 參數(shù)決定加載什么類型的 Transporter少辣，默認(rèn)為 NettyTransporter。
- 源碼：[dubbo-remoting-netty] NettyTransporter#bind
- 源碼：[dubbo-remoting-netty] NettyServer#doOpen
注冊到注冊中心
注冊中心默認(rèn)為Zookeeper羡蛾，客戶端默認(rèn)使用Curator漓帅。
- 源碼：[dubbo-registry-zookeeper] ZookeeperRegistryFactory#createRegistry
- 源碼：[dubbo-remoting-zookeeper] CuratorZookeeperTransporter#createZookeeperClient
