dubbo扩展点机制

摘要：在中配置，以配置为例整个，最先使用的地方从里面读取这个配置使用接口的中获取具体的实现类中有两个值当主线程被外部终止时，会触发，执行的与方法通知下面的锁操作，主线程正常走完代码，并最终停止。

常见的一种在本地使用main方法启动spring的方法

    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"META-INF/spring/dubbo-demo-provider.xml"});
        context.start();
        ...
        //System.in.read(); // 按任意键退出
        context.close();
    }

这个大家应该都知道，通过com.alibaba.dubbo.container.Main.main方法来启动的。

public class Main {

    //在dubbo.properties中配置， 以配置dubbo.container=log4j,spring为例
    public static final String CONTAINER_KEY = "dubbo.container";

    public static final String SHUTDOWN_HOOK_KEY = "dubbo.shutdown.hook";

    private static final Logger logger = LoggerFactory.getLogger(Main.class);
    
    //整个dubbo，最先使用ExtensionLoader的地方
    private static final ExtensionLoader loader = ExtensionLoader.getExtensionLoader(Container.class);

    private static volatile boolean running = true;

    public static void main(String[] args) {
        try {
            //1. 从dubbo.properties里面读取dubbo.container这个配置；
            if (args == null || args.length == 0) {
                String config = ConfigUtils.getProperty(CONTAINER_KEY, loader.getDefaultExtensionName());
                args = Constants.COMMA_SPLIT_PATTERN.split(config);
            }
            //2. 使用Container接口的ExtensionLoader中获取具体的Container实现类；
            final List containers = new ArrayList();
            //agrs中有两个值 "log4j,spring"
            for (int i = 0; i < args.length; i++) {
                containers.add(loader.getExtension(args[i]));
            }
            logger.info("Use container type(" + Arrays.toString(args) + ") to run dubbo serivce.");

            if ("true".equals(System.getProperty(SHUTDOWN_HOOK_KEY))) {
                //5. 当主线程被外部终止时，会触发 shutdownhook，执行Container的stop与close方法
                Runtime.getRuntime().addShutdownHook(new Thread() {
                    public void run() {
                        for (Container container : containers) {
                            try {
                                container.stop();
                                logger.info("Dubbo " + container.getClass().getSimpleName() + " stopped!");
                            } catch (Throwable t) {
                                logger.error(t.getMessage(), t);
                            }
                            synchronized (Main.class) {
                                running = false;
                                //6.通知下面的锁操作，主线程正常走完代码，并最终停止。
                                Main.class.notify();
                            }
                        }
                    }
                });
            }
            //3. 执行Container接口的start方法；
            for (Container container : containers) {
                container.start();
                logger.info("Dubbo " + container.getClass().getSimpleName() + " started!");
            }
            System.out.println(new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss]").format(new Date()) + " Dubbo service server started!");
        } catch (RuntimeException e) {
            e.printStackTrace();
            logger.error(e.getMessage(), e);
            System.exit(1);
        }
        //4. 用一个死循环，保留主线程；
        synchronized (Main.class) {
            while (running) {
                try {
                    Main.class.wait();
                } catch (Throwable e) {
                }
            }
        }
    }

}

明确下面几个概念

扩展接口 com.alibaba.dubbo.container.Container

扩展配置 dubbo.container = log4j,spring

扩展实现

com.alibaba.dubbo.container.log4j.Log4jContainer

  log4j的日志初始工作，当多进程启动时，做日志隔离

com.alibaba.dubbo.container.logback.LogbackContainer

  logback的日志初始工作

com.alibaba.dubbo.container.spring.SpringContainer

  spring容器的启动，使用spring容器来实现aop与ioc，**【这个配置，往往是必选的】**

com.alibaba.dubbo.container.jetty.JettyContainer

  启动一个Servlet Web容器，提供了一个web页面，做一些监控之类的时期，注意：在写HttpResponse的时候，也是用SPI机制，不同的请 

求页面经过PageServlet交个不同的PageHandler去实现

com.alibaba.dubbo.monitor.simple.RegistryContainer

我们来想一个这样的问题，上面是dubbo支持的容器，包括log4j、logback、spring、jetty、registry，那么dubbo是如何通过配置的方式来实现容器的可扩展的呢？假如给你做你怎么做呢？

spring的API(Application Programming Interface、应用编程接口)方式,接口多实现类的动态调动；

JDK标准的SPI(Service Provider Interface、)机制
dubbo的扩展点加载机制是从JDK的spi机制加强而来。
dubbo改进了JDK标准的SPI机制以下问题：

spring与JDK的SPI都会一次性实例化扩展点所有实现，如果有扩展实现初始化很耗时，但如果没用上，也会加载。

JDK的SPI机制不支持Ioc与Aop功能，而dubbo中的扩展点可以直接setter注入其他扩展点。【这个一部分，下面会有涉及，我们会在下一个文章中详细描述】

关键说明，

必须带有SPI注解

注解里面的值，是默认实现，在ExtensionLoader源码去细讲。

/**
 * Container. (SPI, Singleton, ThreadSafe)
 *
 * @author william.liangf
 */
@SPI("spring")
public interface Container {

    /**
     * start.
     */
    void start();

    /**
     * stop.
     */
    void stop();

}

关键说明，

1.  ExtensionLoader有一个private的构造函数，并通过getExtensionLoader这个镜头方法返回实例，是一个单例工厂类。
2.  一个扩展接口对应一个ExtensionLoader实例，也就是说最终我们加载了多少个扩展接口(注意是扩展接口，而不是扩展实现类)，就多少个实例；
3.  关键static final变量，所有实例共享

    private static final ConcurrentMap, ExtensionLoader> EXTENSION_LOADERS = new ConcurrentHashMap, ExtensionLoader>();

    private static final ConcurrentMap, Object> EXTENSION_INSTANCES = new ConcurrentHashMap, Object>();

4.  所有的final变量，单个实例共享，每一个扩展接口对应的ExtensionLoader都不一样

    //扩展接口名称
    private final Class type;
    //也是一个扩展接口，用于注入扩展接口中需要注入的类，实现dubbo的扩展点的自动注入
    private final ExtensionFactory objectFactory;

    private final ConcurrentMap, String> cachedNames = new ConcurrentHashMap, String>();

    private final Holder>> cachedClasses = new Holder>>();

    private final Map cachedActivates = new ConcurrentHashMap();
    private final ConcurrentMap> cachedInstances = new ConcurrentHashMap>();
    private final Holder