美文网首页
fescar源码分析-EnhancedServiceLoader

fescar源码分析-EnhancedServiceLoader

作者: do_young | 来源:发表于2019-01-25 15:58 被阅读74次

    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实现服务加载能力增强的整个过程。
    其实有很多技术框架都是基于这种方式来扩展类加载的方式,比如:

    相关文章

      网友评论

          本文标题:fescar源码分析-EnhancedServiceLoader

          本文链接:https://www.haomeiwen.com/subject/cxqsjqtx.html