2.2 导出 Dubbo 服务

前置工作做完，接下来就可以进行服务导出了。服务导出分为导出到本地 (JVM)，和导出到远程。在深入分析服务导出的源码前，我们先来从宏观层面上看一下服务导出逻辑。如下：

  1. private void doExportUrlsFor1Protocol(ProtocolConfig protocolConfig, List<URL> registryURLs) {
  3.     // 省略无关代码
  5.     if (ExtensionLoader.getExtensionLoader(ConfiguratorFactory.class)
  6.             .hasExtension(url.getProtocol())) {
  7.         // 加载 ConfiguratorFactory，并生成 Configurator 实例，然后通过实例配置 url
  8.         url = ExtensionLoader.getExtensionLoader(ConfiguratorFactory.class)
  9.                 .getExtension(url.getProtocol()).getConfigurator(url).configure(url);
  10.     }
  12.     String scope = url.getParameter(Constants.SCOPE_KEY);
  13.     // 如果 scope = none，则什么都不做
  14.     if (!Constants.SCOPE_NONE.toString().equalsIgnoreCase(scope)) {
  15.         // scope != remote，导出到本地
  16.         if (!Constants.SCOPE_REMOTE.toString().equalsIgnoreCase(scope)) {
  17.             exportLocal(url);
  18.         }
  20.         // scope != local，导出到远程
  21.         if (!Constants.SCOPE_LOCAL.toString().equalsIgnoreCase(scope)) {
  22.             if (registryURLs != null && !registryURLs.isEmpty()) {
  23.                 for (URL registryURL : registryURLs) {
  24.                     url = url.addParameterIfAbsent(Constants.DYNAMIC_KEY, registryURL.getParameter(Constants.DYNAMIC_KEY));
  25.                     // 加载监视器链接
  26.                     URL monitorUrl = loadMonitor(registryURL);
  27.                     if (monitorUrl != null) {
  28.                         // 将监视器链接作为参数添加到 url 中
  29.                         url = url.addParameterAndEncoded(Constants.MONITOR_KEY, monitorUrl.toFullString());
  30.                     }
  32.                     String proxy = url.getParameter(Constants.PROXY_KEY);
  33.                     if (StringUtils.isNotEmpty(proxy)) {
  34.                         registryURL = registryURL.addParameter(Constants.PROXY_KEY, proxy);
  35.                     }
  37.                     // 为服务提供类(ref)生成 Invoker
  38.                     Invoker<?> invoker = proxyFactory.getInvoker(ref, (Class) interfaceClass, registryURL.addParameterAndEncoded(Constants.EXPORT_KEY, url.toFullString()));
  39.                     // DelegateProviderMetaDataInvoker 用于持有 Invoker 和 ServiceConfig
  40.                     DelegateProviderMetaDataInvoker wrapperInvoker = new DelegateProviderMetaDataInvoker(invoker, this);
  42.                     // 导出服务，并生成 Exporter
  43.                     Exporter<?> exporter = protocol.export(wrapperInvoker);
  44.                     exporters.add(exporter);
  45.                 }
  47.             // 不存在注册中心，仅导出服务
  48.             } else {
  49.                 Invoker<?> invoker = proxyFactory.getInvoker(ref, (Class) interfaceClass, url);
  50.                 DelegateProviderMetaDataInvoker wrapperInvoker = new DelegateProviderMetaDataInvoker(invoker, this);
  52.                 Exporter<?> exporter = protocol.export(wrapperInvoker);
  53.                 exporters.add(exporter);
  54.             }
  55.         }
  56.     }
  57.     this.urls.add(url);
  58. }

上面代码根据 url 中的 scope 参数决定服务导出方式，分别如下：

  • scope = none，不导出服务
  • scope != remote，导出到本地
  • scope != local，导出到远程

不管是导出到本地，还是远程。进行服务导出之前，均需要先创建 Invoker，这是一个很重要的步骤。因此下面先来分析 Invoker 的创建过程。