本篇是基于Dubbo的2.7.3-release版本.
下图是来自Dubbo官方的的消费者调用时序图 数组
从上一篇
消费者启动过程分析中,经过JDK的动态代理对象,传入的InnvokeHandler是ReferenceBeanInvocationHandler,这里经过调用注入的@Reference的代理会触发invoke方法的调用,这里的bean对象是触发真实代理对象的分调用.
经过ReferenceBean中get方法中获取经过init方法初始化生成代理对象.
ReferenceBeanInvocationHandler中bean就是经过init方法中的createProxy方法中生成代理代理对象.
ReferenceBean中Protocol是Protocol@Adaptive(SPI对象生成适配类),调用调用refer方法获得Invoker对象,这里使用到Dubbo的SPI机制特性,若是有注册中心这Protocol加载的扩展协议是RegsitryProtocol,因为Protocol注册有ProtocolFilterWrapper和ProtocolListenerWrapper包装类,全部执行顺序是ProtocolListenerWrapper.refer()--->ProtocolFilterWrapper.refer()--->RegistryProtocol.refer()这种执行顺序执行.
首先会调用ProtocolListenerWrapper的refer方法,这里判断URL的Protocol中的协议是不是Registry的协议,则调用protoco(这里注入的protocol是ProtocolFilterWrapper)的refer方法
而后调用ProtocolFilterWrapper中refer方法,这里判断URL的Protocol中的协议是不是Registry的协议,因为咱们配置了zookeeper的注册中心,这里第一个if判断是true,而且这里注入的对象是RegistryProtocol中,并执行RegistryProtocol.refer方法返回Invoker对象.
RegistryProtocol的refer方法,这里首先会删除了URL参数中registry的key,并设置协议为Dubbo,接着判断是否注册的信息是不是RegistryService类型的bean,若是是经过ProxyFactoy包装成Invoker返回,而后判断@Reference是否配置group.而后调用doRefer进行服务引用.
建立的RegistryDirectory去注册服务消费者,而且对服务的路由、配置、提供者信息变动的更新.最后经过注入的Cluster(集群的特性后面会详细讲)这个扩展点,调用join方法对多个服务的合并转换成Invoker,并将其注册到ProviderConsumerRegTable这个对象中.
AbstractProtocol中refer方法中protocolBindingRefer方法是抽象方法,是具体协议对象,默认DubboProtocol去实现了protocolBindingRefer方法.若是是是否group,最后调用doRefer方法
这里doRefer方法是经过RegistryDirectory向注册中心注册元数据信息,而且订阅注册中心提供者信息,而后经过Cluster.join合并成一个Invoker,默认集群策略是FailOver的,因此这里返回的Invoker对象是FailoverClusterInvoker
服务订阅时,会经过获取注册中心的提供者的URL,并默认使用DubboPrtocol的refer方法从新引用一次
Dubbo中的protocolBindingRefer方法,构建一个DubboInvoker对象,其中第三个参数是获取ExchangeClient[]数组,消费端的远程调用通讯就是它完成的(默认是Netty),
这里就是ProxyFactory调用getProxy方法获取的代理对象,这里ProxyFactory注入是实例对象是ProxyFactroy$Adaptive对象,默认是使用JavassistProxyFactory生成Invoker.
JavassistProxyFactory的getProxy主要是将经过Protocol转换成的Invoker.经过Dubbo本身实现的Proxy生成代理类.注入到Spring容器中Bean标注@Reference中属性和方法中.
经过调用@Reference的bean方法调用,最终会调用InvokerInvocationHandler的invoke方法,该方法里面是调用Invoker的invoke方法,经过传入RpcInvocation对象,传入method和参数等,经过ExchangeClient调用远程的方法并返回
总结:
今天主要是分析Reference执行启动的流程,以及调用的过程,markdown