梳理Dubbo擴展的理解

不得不擴展

從SPI說起

ExtensionLoader

驗證自定義協(xié)議


不得不擴展

Dubbo分為很多邏輯層,對于各個層的接口蜂林,Dubbo都提供了很多種的實現(xiàn)遥诉,
對于需要滿足很多使用個性需求的框架來說,單單是多提供幾個實現(xiàn)是不夠的噪叙。
重要的是需要在框架設計層面有一個好的解決方案矮锈,能讓框架能應對不斷擴張的需求。
這樣才能在不改動最原始邏輯的基礎上睁蕾,不斷豐富框架的內(nèi)容苞笨。

Dubbo應對這種需求,實現(xiàn)了內(nèi)核+插件的方式子眶,草圖如下:


image

如何讓眾多的實現(xiàn)呛凶,以統(tǒng)一的方式準確地接入Dubbo框架中搔体?這是重點需要解決的問題丁恭。

如果需要靈活鲤遥,硬編碼的方式肯定是不行的,
從編碼的角度來說渴杆,如果能提供配置寥枝,讓框架解析配置宪塔,這是比較好的方法。(如果是我脉顿,我會這樣想)

從SPI說起

Service Provider Interface蝌麸,是一種設計方式,而不是某種具體的API艾疟,可以理解為:通過接口尋找實現(xiàn)類来吩。
一般說來,面向接口編程蔽莱,接口實現(xiàn)方弟疆,可以提供多種實現(xiàn),從而在調(diào)用方盗冷,屏蔽實現(xiàn)的細節(jié)怠苔。
SPI設計方式,在此基礎上做了一定的擴展仪糖,同樣柑司,服務調(diào)用方不在意接口的實現(xiàn)細,并且接口由調(diào)用方制定锅劝,實現(xiàn)是在另外獨立的包中攒驰。
有點抽象,我們可以用生活中很常見的事情來模擬下這種方案:

某天故爵,幼兒園的老師布置了一個作業(yè):小朋友明天都帶一條小魚來幼兒園玻粪,用玻璃瓶裝好,我們明天一起觀察小魚诬垂,
然后評選出最漂亮的小魚拍照放貼教室墻上劲室。
消息傳達到家長那里,第二天结窘,有人帶小鯽魚很洋,有人帶小金魚,有人帶小丑魚隧枫,咦蹲缠,蛋蛋,你帶的是條魚干嗎悠垛?!

玩笑結(jié)束 :)
首先娜谊,老師布置的作業(yè)确买,我們可以理解為一個接口,這個接口是由需要使用接口實現(xiàn)的人發(fā)布的纱皆,它的目的就是多樣化湾趾,因為作業(yè)(接口)的實現(xiàn)方芭商,是各位小朋友,大家對這個接口的實現(xiàn)肯定不是一樣的搀缠。這樣在上課的時候(程序運行期間)铛楣,大家都把自己的實現(xiàn)帶到教室,由老師(調(diào)用方)來使用艺普,至于使用哪個簸州,是需要看當時具體的情況。

從以上的例子可以看出歧譬,接口在邏輯上岸浑,和接口的使用者更接近,而不是實現(xiàn)者瑰步。

Java6提供了一種SPI實現(xiàn)矢洲,并且提供一個ServiceLoader類來加載對象。
它約定接口的實現(xiàn)者實現(xiàn)接口后缩焦,在自己所在項目的目錄(不一定和調(diào)用者在一起項目內(nèi))META-INF\services\下读虏,創(chuàng)建一個接口全類名為名字的文件,將實現(xiàn)類的全類名寫進去袁滥。
ServiceLoader的例子網(wǎng)上有很多盖桥,此處不再提了。

ExtensionLoader

SPI為Dubbo需要解決的擴展問題提供了很好的思路呻拌。但是JDK原生的SPI實現(xiàn)葱轩,不適合拿來用。

  • 一次性會加載出接口的所有實現(xiàn)藐握,這樣的性能不會高靴拱;

  • 沒有辦法做到對內(nèi)部的擴展對象進行級聯(lián)初始化;

  • 默認實現(xiàn)不是單例的猾普;

