dubbo源码分析(一) 服务暴露--服务引用
2017-09-23 16:46
615 查看
又到了面试的时间 为了应付面试 得准备些干货
##provider示例
以上是基本的provider配置
###dubbo无缝接入了spring 我们看看是如何实现的
从上面的配置文件看到dubbo使用了自定义标签 那么肯定实现了NamespaceHandlerSupport用于解析自己的标签
可以找到NamespaceHandlerSupport的实现DubboNamespaceHandler
通过META-INF/spring.handlers注册当前handler,这是spring的拓展机制
这里不多说
这里DubboNamespaceHandler将解析工作委托给了DubboBeanDefinitionParser 这里不过多叙述
DubboBeanDefinitionParser 可以看到dubbo对于各个自定义标签解析所用到的类 这里做个整理
这里具体的标签属性解析过程暂不分析 有兴趣可以自己查看原发
DubboBeanDefinitionParser完成了对xml配置的解析 并装载至spring容器的过程
本人对spring的解析机制不是很了解,不过通过DubboBeanDefinitionParser可以看出,最终spring容器加载到的是一个BeanDefinition,可以理解spring中对对象的抽象实现
当provider对象解析 装载完成理所当然是根据配置生成服务
我们看ServiceBean代码的实现
###服务暴露
可以看到最终调用到Protocol对象的export()方法暴露服务.
到这里就完成了流程上的服务暴露.具体暴露细节由各个协议自己实现.
###服务引用
通过Protocol的refer()拿到了一个Invoker对象,再通过动态代理生成接口的代理对象,实现rpc通信
总结: 通过Protocol接口的exporter()和refer()接口,完成流程上的服务暴露和服务引用
###dubbo-protocol层介绍
Protocol接口在dubbo属于Protocol层.Protocol层中主要有Exporter,Invoker,Protocol三大对象
Exporter: 暴露器,可通过其获得Invoker对象
Invoker:(通讯)执行器,实现与远端的通信
Protocol: 抽象协议,暴露服务和引用服务
Protocol层是dubbo的核心层,只要有Protocol + Invoker + Exporter就可以完成非透明的RPC调用.
来看Protocol,Exporter,Invoker接口定义
##provider示例
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd "> <!-- 用dubbo协议在20880端口暴露服务 --> <dubbo:protocol name="dubbo" port="20952"/> <!-- 声明需要暴露的服务接口 --> <dubbo:service interface="com.***.workorder.facade.exports.ApplyTaskFacade" ref="applyTaskFacadeImpl" version="1.0.0" delay="-1"/> <dubbo:service interface="com.***.workorder.facade.exports.TaskFacade" ref="taskFacadeImpl" version="1.0.0" delay="-1"/> </beans>
以上是基本的provider配置
###dubbo无缝接入了spring 我们看看是如何实现的
从上面的配置文件看到dubbo使用了自定义标签 那么肯定实现了NamespaceHandlerSupport用于解析自己的标签
可以找到NamespaceHandlerSupport的实现DubboNamespaceHandler
通过META-INF/spring.handlers注册当前handler,这是spring的拓展机制
这里不多说
这里DubboNamespaceHandler将解析工作委托给了DubboBeanDefinitionParser 这里不过多叙述
DubboBeanDefinitionParser 可以看到dubbo对于各个自定义标签解析所用到的类 这里做个整理
标签 | 解析类 | 作用 |
---|---|---|
application | ApplicationConfig | 应用配置,用于配置当前应用信息,不管该应用是提供者还是消费者。 |
module | ModuleConfig | 模块配置,用于配置当前模块信息,可选。 |
registry | RegistryConfig | 注册中心配置,用于配置连接注册中心相关信息。 |
monitor | MonitorConfig | 监控中心配置,用于配置连接监控中心相关信息,可选。 |
provider | ProviderConfig | 提供方的缺省值,当ProtocolConfig和ServiceConfig某属性没有配置时,采用此缺省值,可选。 |
consumer | ConsumerConfig | 消费方缺省配置,当ReferenceConfig某属性没有配置时,采用此缺省值,可选。 |
protocol | ProtocolConfig | 协议配置,用于配置提供服务的协议信息,协议由提供方指定,消费方被动接受。 |
service | ServiceBean | 服务配置,用于暴露一个服务,定义服务的元信息,一个服务可以用多个协议暴露,一个服务也可以注册到多个注册中心。 |
reference | ReferenceBean | 引用配置,用于创建一个远程服务代理,一个引用可以指向多个注册中心。 |
annotation | AnnotationBean | 注解识别处理器 |
DubboBeanDefinitionParser完成了对xml配置的解析 并装载至spring容器的过程
本人对spring的解析机制不是很了解,不过通过DubboBeanDefinitionParser可以看出,最终spring容器加载到的是一个BeanDefinition,可以理解spring中对对象的抽象实现
当provider对象解析 装载完成理所当然是根据配置生成服务
我们看ServiceBean代码的实现
public class ServiceBean<T> extends ServiceConfig<T> implements InitializingBean, DisposableBean, ApplicationContextAware, ApplicationListener, BeanNameAware
###服务暴露
可以看到最终调用到Protocol对象的export()方法暴露服务.
到这里就完成了流程上的服务暴露.具体暴露细节由各个协议自己实现.
###服务引用
通过Protocol的refer()拿到了一个Invoker对象,再通过动态代理生成接口的代理对象,实现rpc通信
总结: 通过Protocol接口的exporter()和refer()接口,完成流程上的服务暴露和服务引用
###dubbo-protocol层介绍
Protocol接口在dubbo属于Protocol层.Protocol层中主要有Exporter,Invoker,Protocol三大对象
Exporter: 暴露器,可通过其获得Invoker对象
Invoker:(通讯)执行器,实现与远端的通信
Protocol: 抽象协议,暴露服务和引用服务
Protocol层是dubbo的核心层,只要有Protocol + Invoker + Exporter就可以完成非透明的RPC调用.
来看Protocol,Exporter,Invoker接口定义
@SPI("dubbo") public interface Protocol { /** * 获取缺省端口,当用户没有配置端口时使用。 * * @return 缺省端口 */ int getDefaultPort(); /** * 暴露远程服务:<br> * 1. 协议在接收请求时,应记录请求来源方地址信息:RpcContext.getContext().setRemoteAddress();<br> * 2. export()必须是幂等的,也就是暴露同一个URL的Invoker两次,和暴露一次没有区别。<br> * 3. export()传入的Invoker由框架实现并传入,协议不需要关心。<br> * * @param <T> 服务的类型 * @param invoker 服务的执行体 * @return exporter 暴露服务的引用,用于取消暴露 * @throws RpcException 当暴露服务出错时抛出,比如端口已占用 */ @Adaptive <T> Exporter<T> export(Invoker<T> invoker) throws RpcException; /** * 引用远程服务:<br> * 1. 当用户调用refer()所返回的Invoker对象的invoke()方法时,协议需相应执行同URL远端export()传入的Invoker对象的invoke()方法。<br> * 2. refer()返回的Invoker由协议实现,协议通常需要在此Invoker中发送远程请求。<br> * 3. 当url中有设置check=false时,连接失败不能抛出异常,并内部自动恢复。<br> * * @param <T> 服务的类型 * @param type 服务的类型 * @param url 远程服务的URL地址 * @return invoker 服务的本地代理 * @throws RpcException 当连接服务提供方失败时抛出 */ @Adaptive <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException; /** * 释放协议:<br> * 1. 取消该协议所有已经暴露和引用的服务。<br> * 2. 释放协议所占用的所有资源,比如连接和端口。<br> * 3. 协议在释放后,依然能暴露和引用新的服务。<br> */ void destroy(); } public interface Exporter<T> { Invoker<T> getInvoker(); void unexport(); } ** * Invoker. (API/SPI, Prototype, ThreadSafe) * 分三种: * 1.AbstractInvoker 通过网络调用远程服务 (客户端用) * 2.AbstractProxyInvoker 调用本地实现 (服务端用) * 3.ClusterInvoker 提供集群服务 (客户端用) */ public interface Invoker<T> extends Node { Class<T> getInterface(); Result invoke(Invocation invocation) throws RpcException; }
相关文章推荐
- [置顶] Dubbo暴露服务和引用服务的实现源码分析
- Dubbo暴露服务和引用服务的实现源码分析
- [Dubbo源码分析]Dubbo暴露与引用
- Dubbo源码分析----暴露服务
- Dubbo源码分析之三:服务的暴露
- dubbo服务暴露过程源码分析
- 7、dubbo源码分析 之 服务本地暴露
- 8、dubbo源码分析 之 服务远程暴露(上)
- Dubbo源码分析之服务暴露
- 6、dubbo源码分析 之 服务暴露概述
- dubbo源码分析12——服务暴露3_doExportUrls()方法分析
- dubbo源码分析10——服务暴露1_export()方法分析
- dubbo源码分析8——服务暴露概述
- Dubbo 源码分析 - 服务引用
- Dubbo源码分析之四:服务的调用
- dubbo源码解析(六) dubbo服务发布过程及本地暴露
- Dubbo暴露服务源码解析
- Dubbo源码解析 —— 服务暴露总结
- Dubbo源码分析(十):服务发布
- Dubbo介绍2- 源码分析,通过schema启动服务