不得不擴展
從SPI說起
ExtensionLoader
驗證自定義協(xié)議
不得不擴展
Dubbo分為很多邏輯層,對于各個層的接口蜂林,Dubbo都提供了很多種的實現(xiàn)遥诉,
對于需要滿足很多使用個性需求的框架來說,單單是多提供幾個實現(xiàn)是不夠的噪叙。
重要的是需要在框架設計層面有一個好的解決方案矮锈,能讓框架能應對不斷擴張的需求。
這樣才能在不改動最原始邏輯的基礎上睁蕾,不斷豐富框架的內(nèi)容苞笨。
Dubbo應對這種需求,實現(xiàn)了內(nèi)核+插件的方式子眶,草圖如下:
如何讓眾多的實現(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-