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