本文共 7833 字,大约阅读时间需要 26 分钟。
ExtensionLoaderextensionLoader = ExtensionLoader.getExtensionLoader(Protocol.class);Protocol http = extensionLoader.getExtension("dubbo");System.out.println(http);
上面这个Demo就是Dubbo常见的写法,表示获取"dubbo"对应的Protocol扩展点。Protocol是一个接口。
在ExtensionLoader类的内部有一个static的ConcurrentHashMap,用来缓存某个接口类型所对应的ExtensionLoader实例
ExtensionLoader表示一个扩展点加载器,在这个类中除开有上文的Map外,还有两个非常重要的属性:
构造方法如下:
private ExtensionLoader(Class type) { this.type = type; objectFactory = (type == ExtensionFactory.class ? null : ExtensionLoader.getExtensionLoader(ExtensionFactory.class).getAdaptiveExtension());}
从上面的构造方法中可以看到一段比较特殊的代码:
ExtensionLoader.getExtensionLoader(ExtensionFactory.class).getAdaptiveExtension()
在ExtensionLoader中有三个常用的方法:
其中,什么是自适应的扩展点实例?它其实就是当前这个接口类型的一个代理类,可以通过这个代理类去获取某个名字的扩展点。那为什么要这么设计呢?
这是因为对于某个接口的实现类实例,并不是仅仅只能通过Dubbo框架来生成,比如通过getExtension("dubbo")方法所获得扩展点实例,是由Dubbo框架根据名字对应的实现类帮我们生成的一个实例对象。而有的时候,我们需要从Dubbo之外去获取实例对象,比如从Spring容器中根据名字取获取bean,来作为一个扩展点实例。
所以ExtensionFactory表示一个扩展点工厂,在Dubbo中有三个实现类:
所以回到上文的那么代码,它拿到的就是一个AdaptiveExtensionFactory实例, objectFactory表示一个扩展点实例工厂。
在调用getExtension去获取一个扩展点实例后,会对实例进行缓存,下次再获取同样名字的扩展点实例时就会从缓存中拿了。
在调用createExtension(String name)方法去创建一个扩展点实例时,要经过以下几个步骤:
getExtensionClasses()是用来加载当前接口所有的扩展点实现类的,返回一个Map。之后可以从这个Map中按照指定的name获取对应的扩展点实现类。
当把当前接口的所有扩展点实现类都加载出来后也会进行缓存,下次需要加载时直接拿缓存中的。
Dubbo在加载一个接口的扩展点时,思路是这样的:
这里其实会设计到老版本兼容的逻辑,不解释了。
loadResource方法就是完成对文件内容的解析,按行进行解析,会解析出"="两边的内容,"="左边的内容就是扩展点的name,右边的内容就是扩展点实现类,并且会利用ExtensionLoader类的类加载器来加载扩展点实现类。
然后调用loadClass方法对name和扩展点实例进行详细的解析,并且最终把他们放到Map中去。
loadClass方法会做如下几件事情:
至此,加载类就走完了。
回到createExtension(String name)方法中的逻辑,当前这个接口的所有扩展点实现类都扫描完了之后,就可以根据用户所指定的名字,找到对应的实现类了,然后进行实例化,然后进行IOC(依赖注入)和AOP。
dubbo中也实现了一套非常简单的AOP,就是利用Wrapper,如果一个接口的扩展点中包含了多个Wrapper类,那么在实例化完某个扩展点后,就会利用这些Wrapper类对这个实例进行包裹,比如:现在有一个DubboProtocol的实例,同时对于Protocol这个接口还有很多的Wrapper,比如ProtocolFilterWrapper、ProtocolListenerWrapper,那么,当对DubboProtocol的实例完成了IOC之后,就会先调用new ProtocolFilterWrapper(DubboProtocol实例)生成一个新的Protocol的实例,再对此实例进行IOC,完了之后,会再调用new ProtocolListenerWrapper(ProtocolFilterWrapper实例)生成一个新的Protocol的实例,然后进行IOC,从而完成DubboProtocol实例的AOP。
上文多次提到了Adaptive,表示一个接口的自适应类,这里详细的来讲讲。
通过getAdaptiveExtension方法获得的实例就是Adaptive类的实例,在Dubbo中有两种方式来针对某个接口得到一个Adaptive类,一种是在某个接口的实现类上指定一个@Adaptive注解,那么该类就是这个接口的Adaptive类,或者利用Dubbo的默认实现来得到一个Adaptive类,一个接口只能有一个Adaptive类。
如果是手动实现的Adaptive类,那么自适应逻辑就是自己实现的。如果是有Dubbo默认实现的,那么我们就看看Dubbo是如何实现Adaptive类的。
createAdaptiveExtensionClass方法就是Dubbo中默认生成Adaptive类实例的逻辑。说白了,这个实例就是当前这个接口的一个代理对象。比如下面的代码:
ExtensionLoaderextensionLoader = ExtensionLoader.getExtensionLoader(Protocol.class);Protocol protocol = extensionLoader.getAdaptiveExtension();
这个代码就是Protocol接口的一个代理对象,那么代理逻辑就是在new AdaptiveClassCodeGenerator(type, cachedDefaultName).generate()方法中。
看个例子,Protocol接口的Adaptive类:
package org.apache.dubbo.rpc;import org.apache.dubbo.common.extension.ExtensionLoader;public class Protocol$Adaptive implements org.apache.dubbo.rpc.Protocol { public void destroy() { throw new UnsupportedOperationException("The method public abstract void org.apache.dubbo.rpc.Protocol.destroy() of interface org.apache.dubbo.rpc.Protocol is not adaptive method!"); } public int getDefaultPort() { throw new UnsupportedOperationException("The method public abstract int org.apache.dubbo.rpc.Protocol.getDefaultPort() of interface org.apache.dubbo.rpc.Protocol is not adaptive method!"); } public org.apache.dubbo.rpc.Exporter export(org.apache.dubbo.rpc.Invoker arg0) throws org.apache.dubbo.rpc.RpcException { if (arg0 == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument == null"); if (arg0.getUrl() == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument getUrl() == null"); org.apache.dubbo.common.URL url = arg0.getUrl(); String extName = ( url.getProtocol() == null ? "dubbo" : url.getProtocol() ); if(extName == null) throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.Protocol) name from url (" + url.toString() + ") use keys([protocol])"); org.apache.dubbo.rpc.Protocol extension = (org.apache.dubbo.rpc.Protocol)ExtensionLoader.getExtensionLoader(org.apache.dubbo.rpc.Protocol.class).getExtension(extName); return extension.export(arg0); } public org.apache.dubbo.rpc.Invoker refer(java.lang.Class arg0, org.apache.dubbo.common.URL arg1) throws org.apache.dubbo.rpc.RpcException { if (arg1 == null) throw new IllegalArgumentException("url == null"); org.apache.dubbo.common.URL url = arg1; String extName = ( url.getProtocol() == null ? "dubbo" : url.getProtocol() ); if(extName == null) throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.Protocol) name from url (" + url.toString() + ") use keys([protocol])"); org.apache.dubbo.rpc.Protocol extension = (org.apache.dubbo.rpc.Protocol)ExtensionLoader.getExtensionLoader(org.apache.dubbo.rpc.Protocol.class).getExtension(extName); return extension.refer(arg0, arg1); }}
可以看到,Protocol接口中有四个方法,但是只有export和refer两个方法进行代理。为什么?因为Protocol接口中在export方法和refer方法上加了@Adaptive注解。但是,不是只要在方法上加了@Adaptive注解就可以进行代理,还有其他条件,比如:
所以,可以发现,某个接口的Adaptive对象,在调用某个方法时,是通过该方法中的URL参数,通过调用ExtensionLoader.getExtensionLoader(com.luban.Car.class).getExtension(extName);得到一个扩展点实例,然后调用该实例对应的方法。
上文说到,每个扩展点都有一个name,通过这个name可以获得该name对应的扩展点实例,但是有的场景下,希望一次性获得多个扩展点实例,可以通过传入多个name来获取,可以通过识别URL上的信息来获取:
extensionLoader.getActivateExtension(url, new String[]{"car1", "car2"}); 这个可以拿到name为car1和car2的扩展类实例,同时还会通过传入的url寻找可用的扩展类, 怎么找的呢?
在一个扩展点类上,可以添加@Activate注解,这个注解的属性有:
转载地址:http://udbnb.baihongyu.com/