EnhancedServiceLoader功能说明
fescar在fescar-core工程的com.alibaba.fescar.core.context.ContextCoreLoader
会使用fescar-common组件中的EnhancedServiceLoader
类;
ContextCoreLoader
就是用来加载ContextCore
接口的实现类,其中主要的加载的实现逻辑就是由EnhancedServiceLoader
来实现的,如果获取不到,主默认使用ThreadLocalContextCore
:
public class ContextCoreLoader {
private static class ContextCoreHolder {
private static ContextCore INSTANCE;
static {
ContextCore contextCore = EnhancedServiceLoader.load(ContextCore.class);
if (contextCore == null) {
// Default
contextCore = new ThreadLocalContextCore();
}
INSTANCE = contextCore;
}
}
public static ContextCore load() {
return ContextCoreHolder.INSTANCE;
}
}
那么EnhancedServiceLoader
的作用就是要通过一定规则加载指定接口服务的实现类。下面通过代码分析它的加载规则。
源码分析
providers 属性
EnhancedServiceLoader
是一个单例对象,其中有一个Map类型的providers
静态属性,由于该属性会被并发读写,为了保证线程安全,使用了ConcurrentHashMap
的实例。其中键为要加载接口的类型,值为有序的链表类型,存储接口的实现类(一个要加载的接口有多个实现类)。
private static Map<Class, List<Class>> providers = new ConcurrentHashMap<Class, List<Class>>();
load(Class<S> service)方法
当调用EnhancedServiceLoader
的load方法时,会直接调用内部的loadFile()
方法
public static <S> S load(Class<S> service) throws EnhancedServiceNotFoundException {
return loadFile(service, null, findClassLoader());
}
findAllExtensionClass()方法
在loadFile()
方法中会先通过providers
属性查找是否已经缓存有想要加载的实现类,如果没有就同步加载。加载逻辑由findAllExtensionClass()
实现:
synchronized (service) {
extensions = providers.get(service);
if (extensions == null) {
extensions = findAllExtensionClass(service, activateName, loader);
foundFromCache = false;
providers.put(service, extensions);
}
}
加载完成以后对接口加载到的实现列表接注解的优化级进行排序。
Collections.sort(extensions, new Comparator<Class>() {
@Override
public int compare(Class c1, Class c2) {
Integer o1 = 0;
Integer o2 = 0;
@SuppressWarnings("unchecked")
LoadLevel a1 = (LoadLevel) c1.getAnnotation(LoadLevel.class);
@SuppressWarnings("unchecked")
LoadLevel a2 = (LoadLevel) c2.getAnnotation(LoadLevel.class);
if (a1 != null) {
o1 = a1.order();
}
if (a2 != null) {
o2 = a2.order();
}
return o1.compareTo(o2);
}
});
loadFile(Class<?> service, String dir, ClassLoader classLoader, List<Class> extensions)方法
在findAllExtensionClass()
方法中会使用loadFile()
来加载接口的实现类。
loadFile(service, SERVICES_DIRECTORY, loader, extensions);
loadFile(service, FESCAR_DIRECTORY, loader, extensions);
它会使用应用的classloader来加载classpath下的如下文件:
META-INF/services/com.alibaba.fescar.core.context.ContextCore
META-INF/fescar/com.alibaba.fescar.core.context.ContextCore
读取文件中的数据,如果是注释则忽略,否则读取该行数据(该数据就是接口的实现类名)转换为Class,添加到provider对象中。
while ((line = reader.readLine()) != null) {
final int ci = line.indexOf('#');
if (ci >= 0) {
line = line.substring(0, ci);
}
line = line.trim();
if (line.length() > 0) {
extensions.add(Class.forName(line, true, classLoader));
}
}
最后从provider中取出实现类链表,取出优化级最高的类,并创建实例:
Class<?> extension = extensions.get(extensions.size() - 1);// 最大的一个
S result = service.cast(extension.newInstance());
以上就是EnhancedServiceLoader
实现服务加载能力增强
的整个过程。
其实有很多技术框架都是基于这种方式来扩展类加载的方式,比如:
- servlet3.0中对ServletContainerInitializer接口的实现。
网友评论