vlambda博客
学习文章列表

private void loadDirectory(Map<String, Class<?>> extensionClasses, String dir,String type, boolean extensionLoaderClassLoaderFirst) { // 文件名称规则: 路径/包名.接口名 String fileName = dir + type; try { // 寻找classloader和url列表 Enumeration<java.net.URL> urls = null; ClassLoader classLoader = findClassLoader(); // try to load from ExtensionLoader's ClassLoader first // 如果需要的话, 需要先从当前类的ClassLoader中寻找 if (extensionLoaderClassLoaderFirst) { ClassLoader extensionLoaderClassLoader = ExtensionLoader.class.getClassLoader(); if (ClassLoader.getSystemClassLoader() != extensionLoaderClassLoader) { urls = extensionLoaderClassLoader.getResources(fileName); } } // 如果找不到任何的URL列表，则继续尝试去其当前线程的ClassLoader中寻找 if(urls == null || !urls.hasMoreElements()) { if (classLoader != null) { urls = classLoader.getResources(fileName); } else { urls = ClassLoader.getSystemResources(fileName); } } // 如果存在文件的话 if (urls != null) { while (urls.hasMoreElements()) { // 遍历每一个资源文件，并且进行加载资源信息到extensionClasses,  //主要功能是读取文件内容 java.net.URL resourceURL = urls.nextElement(); loadResource(extensionClasses, classLoader, resourceURL); } } } catch (Throwable t) { logger.error("Exception occurred when loading extension class "(interface: " + type + ", description file: " + fileName + ").", t); }}

private void loadResource(Map<String, Class<?>> extensionClasses, ClassLoaderclassLoader, java.net.URL resourceURL) { try { // 读取文件 try (BufferedReader reader = new BufferedReader(new InputStreamReader(resourceURL.openStream(), StandardCharsets.UTF_8))) { String line; 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) { try { // 则进行加载key=value的形式数据 String name = null; int i = line.indexOf('='); if (i > 0) { name = line.substring(0, i).trim(); line = line.substring(i + 1).trim(); } if (line.length() > 0) { // 对类信息进行加载操作 loadClass(extensionClasses, resourceURL, Class.forName(line, true, classLoader), name); } } catch (Throwable t) { IllegalStateException e = new IllegalStateException("Failed to load extension class (interface: " + type + ",class line: " + line + ") in " + resourceURL + ", cause: " + t.getMessage(), t); exceptions.put(line, e); } } } } } catch (Throwable t) { logger.error("Exception occurred when loading extension class" "(interface: " +type + ", class file: " + resourceURL + ") in " + resourceURL,t); }}

private void loadClass(Map<String, Class<?>> extensionClasses, java.net.URLresourceURL, Class<?> clazz, String name) throws NoSuchMethodException { // 当前扩展点的实现，必须是当前扩展接口的实现才可以 if (!type.isAssignableFrom(clazz)) { throw new IllegalStateException("Error occurred when loading extension" "class (interface: " +type + ", class line: " + clazz.getName() + "), class " + clazz.getName() + " is not subtype of interface."); } // 如果是包含了Adaptive注解，则认为是需要对扩展点包装的方法，这里只做了存储操作，存储至 //cachedAdaptiveClass中 if (clazz.isAnnotationPresent(Adaptive.class)) { cacheAdaptiveClass(clazz); } else if (isWrapperClass(clazz)) { // 判断是否是wapper类型, 是否构造函数中有该接口类型的传入 // wrapper类型的意思是，对当前的扩展点实现封装功能处理 cacheWrapperClass(clazz); } else { clazz.getConstructor(); // 寻找他是否已经定义过了名称, 这里就不继续往里面细看了,主要是获取当前类的 //org.apache.dubbo.common.Extension注解，如果有的话就使用这个名称，否则的话就是用当前类的 //简单名称 if (StringUtils.isEmpty(name)) { name = findAnnotationName(clazz); if (name.length() == 0) { throw new IllegalStateException("No such extension name for the" "class " + clazz.getName() + " in the config " + resourceURL); } } // 否则的话，就对这个名称和class做映射关系 String[] names = NAME_SEPARATOR.split(name); if (ArrayUtils.isNotEmpty(names)) { // 如果当前类拥有Activate注解，则将其进行添加到cachedActivates对象中，意味 //着需要执行 cacheActivateClass(clazz, names[0]); // 进行名称映射保存 for (String n : names) { cacheName(clazz, n); saveInExtensionClass(extensionClasses, clazz, n); } } }}

public T getExtension(String name) { if (StringUtils.isEmpty(name)) { throw new IllegalArgumentException("Extension name null"); } // 获取当前SPi的默认扩展实现类 if ("true".equals(name)) { return getDefaultExtension(); } // 获取当前类的holder，实现原理和cachedClasses的方式相同，都是建立同一个引用后再进行加锁 final Holder<Object> holder = getOrCreateHolder(name); Object instance = holder.get(); if (instance == null) { synchronized (holder) { instance = holder.get(); if (instance == null) { // 真正进行创建实例 instance = createExtension(name); holder.set(instance); } } } return (T) instance;}

private Holder<Object> getOrCreateHolder(String name) { // 获取当前名称的和对象Holder的映射关系 Holder<Object> holder = cachedInstances.get(name); if (holder == null) { // 如果不存在的话，则使用putIfAbsent的原子操作来设置值，这个值可以保证多线程的额情 //况下有值的时候不处理，没有值进行保存 cachedInstances.putIfAbsent(name, new Holder<>()); // 获取真实的holder处理器 holder = cachedInstances.get(name); } return holder;}

private T createExtension(String name) { // 从配置文件中加载所有的扩展类 可以得到配置项名称 到配置类的映射关系 Class<?> clazz = getExtensionClasses().get(name); if (clazz == null) { throw findException(name); } try { // 获取是否已经有实例了 T instance = (T) EXTENSION_INSTANCES.get(clazz); if (instance == null) { // 没有的话，同样适用putIfAbsent的方式来保证只会创建一个对象并且保存 EXTENSION_INSTANCES.putIfAbsent(clazz, clazz.newInstance()); instance = (T) EXTENSION_INSTANCES.get(clazz); } // 注入其他扩展点的实体，用于扩展点和其他的扩展点相互打通 injectExtension(instance); // 进行遍历所有的包装类信息，分别对包装的类进行包装实例化，并且返回自身引用 Set<Class<?>> wrapperClasses = cachedWrapperClasses; if (CollectionUtils.isNotEmpty(wrapperClasses)) { for (Class<?> wrapperClass : wrapperClasses) { // 同样进行注册其他扩展点的功能 instance = injectExtension((T) wrapperClass.getConstructor(type).newInstance(instance)); } } // 对扩展点进行初始化操作 initExtension(instance); return instance; } catch (Throwable t) { throw new IllegalStateException("Extension instance (name: " + name + ", "class: " +type + ") couldn't be instantiated: " + t.getMessage(), t); }}