Dubbo自己做了一套基于SPI機制的加載和緩存擴展的實現(xiàn)袜炕,ExtensionLoader
它著重解決如下的幾個方面的問題:

  • 對于某個擴展接口初家,需要可以加載出所有的實現(xiàn)偎窘,保證每個實現(xiàn)都是單例的;
  • 需要能在運行時決定需要使用哪個擴展溜在;

為了適配各種實現(xiàn)陌知,Dubbo對每個擴展接口,都對應生成一個唯一的Adaptive對象掖肋,這個對象是個適配器仆葡,也可以成為代理,它
會根據(jù)每個擴展功能的實際配置志笼,決定需要用哪個實現(xiàn)沿盅。
并且對加載出來的擴展Adaptive對象把篓、Class對象、擴展對象和擴展名的對應關系都是存儲在static容器中
在加載的時候甚至還做了雙重判空和必要的同步腰涧。

ExtensionLoader默認在如下三個目錄加載擴展:
private static final String SERVICES_DIRECTORY = "META-INF/services/";
private static final String DUBBO_DIRECTORY = "META-INF/dubbo/";
private static final String DUBBO_INTERNAL_DIRECTORY = "META-INF/dubbo/internal/";

每個實現(xiàn)都會有一個對應的key韧掩,例如:

default=cn.irving.extension.DefaultExtension
sw=cn.irving.extension.SWExtension
adaptive=cn.irving.extension.AdaptiveExtension

如果某個實現(xiàn)上添加了@Adaptive注解,就說明是個適配類窖铡,配置類本身不提供服務疗锐,它會去ExtensionLoader中加載實現(xiàn)對象,并且調(diào)用相同的方法并返回万伤。
如果沒有任何實現(xiàn)由這個注解窒悔,就需要在接口的方法上添加并且提供URL作為參數(shù),從中提取需要適配的方法敌买,臨時構(gòu)造一個適配器類简珠,這個適配器類,功能和上面的一致虹钮。

擴展實現(xiàn)通過擴展適配器被內(nèi)核使用聋庵,這樣外部的實現(xiàn)也能融合到框架內(nèi)部。

驗證自定義協(xié)議

可以弄個例子芙粱,簡單地試一下祭玉,做一個簡單的dubbo例子,測試一下dubbo是否可以接納我們自己定義的Protocol:
1春畔、創(chuàng)建接口:

public interface DemoService {
    String sayHello(String name);
}

2脱货、創(chuàng)建provider實現(xiàn):

public class DemoServiceImpl implements DemoService {
    public String sayHello(String name) {
        return "Hello world, "+name;
    }
}

3、配置dubbo的provider-xml和consumer-xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <dubbo:application name="demo-provider-zk"/>
    <dubbo:registry address="zookeeper://localhost:2181" check="false"/>
    <dubbo:protocol name="test" port="20880"/>
    <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService"/>
    <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl"/>
</beans>

注意律姨,此處用到的協(xié)議名為:test

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <dubbo:application name="demo-consumer" logger="log4j"/>
    <dubbo:registry address="zookeeper://localhost:2181" check="false"/>
    <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" check="false"/>
</beans>

4振峻、定義服務啟動類和消費者類:

public class App 
{
    public static void main( String[] args )throws Exception
    {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{
                "spring-config-zk-provider.xml"
        });
        context.start();
        System.in.read();
    }
}
public class Consumer {
    public static void main(String[] args) throws IOException, InterruptedException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{
               "spring-config-zk-consumer.xml"
        });
        context.start();
        DemoService demoService = (DemoService)context.getBean("demoService");
        System.in.read();
        for(int i = 0 ; i < 3 ; i++) {
            System.out.println(demoService.sayHello("SUN-中文")+i);
        }
    }
}

此時如果啟動服務,將會得到如下的報錯:

Exception in thread "main" java.lang.IllegalStateException: No such extension com.alibaba.dubbo.rpc.Protocol by name test

