dubbo源碼解析-簡單原理、與spring融合

前言

結束了集羣容錯和服務發佈原理這兩個小專題以後,有朋友問我服務引用何時開始,本篇爲服務引用的啓蒙篇.以前是一直和你們一塊兒看源碼,鑑於Talk is cheap.Show me your code,因此本篇將和你們一塊兒寫寫代碼.

插播面試題

• dubbo的原理是怎麼樣的?請簡單談談

• 有沒有考慮過本身實現一個相似dubbo的RPC框架,若是有,請問你會若是着手實現?(面試高頻題,區分度高)

• 你說你用過mybatis,那你知道Mapper接口的原理嗎?(若是回答得不錯,而且提到動態代理這個關鍵詞會繼續往下問,那這個動態代理又是如何經過依賴注入到Mapper接口的呢?)

直入主題

簡單原理

談到dubbo的原理,咱們就必須首先要知道,dubbo的基本概念,通俗的說,就是dubbo是幹嗎的

dubbo是一個分佈式服務框架，致力於提供高性能和透明化的RPC遠程服務調用方案，以及SOA服務治理方案

在此以前,就必需要講講如下幾個簡單又容易混淆的概念

• 集羣

同一個業務，部署在多個服務器上

• 分佈式

一個業務分拆多個子業務，部署在不一樣的服務器上

• RPC

RPC（Remote Procedure Call Protocol）---遠程過程調用

咱們捕捉到幾個重要的關鍵詞,分佈式,透明化,RPC.

既然各服務是部署在不一樣的服務器上,那服務間的調用就是要經過網絡通訊,簡單的用圖描述以下:

以前在dubbo源碼解析-本地暴露的時候就有不少朋友留言問到,這個本地暴露有什麼用.首先,dubbo做爲一個被普遍運用的框架,點滴的性能提高,那麼受益者都是很大一個數量.這也就是爲何JDK的源碼,都喜歡用位運算.好比圖中的UserService和RoleService服務是在同一模塊內的,他們直接的通訊經過JVM性能確定要比經過網絡通訊要好得多.這就是爲何dubbo在設計上,既有遠程暴露,又有本地暴露的緣由.

既然涉及到了網絡通訊,那麼服務消費者調用服務以前,都要寫各類網絡請求,編解碼之類的相關代碼,明顯是很不友好的.dubbo所說的透明,就是指,讓調用者對網絡請求,編解碼之類的細節透明,讓咱們像調用本地服務同樣調用遠程服務,甚至感受不到本身在調用遠程服務.

說了這麼多,那到底怎麼作?要實現這個需求,咱們很容易想到一個關鍵詞,那就是動態代理

1public interface MenuService {
2    void sayHello();
3}

1public class MenuServiceImpl implements MenuService{
2    @Override
3    public void sayHello() {
4    }
5}

 1public class ProxyFactory implements InvocationHandler {
 2    private Class interfaceClass;
 3    public ProxyFactory(Class interfaceClass) {
 4        this.interfaceClass = interfaceClass;
 5    }
 6    //返回代理對象,此處用泛型爲了調用時不用強轉,用Object須要強轉
 7    public <T> T getProxyObject(){
 8        return (T) Proxy.newProxyInstance(this.getClass().getClassLoader(),//類加載器
 9                new Class[]{interfaceClass},//爲哪些接口作代理(攔截哪些方法)
10                this);//(把這些方法攔截到哪處理)
11    }
12    @Override
13    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
14        System.out.println(method);
15        System.out.println("進行編碼");
16        System.out.println("發送網絡請求");
17        System.out.println("將網絡請求結果進行解碼並返回");
18        return null;
19    }
20}

 1public void test() throws Exception {
 2    ProxyFactory proxyFactor = new ProxyFactory(MenuService.class);
 3    MenuService menuService = proxyFactor.getProxyObject();
 4    menuService.sayHello();
 5    //輸出結果以下:
 6    //public abstract void com.toby.rpc.MenuService.sayHello()
 7    //進行編碼
 8    //發送網絡請求
 9    //將網絡請求結果進行解碼並返回
10}

看到這裏可能有朋友要吐槽了,我都看了你幾個月的源碼解析了,上面說的那些我早就懂了,那我還關注肥朝幹嗎.我要的是整出一個相似dubbo的框架,性能上差點不要緊,至少外觀使用上要差很少,好比咱們平時使用dubbo都是先在配置文件配置這麼個東西

1<dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService"/>

而後用在用@Autowired依賴注入來使用的,說白了,逼格要有!

與spring融合

咱們假如要寫一個簡單的RPC,就取名叫tobyRPC(肥朝英文名爲toby),其實我我的是比較喜歡截圖,可是部分朋友和我反覆強調貼代碼,那這裏我就貼代碼吧

