筆記簡(jiǎn)述
Dubbo服務(wù)暴露之前分為了兩小節(jié)Dubbo 服務(wù)暴露 源碼學(xué)習(xí)(上)(三) 和Dubbo 服務(wù)暴露 源碼學(xué)習(xí)(下)(四) 從源碼的角度去分析去學(xué)習(xí)dubbo服務(wù)暴露的細(xì)節(jié),現(xiàn)在站在更高的一個(gè)角度去回顧整個(gè)服務(wù)暴露整個(gè)的流程和操作菩掏,我們能從其中學(xué)習(xí)到什么魂角。
更多內(nèi)容可看[目錄](méi)Dubbo 源碼學(xué)習(xí)
目錄
Dubbo 服務(wù)暴露 總結(jié)(五)
1、Spring
2智绸、SPI
3野揪、服務(wù)暴露流程
- 獲取注冊(cè)中心
- 服務(wù)信息的組裝
- 服務(wù)IO端口提供
- 服務(wù)的注冊(cè)
1、Spring
基于spring開(kāi)發(fā)瞧栗,做到無(wú)縫對(duì)接spring斯稳,在使用上只有極少數(shù)的xml配置學(xué)習(xí)成本,在Dubbo內(nèi)部繼承了若干個(gè)類(lèi)迹恐,自定義實(shí)現(xiàn)的xsd和配套的解析方法等挣惰。如果以后需要接入自定義的NameSpaceContext,同樣需要類(lèi)似的處理
- 通過(guò)BeanNameAware修改bean的名稱(chēng)
- ApplicationContextAware去獲取Spring IOC的容器
- IntializingBean的afterPropertiesSet去自定義實(shí)現(xiàn)bean的實(shí)例對(duì)象
- ApplicationListener的onApplicationEvent接收各種事件
- DisposableBean的destroy去銷(xiāo)毀bean
獲取Spring IOC容器之后殴边,在自定義實(shí)現(xiàn)dubbo的服務(wù)bean時(shí)憎茂,就可以獲取到系統(tǒng)配置的注冊(cè)中心、使用的協(xié)議锤岸、均衡負(fù)責(zé)等內(nèi)容(對(duì)注冊(cè)中心竖幔、協(xié)議等對(duì)Spring而言只是個(gè)普通的bean而言),這樣就可以完成對(duì)ServiceBean的屬性輸入是偷。
2拳氢、SPI
雖然之前介紹過(guò)了SPI的整個(gè)的處理細(xì)節(jié),詳情可看Dubbo SPI 源碼學(xué)習(xí) & admin安裝(二)晓猛,在整個(gè)的dubbo中也確實(shí)大量使用中饿幅。可是真正的在調(diào)試服務(wù)暴露中還是有不少細(xì)節(jié)被忽略掉了戒职。
- 基本上所有的類(lèi)都有通過(guò)拼接代碼字符串再編譯生成其對(duì)象
- 動(dòng)態(tài)生成的對(duì)象其實(shí)并沒(méi)有做很多事情栗恩,只是根據(jù)配置的xml參數(shù),動(dòng)態(tài)決定選取合適的實(shí)現(xiàn)類(lèi)洪燥,再調(diào)用其方法
- 參數(shù)注入和spring的參數(shù)注入方法不一樣的是磕秤,dubbo是獲取類(lèi)的所有set開(kāi)頭同時(shí)參數(shù)只有1個(gè)的公共方法,通過(guò)SPI取到參數(shù)的值捧韵,然后反射invoke注入的
- Dubbo為了一些附加的功能市咆,存在包裝類(lèi)的情況,每一個(gè)接口都有wrapper的存在再来,如果存在則最后返回的對(duì)象不是對(duì)象本身蒙兰,而是經(jīng)過(guò)層層包裝產(chǎn)生的對(duì)象磷瘤,例如Protocol
3、服務(wù)暴露流程
如果是我們?nèi)ネ瓿蛇@個(gè)任務(wù)會(huì)怎么去做呢搜变?有兩點(diǎn)肯定是要實(shí)現(xiàn)的
- 注冊(cè)中心采缚,需要把服務(wù)提供方的信息推送給注冊(cè)中心統(tǒng)一管理,服務(wù)調(diào)用方能夠感知到存在這個(gè)服務(wù)
- 對(duì)外的網(wǎng)絡(luò)端口挠他,可通過(guò)套接字和外界(服務(wù)調(diào)用方)發(fā)生信息交換
服務(wù)調(diào)用方感知到服務(wù)的存在扳抽,然后獲取其服務(wù)的套接字信息,然后直接通過(guò)網(wǎng)絡(luò)IO完成信息交換
Dubbo其實(shí)也基本上按照這種思路來(lái)實(shí)現(xiàn)的殖侵,只是支持了多種協(xié)議贸呢,并且還有監(jiān)控、統(tǒng)計(jì)等功能拢军,層次分明楞陷。
1. 獲取注冊(cè)中心
注冊(cè)中心的基本配置就是在xml配置的dubbo:registry,生成的URL也是注冊(cè)協(xié)議的URL,例如
registry://127.0.0.1:2182/com.alibaba.dubbo.registry.RegistryService?application=dubbo-demo&client=zkclient&dubbo=2.5.3&group=dubbo-demo&owner=jwfy&pid=2772®istry=zookeeper×tamp=1525276569763
會(huì)把一個(gè)dubbo的xml配置的基本信息給提取出去
2. 服務(wù)信息的組裝
既然注冊(cè)中心已經(jīng)準(zhǔn)備好了朴沿,那現(xiàn)在就需要處理我們對(duì)外暴露的service信息
對(duì)外暴露服務(wù)也需要配置的猜谚,這個(gè)配置就是從dubbo:protocol來(lái)的
這個(gè)配置會(huì)告訴系統(tǒng),所有對(duì)外暴露的IO讀取協(xié)議是什么赌渣,默認(rèn)的是dubbo,其實(shí)也支持redis昌犹、http等
是處理IO數(shù)據(jù)流方式的協(xié)議
不過(guò)坚芜,如果沒(méi)有IP、端口等數(shù)據(jù)斜姥,則從dubbo:provider提取
再配置其他屬性數(shù)據(jù)鸿竖,生成的URL,例如
dubbo://172.16.109.110:20880/com.jwfy.dubbo.product.ProductService?anyhost=true&application=dubbo-demo&default.loadbalance=random&
dubbo=2.5.3&interface=com.jwfy.dubbo.product.ProductService&methods=print,getStr&owner=jwfy
&pid=2772&side=provider×tamp=1525313423899
這個(gè)對(duì)外的服務(wù)使用的那種均衡負(fù)責(zé)铸敏、暴露的接口缚忧、具體可以被調(diào)用的函數(shù)等,而且是屬于提供方
3. 服務(wù)IO端口提供
既然網(wǎng)絡(luò)IO端的協(xié)議數(shù)據(jù)已經(jīng)準(zhǔn)備好了杈笔,那就可以開(kāi)啟闪水,等待服務(wù)方的調(diào)用
這點(diǎn)可以直接跳到DubboProtocol類(lèi)的export操作了(以Dubbo協(xié)議為例子)
針對(duì)每一個(gè)URL都提取出一個(gè)key,然后存儲(chǔ)對(duì)應(yīng)的invoker蒙具、url等信息
真正操作中取的是服務(wù)名+協(xié)議端口為key球榆,DubboExporter為value的一個(gè)map,后續(xù)就可以通過(guò)key反取出invoke對(duì)象
接下來(lái)就是使用哪種Transporter操作了禁筏,默認(rèn)是使用了netty的NettyTransporter(netty是一種基于java開(kāi)發(fā)的異步的持钉、事件驅(qū)動(dòng)的高效的網(wǎng)絡(luò)IO框架),如果需要使用其他的IO框架篱昔,則需要在dubbo:provider設(shè)置service字段
現(xiàn)在網(wǎng)絡(luò)對(duì)外的協(xié)議Netty已經(jīng)準(zhǔn)備好了每强,服務(wù)信息也已經(jīng)準(zhǔn)備好了,那接下來(lái)就按照特定的格式decode操作,把數(shù)據(jù)轉(zhuǎn)變?yōu)樽止?jié)流空执,由netty向外開(kāi)放出來(lái)即可
由此服務(wù)調(diào)用方就可以通過(guò)網(wǎng)絡(luò)IO 鏈接到服務(wù)提供方上
4. 服務(wù)的注冊(cè)
服務(wù)的注冊(cè)是另一個(gè)操作浪箭,也就是把當(dāng)前提供的服務(wù)告訴給注冊(cè)中心,后續(xù)服務(wù)調(diào)用方就可以訂閱注冊(cè)中心脆烟,從而知道有哪些服務(wù)了山林,當(dāng)前例子是使用了zookeeper作為注冊(cè)中心
現(xiàn)在我們知道的是對(duì)外暴露服務(wù)的url信息(也就是invoke對(duì)象中的url)
所以操作也就很明顯了,先獲取到注冊(cè)中心的配置信息邢羔,然后把服務(wù)url信息轉(zhuǎn)為zk協(xié)議的url信息驼抹,最后連接到注冊(cè)中心,注冊(cè)保存即可
這里面就有使用zookeeper的jar包功能拜鹤,需要和注冊(cè)中心交互的操作
此外還有些附屬的功能框冀,例如超時(shí)重試、連接信息的保存和讀让舨尽(如果注冊(cè)中心突然出現(xiàn)問(wèn)題明也,服務(wù)端和客戶端還可以利用本地文件緩存繼續(xù)工作,只是不能再實(shí)時(shí)獲取最新的訂閱信息罷了)
一般本地的連接信息存儲(chǔ)在/Users/XXX/.dubbo中惯裕,如果出現(xiàn)了無(wú)法注冊(cè)無(wú)法調(diào)用的情況温数,可以考慮刪除該文件重啟服務(wù)