前言

Active注解可以被框架中自动激活加载扩展，此Annotation用于配置扩展被自动激活加载条件，不过有时机上的选择。
理解：比如dubbo的Filter 拦截器，我们有很多的实现存在。但是有些是必须要立刻加载的，访问服务日志拦截器AccessLogFilter 如下：

  1. @Activate(group = PROVIDER, value = ACCESS_LOG_KEY)
  2. public class AccessLogFilter implements Filter

当提供者的URL中含有accesslog才加载，这里的控制就是需要Active 注解。首先，Dubbo加载这些文件，其次，单需要这个Filter时，使用ExtensionLoader 的方法getActivateExtension(URL url, String key) 来加载对应的实现，就能按条件激活了。

Active源码

  1. /**
  2.  * 这个注解能够自动激活某些的类
  3.  */
  4. @Documented
  5. @Retention(RetentionPolicy.RUNTIME)
  6. @Target({ElementType.TYPE, ElementType.METHOD})
  7. public @interface Activate {
  8.     //激活Group的过滤条件
  9.     String[] group() default {};
  11.     //Keys过滤条件
  12.     String[] value() default {};
  14.     //加载这些扩展的排序
  15.     int order() default 0;
  16. }

getExtension

ExtensionLoader 中含有ClassCache，用于加载标注Actives的Class。

  1. //cache actives类
  2. private final Map<String, Object> cachedActivates = new ConcurrentHashMap();
  4. //加载所有标注SPI的class，这个方法在加载所有的SPI实现时，里面有个chachedActivates的缓存代码。
  5. private Map<String, Class<?>> getExtensionClasses()
  7. //加载class时，拿到加载文件的name
  8. private void loadClass(Map<String, Class<?>> extensionClasses, java.net.URL resourceURL, Class<?> clazz, String name) throws NoSuchMethodException {
  9.     ...
  10.     String[] names = NAME_SEPARATOR.split(name);
  11.     if (ArrayUtils.isNotEmpty(names)) {
  12.         cacheActivateClass(clazz, names[0]);
  13.         for (String n : names) {
  14.             cacheName(clazz, n);
  15.             saveInExtensionClass(extensionClasses, clazz, n);
  16.         }
  17.     }
  18. }
  20. //找到name对应的class之后，看到是否含有类的Actives注解
  21. private void cacheActivateClass(Class<?> clazz, String name) {
  22. Activate activate = clazz.getAnnotation(Activate.class);
  23. if (activate != null) {
  24.     cachedActivates.put(name, activate);
  25. } else {
  26.     // support com.alibaba.dubbo.common.extension.Activate
  27.     com.alibaba.dubbo.common.extension.Activate oldActivate = clazz.getAnnotation(com.alibaba.dubbo.common.extension.Activate.class);
  28.     if (oldActivate != null) {
  29.         cachedActivates.put(name, oldActivate);
  30.     }
  31. }
  32. }

getActiveExtension(…)

这里所有的方法最后调用一个调用加载

  1. public List<T> getActivateExtension(URL url, String key) {
  2.     return getActivateExtension(url, key, null);
  3. }
  5. public List<T> getActivateExtension(URL url, String[] values) {
  6.     return getActivateExtension(url, values, null);
  7. }
  9. public List<T> getActivateExtension(URL url, String key, String group) {
  10.     String value = url.getParameter(key);
  11.     return getActivateExtension(url, StringUtils.isEmpty(value) ? null : COMMA_SPLIT_PATTERN.split(value), group);
  12. }

getActivateExtension

真正的加载

  1. public List<T> getActivateExtension(URL url, String[] values, String group) {
  2.     List<T> activateExtensions = new ArrayList<>();
  3.     List<String> names = values == null ? new ArrayList<>(0) : Arrays.asList(values);
  4.     if (!names.contains(REMOVE_VALUE_PREFIX + DEFAULT_KEY)) {
  5.         //加载SPI标记的所有的class，这时候含有Actives的类就会缓存下来
  6.         getExtensionClasses();
  7.         for (Map.Entry<String, Object> entry : cachedActivates.entrySet()) {
  8.             //spi 扩展名
  9.             String name = entry.getKey();
  10.             //Actives注解对应的values
  11.             Object activate = entry.getValue();
  13.             String[] activateGroup, activateValue;
  15.             if (activate instanceof Activate) {
  16.                 activateGroup = ((Activate) activate).group();
  17.                 activateValue = ((Activate) activate).value();
  18.             } else if (activate instanceof com.alibaba.dubbo.common.extension.Activate) {
  19.                 activateGroup = ((com.alibaba.dubbo.common.extension.Activate) activate).group();
  20.                 activateValue = ((com.alibaba.dubbo.common.extension.Activate) activate).value();
  21.             } else {
  22.                 continue;
  23.             }
  24.             //传入的参数group和标注的activeGroup是否一致
  25.             if (isMatchGroup(group, activateGroup)
  26.                     && !names.contains(name)
  27.                     && !names.contains(REMOVE_VALUE_PREFIX + name)
  28.                     && isActive(activateValue, url)) {
  29.                 activateExtensions.add(getExtension(name));
  30.             }
  31.         }
  32.         //排序Activate 具体实现在ActivateComparator里，实现了Comparator 接口compare方法
  33.         activateExtensions.sort(ActivateComparator.COMPARATOR);
  34.     }
  35.     List<T> loadedExtensions = new ArrayList<>();
  36.     for (int i = 0; i < names.size(); i++) {
  37.         String name = names.get(i);
  38.         if (!name.startsWith(REMOVE_VALUE_PREFIX)
  39.                 && !names.contains(REMOVE_VALUE_PREFIX + name)) {
  40.             //遍历所有没有排除的扩展名
  41.             if (DEFAULT_KEY.equals(name)) {
  42.                 if (!loadedExtensions.isEmpty()) {
  43.                     activateExtensions.addAll(0, loadedExtensions);
  44.                     loadedExtensions.clear();
  45.                 }
  46.             } else {
  47.                 //通过扩展名，加载扩展添加到结果集
  48.                 loadedExtensions.add(getExtension(name));
  49.             }
  50.         }
  51.     }
  52.     if (!loadedExtensions.isEmpty()) {
  53.         activateExtensions.addAll(loadedExtensions);
  54.     }
  55.     return activateExtensions;
  56. }

参考