1.設計配置屬性和JavaBean

 1public class ReferenceBean<T> extends ReferenceConfig<T> implements FactoryBean {
 2    @Override
 3    public Object getObject() throws Exception {
 4        return get();
 5    }
 6    @Override
 7    public Class<?> getObjectType() {
 8        return getInterfaceClass();
 9    }
10    @Override
11    public boolean isSingleton() {
12        return true;
13    }
14}

 1public class ReferenceConfig<T> {
 2    private Class<?> interfaceClass;
 3    // 接口代理類引用
 4    private transient volatile T ref;
 5    public synchronized T get() {
 6        if (ref == null) {
 7            init();
 8        }
 9        return ref;
10    }
11    private void init() {
12        ref = new ProxyFactory(interfaceClass).getProxyObject();
13    }
14    public Class<?> getInterfaceClass() {
15        return interfaceClass;
16    }
17    public void setInterfaceClass(Class<?> interfaceClass) {
18        this.interfaceClass = interfaceClass;
19    }
20}

2.編寫XSD文件

 1<?xml version="1.0" encoding="UTF-8" standalone="no"?>
 2<xsd:schema
 3        xmlns="http://toby.com/schema/tobyRPC"
 4        xmlns:xsd="http://www.w3.org/2001/XMLSchema"
 5        xmlns:beans="http://www.springframework.org/schema/beans"
 6        xmlns:tool="http://www.springframework.org/schema/tool"
 7        targetNamespace="http://toby.com/schema/tobyRPC">
 8    <xsd:import namespace="http://www.w3.org/XML/1998/namespace"/>
 9    <xsd:import namespace="http://www.springframework.org/schema/beans"/>
10    <xsd:import namespace="http://www.springframework.org/schema/tool"/>
11
12    <xsd:complexType name="referenceType">
13        <xsd:complexContent>
14            <xsd:extension base="beans:identifiedType">
15                <xsd:attribute name="interface" type="xsd:token" use="required">
16                    <xsd:annotation>
17                        <xsd:documentation><![CDATA[ The service interface class name. ]]></xsd:documentation>
18                        <xsd:appinfo>
19                            <tool:annotation>
20                                <tool:expected-type type="java.lang.Class"/>
21                            </tool:annotation>
22                        </xsd:appinfo>
23                    </xsd:annotation>
24                </xsd:attribute>
25            </xsd:extension>
26        </xsd:complexContent>
27    </xsd:complexType>
28
29    <xsd:element name="reference" type="referenceType">
30        <xsd:annotation>
31            <xsd:documentation><![CDATA[ Reference service config ]]></xsd:documentation>
32        </xsd:annotation>
33    </xsd:element>
34
35</xsd:schema>

3.編寫NamespaceHandler和BeanDefinitionParser完成解析工做

 1public class TobyRPCBeanDefinitionParser extends AbstractSingleBeanDefinitionParser {
 2    protected Class getBeanClass(Element element) {
 3        return ReferenceBean.class;
 4    }
 5    protected void doParse(Element element, BeanDefinitionBuilder bean) {
 6        String interfaceClass = element.getAttribute("interface");
 7        if (StringUtils.hasText(interfaceClass)) {
 8            bean.addPropertyValue("interfaceClass", interfaceClass);
 9        }
10    }
11}

1public class TobyRPCNamespaceHandler extends NamespaceHandlerSupport {
2    public void init() {
3        registerBeanDefinitionParser("reference", new TobyRPCBeanDefinitionParser());
4    }
5}

4.編寫spring.handlers和spring.schemas串聯起全部部件

spring.handlers

1http\://toby.com/schema/tobyRPC=com.toby.config.TobyRPCNamespaceHandler

spring.schemas

1http\://toby.com/schema/tobyRPC.xsd=META-INF/tobyRPC.xsd

5.建立配置文件

 1<?xml version="1.0" encoding="UTF-8"?>
 2<beans xmlns="http://www.springframework.org/schema/beans"
 3    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4    xmlns:tobyRPC="http://toby.com/schema/tobyRPC"
 5    xsi:schemaLocation="http://www.springframework.org/schema/beans
 6    http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
 7    http://toby.com/schema/tobyRPC http://toby.com/schema/tobyRPC.xsd">
 8
 9    <tobyRPC:reference id="menuService" interface="com.toby.rpc.MenuService" />
10
11</beans>

demo結構截圖以下:

萬事俱備,那咱們跑個單元測試看看

運行結果如咱們所料.可是具體要怎麼編碼,怎麼發送請求,又如何解碼好像也沒說啊.沒說?沒說就對了.在完結服務引用這個小專題後,還會重點和你們看一下dubbo中的編解碼,spi,javassist等重點內容源碼,等粗略把整個框架的思想都掌握後,再手把手臨摹一個五臟俱全(包含設計模式,dubbo架構設計)的簡易dubbo框架.總之一句話,關注肥朝便可.

敲黑板劃重點

爲何面試都喜歡問原理,難道都是爲了裝逼?固然不是,明白了原理,不少東西都是一通百通的.咱們來看mybatis的這道面試題.首先Mapper接口的原理,能夠參考我以前的別怕看源碼,一張圖搞定Mybatis的Mapper原理 ,其實說白了,就是給Mapper接口注入一個代理對象,而後動態代理對象調用方法會被攔截到invoke中,而後在這個invoke方法中,作了一些不可描述的事情(老司機能夠盡情YY).而這一切的前提,都是要無聲無息的把動態代理對象注入進去.其實注入進去的原理和dubbo也是同樣的,咱們簡單看兩個圖