作为RPC#xff1a;支持各种传输协议#xff0c;如dubbo,hession,json,fastjson#xff0c;底层采用mina,netty长连接…Dubbo缺省协议采用单一长连接和NIO异步通讯适合于小数据量大并发的服务调用以及服务消费者机器数远大于服务提供者机器数的情况。

作为RPC支持各种传输协议如dubbo,hession,json,fastjson底层采用mina,netty长连接进行传输典型的provider和cusomer模式!

作为SOA具有服务治理功能提供服务的注册和发现用zookeeper实现注册中心启动时候服务端会把所有接口注册到注册中心并且订阅configurators,服务消费端订阅provideconfigurators,routers,订阅变更时zk会推送providers,configuatorsrouters,启动时注册长连接进行通讯proveider和provider启动后后台启动定时器发送统计数据到monitor监控中心提供各种容错机制和负载均衡策略

我们解释以下这个架构图https://yq.aliyun.com/articles/38380

Consumer服务消费者Provider服务提供者。

Container服务容器。

消费当然是invoke提供者了invoke这条实线按照图上的说明当然同步的意思了多说一句在实际调用过程中Provider的位置对于Consumer来说是透明的上一次调用服务的位置IP地址和下一次调用服务的位置是不确定的。

这个地方就是实现了软负载。

消费订阅subscribe服务如果没有订阅到自己想获得的服务它会不断的尝试订阅。

新的服务注册到注册中心以后注册中心会将这些服务通过notify到消费者。

和Provider通过异步的方式发送消息至MonitorConsumer和Provider会将信息存放在本地磁盘平均1min会发送一次信息。

Monitor在整个架构中是可选的图中的虚线并不是可选的意思Monitor功能需要单独配置不配置或者配置以后Monitor挂掉并不会影响服务的调用。

netty

是一个基于nio的客户、服务器端编程框架,netty提供异步的,事件驱动的网络应用程序框架和工具,可以快速开发高可用的客户端和服务器。

netty是基于nio的,它封装了jdk的nio,让我们使用起来更加方法灵活。

二、dubbo原理

上图中的第一步start就是将服务装载容器中然后准备注册服务。

和Spring中启动过程类似spring启动时将bean装载进容器中的时候首先要解析bean。

所以dubbo也是先读配置文件解析服务。

解析服务

1、基于dubbo.jar内的Meta-inf/spring.handlers配置spring在遇到dubbo名称空间时会回调DubboNamespaceHandler类。

2、所有的dubbo标签都统一用DubboBeanDefinitionParser进行解析基于一对一属性映射将XML标签解析为Bean对象。

初始化时将Bean对象转会为url格式将所以Bean属性转成url的参数。

然后将URL传给Protocol扩展点基于扩展点的Adaptive机制根据URL的协议头进行不同协议的服务暴露和引用。

只暴露服务端口

在没有使用注册中心的情况这种情况一般适用在开发环境下服务的调用这和提供在同一个IP上只需要打开服务的端口即可。

即当配置

Dubbo//service-host/com.xxx.TxxService?version1.0.0

基于扩展点的Adaptiver机制通过URL的“dubbo//”协议头识别直接调用DubboProtocol的export方法打开服务端口。

b、向注册中心暴露服务

registry://registry-host/com.alibaba.dubbo.registry.RegistryService?exportURL.encode(“dubbo://service-host/com.xxx.TxxService?version1.0.0”)

基于扩展点的Adaptive机制通过URL的“registry//”协议头识别调用RegistryProtocol的export方法将export参数中的提供者URL先注册到注册中心再重新传给Protocol扩展点进行暴露

Dubbo//service-host/com.xxx.TxxService?version1.0.0

首先ServiceConfig类拿到对外提供服务的实际类ref(如HelloWorldImpl),然后通过ProxyFactory类的getInvoker方法使用ref生成一个AbstractProxyInvoker实例

到这一步就完成具体服务到Invoker的转化。

接下来就是Invoker转换到Exporter的过程。

Dubbo处理服务暴露的关键就在Invoker转换到Exporter的过程(如上图中的红色部分)下面我们以Dubbo和RMI这两种典型协议的实现来进行说明

Dubbo协议的Invoker转为Exporter发生在DubboProtocol类的export方法它主要是打开socket侦听服务并接收客户端发来的各种请求通讯细节由Dubbo自己实现。

RMI协议的Invoker转为Exporter发生在RmiProtocol类的export方法

它通过Spring或Dubbo或JDK来实现RMI服务通讯细节这一块由JDK底层来实现这就省了不少工作量。

首先ReferenceConfig类的init方法调用Protocol的refer方法生成Invoker实例(如上图中的红色部分)这是服务消费的关键。