前言
Dubbo服务消费方主要是作为客户端向服务提供方发起请求并接受响应的。
它有两个核心能力:
1、订阅和感知最新提供者信息
2、向服务提供者发起rpc请求调用
本文将分析服务消费方的启动和订阅原理。
启动消费者实例方式
总共有两种机制时机来引用服务: 第1是俄汉式(默认),在ReferenceBean类的afterPropertiesSet方法中,第2种是是在 ReferenceBean 对应的服务被注入到其他类中时引用(dubbo:Reference标签中init属性配置成true时候)
1、ReferenceBean由于实现了FactoryBean,自定义Bean实例化服务Bean过程。spring注册该服务对象到其他bean中的时候,调用com.alibaba.dubbo.config.spring.ReferenceBean#getObject,执行服务应用过程。
2、前置条件判断,是否已经初始化,配置是否合格,com.alibaba.dubbo.config.ReferenceConfig#init
3、com.alibaba.dubbo.config.ReferenceConfig#createProxy 创建消费方代理对象
这里要分几种情况:
如果是jvm内调用,生成injvm url
如果是直联方式调用,配置了url的情况
如果是注册中心方式先创建通信客户端
com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol#initClient
最后再创建invoker。
源码流转图
通过源码可知,在消费者启动过程中,会向注册中心订阅服务提供者信息,并且创建具备通信能力的代理对象,发起远程调用时候直接使用创建好的客户端发起通信请求。
总结
1、Dubbo服务消费者启动中主要有两个核心步骤,第1个是订阅服务提供者信息实现动态感知服务上下线的能力,第2个是创建客户端代理对象实现远程服务调用的能力 2、服务消费方拉取到服务提供者的信息会做本地缓存,实现高可用能力,注册中心如果不可用,不影响服务的调用。