深入学习Motan系列（三）——服务发布

袋鼠回头看了看文章，有些啰嗦，争取语音简练，不断提高表达力！袋鼠奋起直追！

注：此篇文章，暂时为了以后时间线排序的需要，暂时发表出来，可是仍然有许多地方需要改写。自己打算把服务端发布，客户端订阅都搞定后，再修改这部分。

接着上篇继续分析doExport（）

。。。前面的部分就做了一件事，将相关配置信息转换成URL类。。。
下面的两行也就做了一件事，委托configHandler，生成exporter对象

1 ConfigHandler configHandler = ExtensionLoader.getExtensionLoader(ConfigHandler.class).getExtension(MotanConstants.DEFAULT_VALUE);

        exporters.add(configHandler.export(interfaceClass, ref, urls));

public <T> Exporter<T> export(Class<T> interfaceClass, T ref, List<URL> registryUrls) {

　　　　　  // embed的属性，embed则是保存了服务URL
        String serviceStr = StringTools.urlDecode(registryUrls.get(0).getParameter(URLParamType.embed.getName()));
        URL serviceUrl = URL.valueOf(serviceStr);

        // export service
        
        String protocolName = serviceUrl.getParameter(URLParamType.protocol.getName(), URLParamType.protocol.getValue());
           // 查找协议，即DefaultRpcProtocol对象
        Protocol orgProtocol = ExtensionLoader.getExtensionLoader(Protocol.class).getExtension(protocolName);
           // 创建提供service的provider
        Provider<T> provider = getProvider(orgProtocol, ref, serviceUrl, interfaceClass);
        // 利用protocol decorator来增加filter特性
        Protocol protocol = new ProtocolFilterDecorator(orgProtocol);
           // 暴露过程 它是委托给具体协议，调用协议类（即DefaultRpcProtocol对象）的export方法来进行暴露
        Exporter<T> exporter = protocol.export(provider, serviceUrl);

        // register service 暴露之后注册服务，注意这里的先后顺序。为了保证，通知上线时，已经完成暴露的过程。
        register(registryUrls, serviceUrl);

        return exporter;
    }

我们进到第13行的方法

    public <T> Exporter<T> export(Provider<T> provider, URL url) {
　　　　　　// decorateWithFilter(provider, url)的结果为参数provider本身，filter为null
        return protocol.export(decorateWithFilter(provider, url), url);
    }

public <T> Exporter<T> export(Provider<T> provider, URL url) {
        if (url == null) {
            throw new MotanFrameworkException(this.getClass().getSimpleName() + " export Error: url is null",
                    MotanErrorMsgConstant.FRAMEWORK_INIT_ERROR);
        }

        if (provider == null) {
            throw new MotanFrameworkException(this.getClass().getSimpleName() + " export Error: provider is null, url=" + url,
                    MotanErrorMsgConstant.FRAMEWORK_INIT_ERROR);
        }

　　　　　　 // 这里的url是服务url
        String protocolKey = MotanFrameworkUtil.getProtocolKey(url);

        synchronized (exporterMap) {
            Exporter<T> exporter = (Exporter<T>) exporterMap.get(protocolKey);

            if (exporter != null) {
                throw new MotanFrameworkException(this.getClass().getSimpleName() + " export Error: service already exist, url=" + url,
                        MotanErrorMsgConstant.FRAMEWORK_INIT_ERROR);
            }

               // 在DefaultRpcExporter的类初始化中，根据当前系统的SPI配置，找到EndpointFactory的实现类，并创建一个Server对象，
　　　　　　　　 // 由Server对象的server.open()最终完成transport的网络层暴露。
               // 网络层暴露的Netty部分，暂时略过
22             exporter = createExporter(provider, url);
23             exporter.init();

            exporterMap.put(protocolKey, exporter);

            LoggerUtil.info(this.getClass().getSimpleName() + " export Success: url=" + url);

            return exporter;
        }


    }

接下来，是具体的服务注册部分。

registryUrls是zookeeper的注册地址，serviceUrl则是提供需要的参数。

private void register(List<URL> registryUrls, URL serviceUrl) {

        for (URL url : registryUrls) {
            // 根据check参数的设置，register失败可能会抛异常，上层应该知晓
　　　　　　　　 // SPI生成ZookeeperRegistryFactory
            RegistryFactory registryFactory = ExtensionLoader.getExtensionLoader(RegistryFactory.class).getExtension(url.getProtocol());
            if (registryFactory == null) {
                throw new MotanFrameworkException(new MotanErrorMsg(500, MotanErrorMsgConstant.FRAMEWORK_REGISTER_ERROR_CODE,
                        "register error! Could not find extension for registry protocol:" + url.getProtocol()
                                + ", make sure registry module for " + url.getProtocol() + " is in classpath!"));
            }
            Registry registry = registryFactory.getRegistry(url);
            registry.register(serviceUrl);
        }
    }

根据url得到注册地址的字符串，然后缓存中查询，没有的话，初始化生成ZookeeperRegistry的实例，并返回。

public Registry getRegistry(URL url) {
        String registryUri = getRegistryUri(url);
        try {
            lock.lock();
            Registry registry = registries.get(registryUri);
            if (registry != null) {
                return registry;
            }
               // zookeeper的相关代码封装在下面方法中
            registry = createRegistry(url);
            if (registry == null) {
                throw new MotanFrameworkException("Create registry false for url:" + url, MotanErrorMsgConstant.FRAMEWORK_INIT_ERROR);
            }
            registries.put(registryUri, registry);
            return registry;
        } catch (Exception e) {
            throw new MotanFrameworkException("Create registry false for url:" + url, e, MotanErrorMsgConstant.FRAMEWORK_INIT_ERROR);
        } finally {
            lock.unlock();
        }
    }