Dubbo是如何基于動(dòng)態(tài)代理實(shí)現(xiàn)RPC調(diào)用的?
今天給大家講一個(gè)知識(shí)點(diǎn),就是平時(shí)我們很多兄弟開發(fā)的系統(tǒng)都不再是那種 10 年前的簡(jiǎn)單單塊系統(tǒng)了,一個(gè)工程打包部署啟動(dòng),系統(tǒng)連接 MySQL,然后 Crud 整起就夠的了,我們現(xiàn)在開發(fā)的系統(tǒng)都是很高大上的分布式系統(tǒng)。
啥叫分布式系統(tǒng)?
就是說你寫的系統(tǒng)收到一個(gè)請(qǐng)求之后,你自己的代碼跑完還不夠,你得去調(diào)用別的兄弟寫的系統(tǒng),讓他的系統(tǒng)也干一些事兒,然后他的活兒也干完了之后,你這次請(qǐng)求處理才算是完事兒了。
就因?yàn)槟闾幚碚?qǐng)求得調(diào)用別的兄弟系統(tǒng)一起運(yùn)行,一個(gè)請(qǐng)求涉及到了分布在多臺(tái)機(jī)器上的多個(gè)系統(tǒng),所以就叫做分布式了。
如下圖:
分布式系統(tǒng)之間如何調(diào)用呢?
那現(xiàn)在兄弟們平時(shí)開發(fā)分布式系統(tǒng),就是去調(diào)用別的系統(tǒng),一般都是用什么框架呢?
簡(jiǎn)單,現(xiàn)在兄弟們一般都是用 SpringCloud,或者是用 Dubbo,這兩種都有人用,用 SpringCloud 的一般前兩年多一些,最近這兩年大家都紛紛轉(zhuǎn)用 SpringCloud Alibaba 了。
以前用 SpringCloud 的時(shí)候,你要調(diào)用別的系統(tǒng)一般用的是 Feign 這個(gè)框架,然后現(xiàn)在你用 SpringCloud Alibaba 的時(shí)候,一般用的都是 Dubbo 這個(gè)框架,我們今天就以 Dubbo 這個(gè)框架舉例來講講我們平時(shí)系統(tǒng)之間是如何進(jìn)行調(diào)用的。
首先呢,我們還是看上面那個(gè)圖里的業(yè)務(wù)系統(tǒng) B,這個(gè)系統(tǒng)如果要提供接口給別人調(diào)用,那么他必須寫一個(gè)接口,這個(gè)接口里得定義好你要允許別人調(diào)用哪些方法,大致看起來可能類似下面這樣的代碼。
如下:
public interface Service {
String sayHello(String name);
}
接著呢,你得針對(duì)這個(gè)接口開發(fā)一個(gè)實(shí)現(xiàn)類,實(shí)現(xiàn)類里需要完成這個(gè)方法的邏輯,同時(shí)還得給這個(gè)實(shí)現(xiàn)類加上@DubboService這個(gè)注解,讓Dubbo把他識(shí)別為一個(gè)對(duì)外的服務(wù)接口,如下面的代碼:
@DubboService(version = "1.0.0", interfaceClass = Service.class)
public class ServiceImpl implements Service {
public String sayHello(String name) {
// 運(yùn)行一些代碼
return "hello, " + name; }
}
那么當(dāng)你的業(yè)務(wù)系統(tǒng) B 開發(fā)好上面的接口和實(shí)現(xiàn)類,同時(shí)加上了 @DubboService 這個(gè)注解之后,這個(gè)業(yè)務(wù)系統(tǒng) B 啟動(dòng)以后,會(huì)干一個(gè)什么事兒呢?
簡(jiǎn)單來說,Dubbo 框架會(huì)隨著你的業(yè)務(wù)系統(tǒng) B 一起啟動(dòng),他會(huì)啟動(dòng)一個(gè)網(wǎng)絡(luò)服務(wù)器,這個(gè)網(wǎng)絡(luò)服務(wù)器會(huì)監(jiān)聽一個(gè)你指定的端口號(hào),通常這個(gè)端口號(hào)是 20880 端口。
如下圖:
這個(gè)時(shí)候業(yè)務(wù)系統(tǒng) B 上的 Dubbo 已經(jīng)啟動(dòng)好了網(wǎng)絡(luò)服務(wù)器監(jiān)聽了一個(gè)端口號(hào),隨時(shí)可以接收你發(fā)送過來的調(diào)用請(qǐng)求。
接下來就輪到咱們的業(yè)務(wù)系統(tǒng) A 出場(chǎng)了,這個(gè)業(yè)務(wù)系統(tǒng) A 假設(shè)要調(diào)用業(yè)務(wù)系統(tǒng) B 的 Service 接口中定義的那些方法,他會(huì)怎么做呢?
這個(gè)代碼大概會(huì)是這樣的:
@RestController
public class Controller {
// 注意,這里的Service就是業(yè)務(wù)系統(tǒng)B定義的接口
@DubboReference(version = "1.0.0")
private Service service;
@RequestMapping("/hello")
public Response sayHello(String name) {
String result = service.sayHello(name);
return Response.success(result); }
}
所以說,這里最關(guān)鍵的問題來了,上面是業(yè)務(wù)系統(tǒng) A 的代碼,他僅僅是定義了一個(gè)業(yè)務(wù)系統(tǒng) B 的 Service 接口的變量。
就是 Service service 這個(gè)變量,然后加了一個(gè) @DubboReference 注解,所以這個(gè)業(yè)務(wù)系統(tǒng) A 啟動(dòng)的時(shí)候,Dubbo 又會(huì)干點(diǎn)什么事兒呢?
Dubbo 是如何基于動(dòng)態(tài)代理實(shí)現(xiàn) RPC 調(diào)用的
其實(shí)這里有一個(gè)很重點(diǎn)的點(diǎn),那就是 Dubbo 此時(shí)會(huì)使用我們?cè)O(shè)計(jì)模式里的代理模式,去創(chuàng)建一個(gè)動(dòng)態(tài)代理對(duì)象,把這個(gè)動(dòng)態(tài)代理對(duì)象注入給我們上面的 Service service 這個(gè)變量,讓他那個(gè)變量引用 Dubbo 的動(dòng)態(tài)代理對(duì)象。
那么這個(gè)動(dòng)態(tài)代理對(duì)象是個(gè)什么東西呢?簡(jiǎn)單來說,就是 Dubbo 可以動(dòng)態(tài)生成一個(gè)類,這個(gè)類是實(shí)現(xiàn)了 Service 接口的,然后所有的方法都是有他自己的一套實(shí)現(xiàn)邏輯的。
具體什么實(shí)現(xiàn)邏輯一會(huì)兒我們?cè)僬f,但是現(xiàn)在看起來應(yīng)該如下圖:
所以這里其實(shí)很關(guān)鍵的一點(diǎn)是,大家一定要在這里理解這個(gè) Dubbo 動(dòng)態(tài)代理的概念,這是設(shè)計(jì)模式中代理模式一個(gè)很經(jīng)典的運(yùn)用。
就是說,一旦 Dubbo 生成了針對(duì)接口的動(dòng)態(tài)代理對(duì)象,注入給了 Service service 這個(gè)變量,那么你業(yè)務(wù)系統(tǒng) A 里調(diào)用 Service service 的方法時(shí),其實(shí)是會(huì)調(diào)用 Dubbo 動(dòng)態(tài)代理對(duì)象的方法的。
再看一下代碼感受一下:
@RestController
public class Controller {
// 注意,這里的Service就是業(yè)務(wù)系統(tǒng)B定義的接口
// 這個(gè)接口變量其實(shí)會(huì)被注入Dubbo生成的動(dòng)態(tài)代理對(duì)象
@DubboReference(version = "1.0.0")
private Service service;
@RequestMapping("/hello")
public Response sayHello(String name) {
// 注意,這里你調(diào)用接口方法的時(shí)候,其實(shí)是在調(diào)用Dubbo動(dòng)態(tài)代理對(duì)象的方法
String result = service.sayHello(name);
return Response.success(result);
}
}
接著 Dubbo 動(dòng)態(tài)代理對(duì)象的方法被調(diào)用的時(shí)候,他會(huì)干什么事情呢?
其實(shí)這里他就會(huì)跟我們的業(yè)務(wù)系統(tǒng) B 所在的機(jī)器建立一個(gè)網(wǎng)絡(luò)連接,然后通過這個(gè)網(wǎng)絡(luò)連接把一個(gè)調(diào)用請(qǐng)求發(fā)送過去。
業(yè)務(wù)系統(tǒng) B 里面的 Dubbo 網(wǎng)絡(luò)服務(wù)器收到請(qǐng)求之后,就會(huì)根據(jù)請(qǐng)求調(diào)用本地的接口實(shí)現(xiàn)類的方法,拿到返回值,接著通過網(wǎng)絡(luò)連接把返回值返回給業(yè)務(wù)系統(tǒng) A 的 Dubbo 動(dòng)態(tài)代理對(duì)象,最后,Dubbo 動(dòng)態(tài)代理對(duì)象就會(huì)把這個(gè)返回值交給我們了。
如下圖:
好了,今天給大家分享的基于 Dubbo 實(shí)現(xiàn)系統(tǒng)間調(diào)用的原理就到這里了,希望大家平時(shí)用 Dubbo 做開發(fā)的時(shí)候,對(duì)他底層的原理也得有一定的理解。