找不到Protocol實現(xiàn):(

接下來我們自己定義一個Protocol擴展择份,實現(xiàn)Protocol接口:

public class TestProtocol extends DubboProtocol {
    @Override
    public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
        System.out.println("THIS IS TEST EXPORTER");
        return super.export(invoker);
    }
}

這個協(xié)議比較簡單扣孟,全部都用DubboProtocol的實現(xiàn),為了證明它用到了這個實現(xiàn)荣赶,在export服務的時候打印一句話凤价。

然后將我們的擴展配置在/META-INF/dubbo/com.alibaba.dubbo.rpc.Protocol中:

test=cn.irving.extension.TestProtocol

然后再運行服務端和客戶端,將得到如下的結(jié)果:
服務端:

Connected to the target VM, address: '127.0.0.1:58434', transport: 'socket'
log4j:WARN No appenders could be found for logger (org.springframework.core.env.StandardEnvironment).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
THIS IS TEST EXPORTER

客戶端:

Hello world, SUN-中文0
Hello world, SUN-中文1
Hello world, SUN-中文2

-EOF-

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末拔创,一起剝皮案震驚了整個濱河市利诺,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌剩燥,老刑警劉巖立轧,帶你破解...
    沈念sama閱讀 216,544評論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異,居然都是意外死亡氛改,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,430評論 3 392
  • 文/潘曉璐 我一進店門比伏,熙熙樓的掌柜王于貴愁眉苦臉地迎上來胜卤,“玉大人,你說我怎么就攤上這事赁项「瘐铮” “怎么了?”我有些...
    開封第一講書人閱讀 162,764評論 0 353
  • 文/不壞的土叔 我叫張陵悠菜,是天一觀的道長舰攒。 經(jīng)常有香客問我,道長悔醋,這世上最難降的妖魔是什么摩窃? 我笑而不...
    開封第一講書人閱讀 58,193評論 1 292
  • 正文 為了忘掉前任,我火速辦了婚禮芬骄,結(jié)果婚禮上猾愿,老公的妹妹穿的比我還像新娘。我一直安慰自己账阻,他們只是感情好蒂秘,可當我...
    茶點故事閱讀 67,216評論 6 388
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著淘太,像睡著了一般姻僧。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上蒲牧,一...
    開封第一講書人閱讀 51,182評論 1 299
  • 那天撇贺,我揣著相機與錄音,去河邊找鬼造成。 笑死显熏,一個胖子當著我的面吹牛,可吹牛的內(nèi)容都是我干的晒屎。 我是一名探鬼主播喘蟆,決...
    沈念sama閱讀 40,063評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼鼓鲁!你這毒婦竟也來了蕴轨?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 38,917評論 0 274
  • 序言:老撾萬榮一對情侶失蹤骇吭,失蹤者是張志新(化名)和其女友劉穎橙弱,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,329評論 1 310
  • 正文 獨居荒郊野嶺守林人離奇死亡棘脐,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,543評論 2 332
  • 正文 我和宋清朗相戀三年斜筐,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片蛀缝。...
    茶點故事閱讀 39,722評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡顷链,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出屈梁,到底是詐尸還是另有隱情嗤练,我是刑警寧澤,帶...
    沈念sama閱讀 35,425評論 5 343
  • 正文 年R本政府宣布在讶,位于F島的核電站煞抬,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏构哺。R本人自食惡果不足惜革答,卻給世界環(huán)境...
    茶點故事閱讀 41,019評論 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望遮婶。 院中可真熱鬧蝗碎,春花似錦、人聲如沸旗扑。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,671評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽臀防。三九已至眠菇,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間袱衷,已是汗流浹背捎废。 一陣腳步聲響...
    開封第一講書人閱讀 32,825評論 1 269
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留致燥,地道東北人登疗。 一個月前我還...
    沈念sama閱讀 47,729評論 2 368
  • 正文 我出身青樓,卻偏偏與公主長得像嫌蚤,于是被迫代替她去往敵國和親辐益。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 44,614評論 2 353

推薦閱讀更多精彩內(nèi)容