前期准备
<dubbo:service/> 服务配置，用于暴露一个服务，定义服务的元信息，一个服务可以用多个协议暴露，一个服务也可以注册到多个注册中心。
eg、<dubbo:service ref="demoService" interface="com.xxx.xxx.provider.DemoService" />
<dubbo:reference/> 引用服务配置，用于创建一个远程服务代理，一个引用可以指向多个注册中心。
eg、<dubbo:reference id="demoService" interface="com.xxx.xxx.provider.DemoService" />
<dubbo:protocol/> 协议配置，用于配置提供服务的协议信息，协议由提供方指定，消费方被动接受。
eg、<dubbo:protocol name="dubbo" port="20880" />
<dubbo:application/> 应用配置，用于配置当前应用信息，不管该应用是提供者还是消费者。
eg、<dubbo:application name="provider" />
<dubbo:module/> 模块配置，用于配置当前模块信息，可选。
<dubbo:registry/> 注册中心配置，用于配置连接注册中心相关信息。
eg、<dubbo:registry address="zookeeper://192.168.2.249:2181" />
<dubbo:monitor/> 监控中心配置，用于配置连接监控中心相关信息，可选。
<dubbo:provider/> 提供方的缺省值，当ProtocolConfig和ServiceConfig某属性没有配置时，采用此缺省值，可选。
<dubbo:consumer/> 消费方缺省配置，当ReferenceConfig某属性没有配置时，采用此缺省值，可选。
<dubbo:method/> 方法配置，用于ServiceConfig和ReferenceConfig指定方法级的配置信息。
<dubbo:argument/> 用于指定方法参数配置。
Invoker URL ServiceBean
URL 之于 Dubbo，犹如水之于鱼，非常重要。
在 Dubbo 中，Invoker 是一个非常重要的模型。在服务提供端，以及服务引用端均会出现 Invoker。Dubbo 官方文档中对 Invoker 进行了说明，这里引用一下。
Invoker 是实体域，它是 Dubbo 的核心模型，其它模型都向它靠扰，或转换成它，它代表一个可执行体，可向它发起 invoke 调用，它有可能是一个本地的实现，也可能是一个远程的实现，也可能一个集群实现。
1.概览
http://dubbo.apache.org/zh-cn/docs/dev/implementation.html
<dubbo:service/> → ServiceConfig→Invoker→ Exporter->启动server打开端口->注册
1.dubbo在什么时候进行服务暴露
[图片上传失败...(image-aaadb7-1562576327193)]
[图片上传失败...(image-ff9460-1562576327192)]
导出时机：
afterPropertiesSet
onApplicationEvent
为什么要延迟暴露
dubbo服务导出到那里？
导出了什么东西
怎么导出的
2.服务暴露过程
- 1.检查准备环境配置
- 2.加载注册中心
- 3.暴露本地服务
- 4.暴露远程服务
- 5.注册
导出的入口
org.apache.dubbo.config.ServiceConfig#export
- 检测 <dubbo:service> 标签的 interface 属性合法性，不合法则抛出异常
- 检测 ProviderConfig、ApplicationConfig 等核心配置类对象是否为空，若为空，则尝试从其他配置类对象中获取相应的实例。
- 检测并处理泛化服务和普通服务类（扩展泛化调用）
-
检测本地存根配置，并进行相应的处理（解释存根）image
- 对 ApplicationConfig、RegistryConfig 等配置类进行检测，为空则尝试创建，若无法创建则抛出异常
检查配置举个例子 protocol
如果为空就set，然后增加属性
[图片上传失败...(image-819df9-1562576327192)]
- 2.加载注册中心
[图片上传失败...(image-10b9e0-1562576327192)]
[图片上传失败...(image-3c064c-1562576327192)]
org.apache.dubbo.config.AbstractInterfaceConfig#loadRegistries的registries什么时候注入的?提出问题
org.springframework.beans.factory.BeanFactoryUtils#beansOfTypeIncludingAncestors(org.springframework.beans.factory.ListableBeanFactory, java.lang.Class<T>, boolean, boolean)
这里获取默认的配置 扩展IOC
双注册中心
haunt 资料
https://tech.youzan.com/haunt-youzan-service-discovery/
org.apache.dubbo.config.ServiceConfig#doExportUrlsFor1Protocol
1.将一些信息，比如版本、时间戳、方法名以及各种配置对象的字段信息放入到 map 中，map 中的内容将作为 URL 的查询字符串。构建好 map 后，紧接着是获取上下文路径、主机名以及端口号等信息。最后将 map 和主机名等数据传给 URL 构造方法创建 URL 对象。
[图片上传失败...(image-70bad3-1562576327192)]
3.暴露本地服务org.apache.dubbo.config.ServiceConfig#exportLocal
先看一下成员变量。使用spi
[图片上传失败...(image-53fddf-1562576327192)]
[图片上传失败...(image-d81aee-1562576327192)]
创建invoker的过程
[图片上传失败...(image-47e326-1562576327192)]
生成的protocol code
package org.apache.dubbo.rpc;
import org.apache.dubbo.common.extension.ExtensionLoader;
public class Protocol$Adaptive implements org.apache.dubbo.rpc.Protocol {
public void destroy() {
throw new UnsupportedOperationException("The method public abstract void org.apache.dubbo.rpc.Protocol.destroy() of interface org.apache.dubbo.rpc.Protocol is not adaptive method!");
}
public int getDefaultPort() {
throw new UnsupportedOperationException("The method public abstract int org.apache.dubbo.rpc.Protocol.getDefaultPort() of interface org.apache.dubbo.rpc.Protocol is not adaptive method!");
}
public org.apache.dubbo.rpc.Invoker refer(java.lang.Class arg0, org.apache.dubbo.common.URL arg1) throws org.apache.dubbo.rpc.RpcException {
if (arg1 == null) throw new IllegalArgumentException("url == null");
org.apache.dubbo.common.URL url = arg1;
String extName = (url.getProtocol() == null ? "dubbo": url.getProtocol());
if (extName == null) throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.Protocol) name from url (" + url.toString() + ") use keys([protocol])");
org.apache.dubbo.rpc.Protocol extension = (org.apache.dubbo.rpc.Protocol) ExtensionLoader.getExtensionLoader(org.apache.dubbo.rpc.Protocol.class).getExtension(extName);
return extension.refer(arg0, arg1);
}
public org.apache.dubbo.rpc.Exporter export(org.apache.dubbo.rpc.Invoker arg0) throws org.apache.dubbo.rpc.RpcException {
if (arg0 == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument == null");
if (arg0.getUrl() == null) throw new IllegalArgumentException("org.apache.dubbo.rpc.Invoker argument getUrl() == null");
org.apache.dubbo.common.URL url = arg0.getUrl();
String extName = (url.getProtocol() == null ? "dubbo": url.getProtocol());
if (extName == null) throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.Protocol) name from url (" + url.toString() + ") use keys([protocol])");
org.apache.dubbo.rpc.Protocol extension = (org.apache.dubbo.rpc.Protocol) ExtensionLoader.getExtensionLoader(org.apache.dubbo.rpc.Protocol.class).getExtension(extName);
return extension.export(arg0);
}
}
String extName = (url.getProtocol() == null ? "dubbo": url.getProtocol());
org.apache.dubbo.rpc.Protocol extension = (org.apache.dubbo.rpc.Protocol) ExtensionLoader.getExtensionLoader(org.apache.dubbo.rpc.Protocol.class).getExtension(extName);
最后得到
org.apache.dubbo.rpc.protocol.injvm.InjvmProtocol
[图片上传失败...(image-d3033f-1562576327192)]
回忆getExtension的时候，对Protocol包装又包装。
build一个过滤链，启动一个服务质量监控服务器，增加一个监听者。
[图片上传失败...(image-93aad6-1562576327192)]
为什么要有本地暴露
本地调用使用了 injvm 协议，是一个伪协议，它不开启端口，不发起远程调用，只在 JVM 内直接关联，但执行 Dubbo 的 Filter 链。
http://dubbo.apache.org/zh-cn/docs/user/demos/local-call.html
org.apache.dubbo.registry.integration.RegistryProtocol#doLocalExport
org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#openServer
[图片上传失败...(image-ffbf2d-1562576327192)]
[图片上传失败...(image-1fea4f-1562576327192)]
org.apache.dubbo.rpc.Protocol#export 远程暴露
org.apache.dubbo.registry.integration.RegistryProtocol#export
远程暴露第一步 交给具体的协议去暴露本地端口
org.apache.dubbo.registry.integration.RegistryProtocol#doLocalExport
→org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#export(缓存exporter)
→org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#openServer（缓存server）
→org.apache.dubbo.rpc.protocol.dubbo.DubboProtocol#createServer（给url增加一些属性）
->org.apache.dubbo.remoting.exchange.Exchangers#bind(org.apache.dubbo.common.URL, org.apache.dubbo.remoting.exchange.ExchangeHandler)（根据type获取对应的exchanger）
->org.apache.dubbo.remoting.Transporters#bind(org.apache.dubbo.common.URL, org.apache.dubbo.remoting.ChannelHandler...)（门面模式，具体交给netty去做）
->org.apache.dubbo.remoting.transport.netty4.NettyServer#doOpen（真正启动server的地方）
[图片上传失败...(image-498383-1562576327192)]
第二步-注册
获取注册中心
org.apache.dubbo.registry.support.AbstractRegistryFactory#getRegistry
→org.apache.dubbo.registry.etcd.EtcdRegistryFactory#createRegistry
→org.apache.dubbo.remoting.etcd.jetcd.JEtcdTransporter#connect
[图片上传失败...(image-c652f9-1562576327192)]
org.apache.dubbo.remoting.etcd.support.AbstractEtcdClient#create
[图片上传失败...(image-3893ab-1562576327192)]
org.apache.dubbo.remoting.etcd.jetcd.JEtcdClientWrapper#createPersistent
[图片上传失败...(image-71c6f8-1562576327192)]
模板方法
重点是把dubbo的url转换成etcd的节点
为啥注册中心挂了，服务还能继续通信？
com.alibaba.dubbo.registry.RegistryService#subscribe
最后。官网的说明
URL举例
服务提供者暴露一个服务的详细过程
上图是服务提供者暴露服务的主过程：
首先 ServiceConfig 类拿到对外提供服务的实际类 ref(如：HelloWorldImpl),然后通过 ProxyFactory 类的 getInvoker 方法使用 ref 生成一个 AbstractProxyInvoker 实例，到这一步就完成具体服务到 Invoker的转化。接下来就是 Invoker 转换到 Exporter 的过程。
Dubbo 处理服务暴露的关键就在 Invoker 转换到 Exporter 的过程，上图中的红色部分。下面我们以 Dubbo 和 RMI 这两种典型协议的实现来进行说明：
Dubbo 的实现
Dubbo 协议的 Invoker 转为 Exporter 发生在 DubboProtocol 类的 export 方法，它主要是打开 socket 侦听服务，并接收客户端发来的各种请求，通讯细节由 Dubbo 自己实现。
