Dubbo介绍

Dubbo介绍 Dubbo分层

1. 业务层 / Service：包括业务代码接口与实现，即开发者实现的业务代码；
2. 配置层 / config：主要围绕ServiceConfig（暴露的服务配置）和ReferenceConfig（引用的服务配置）两个实现类展开，初始化配置信息。该层管理了整个Dubbo的配置；
3. 服务代理层 / proxy：在Dubbo中，无论生产者还是消费者，框架都会生成一个代理类，整个过程对上层是透明的。当调用一个远程接口时，看起来就像是调用本地的接口一样，代理层会自动做远程调用并返回结果，即让业务层对远程调用完全无感；
4. 注册层 / registry：负责Dubbo框架的服务注册与发现。当有新的服务加入或旧的服务下线时，注册中心会感知并通知所有订阅方，整个过程不需要人工参与；
5. 集群容错层 / cluster：远程调用失败时的容错策略（如失败重试、快速失败）；选择具体调用节点的负载均衡策略（如随机、一致性Hash等）；特殊调用路径的路由策略；
6. 监控层 / monitor：负责监控统计调用次数和调用时间等；
7. 远程调用层 / protocol：封装RPC调用具体过程，Protocol是Invoker暴露和引用的主要功能入口，负责管理Invoker的整个生命周期。Inovker是Dubbo的核心模型，框架中所有其它模型都向它靠拢，或者转换成它，它代表一个可执行体。允许向它发起invoker调用，它可能是执行一个本地的接口实现，也可能是一个远程实现，还可能是一个集群实现；
8. 信息交换层 / exchange：建立Request-Response模型，封装请求响应模式，如把同步请求转化为异步请求；
9. 网络传输层 / transport：把网络传输抽象为统一的接口，如将netty、mina进行接口统一，用户可以添加更多网络传输方式；
10. 序列化层 / Serialize：如果数据要通过网络进行发送，则需要先进行序列化，变成二进制流。序列化层负责管理整个框架网络传输时的序列化 / 反序列化工作。

Dubbo总体调用过程

• 服务暴露过程：

　　首先，服务器端（服务提供者）在框架启动时，会初始化服务实例，通过Proxy组件调用具体协议（Protocol），把服务端要暴露的接口封装成Invoker（真实类型为AbstractProxyInvoker），然后转换成Exporter，这个时候框架会打开服务端口等并记录服务实例到内存中，最后通过Registry把服务元数据注册到注册中心。消费方在启动时会通过Registry在注册中心订阅服务端的元数据（包括IP和端口），这样就可以得到刚才暴露的服务了。

• 服务调用过程：

　　首先，调用过程也是从一个Proxy开始的，Proxy持有了一个Invoker对象，然后触发invoke调用。在invoke调用过程中，需要使用Cluster，Cluster负责容错，如调用失败重试failover、快速失败failfast、failsafe、failback、forking、broadcast、mock、available、mergeable。Cluster在调用之前会通过Directory获取所有可以调用的远程服务Invoker列表，由于可以调用的远程服务有很多，此时如果用户配置了路由规则，还会根据路由规则对Invoker列表进行过滤，路由规则有条件路由、文件路由、脚本路由。

　　然后，存活下来的Invoker可能还会有很多，于是会继续通过LoadBalance方法做负载均衡，最终选出一个可以调用的Invoker，负载均衡策略有随机、轮循、最小活跃调用数、一致性Hash。这个Invoker在调用之前又会经过一个过滤器链（Filter）。

　　接口，会使用Client做数据传输，如常见的Netty Client等。传输之前要做一些私有协议的构造，此时会用到Codec接口。构造完成后，就对数据包做序列化（Serialization），然后传输到服务提供者端。服务提供者收到数据包，也会使用Codec处理协议头及一些半包、粘包等。处理完成后再对完整的数据报文做反序列化处理。

　　随后，这个Request会被分配到线程池（ThreadPool）中进行处理。Server会处理这些Request，根据请求查找对应的Exporter（它内部持有Invoker）。Invoker是被装饰器模式一层一层套了非常多Filter的，因此在调用最终的实现类之前，又会经过一个服务提供者端的过滤器链。

　　最终，就得到了具体接口的真实实现并进行调用，再原路把结果返回。