1. Dubbo概述
Dubbo是阿里巴巴开源出来的一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及作为SOA服务治理的方案。它的核心功能包括:
#remoting:远程通讯基础,提供对多种NIO框架抽象封装,包括“同步转异步”和“请求-响应”模式的信息交换方式。
#Cluster: 服务框架核心,提供基于接口方法的远程过程调用,包括多协议支持,并提供软负载均衡和容错机制的集群支持。
#registry: 服务注册中心,使服务消费方能动态的查找服务提供方,使地址透明,使服务提供方可以平滑增加或减少机器。
由于Dubbo团队的文档和代码都非常优秀,所以更多关于dubbo的方方面面请参考网站http://code.alibabatech.com/wiki/display/dubbo/Home-zh。
这里我们只是补充一下从源码具体实现角度来看的某些细节方面,包括Invoker、ExtensionLoader等方面。任何官方已经介绍过的细节,我们不做画蛇添足,官方文档已经足够详实了,这篇文档的定位是补充实现的相关细节,是基于我在往Dubbo添加web service协议过程中,所碰到过的一些困难。
上图是服务提供者暴露服务的主过程:
首先ServiceConfig类拿到对外提供服务的实际类ref(如:HelloWorldImpl),然后通过ProxyFactory类的getInvoker方法使用ref生成一个AbstractProxyInvoker实例,到这一步就完成具体服务到Invoker的转化。接下来就是Invoker转换到Exporter的过程。
Dubbo处理服务暴露的关键就在Invoker转换到Exporter的过程(如上图中的红色部分),下面我们以Dubbo和RMI这两种典型协议的实现来进行说明:
#Dubbo的实现
Dubbo协议的Invoker转为Exporter发生在DubboProtocol类的export方法,它主要是打开socket侦听服务,并接收客户端发来的各种请求,通讯细节由Dubbo自己实现。
#RMI的实现
RMI协议的Invoker转为Exporter发生在RmiProtocol类的export方法,它通过Spring或Dubbo或JDK来实现RMI服务,通讯细节这一块由JDK底层来实现,这就省了不少工作量。
上图是服务消费的主过程:
首先ReferenceConfig类的init方法调用Protocol的refer方法生成Invoker实例(如上图中的红色部分),这是服务消费的关键。接下来把Invoker转换为客户端需要的接口(如:HelloWorld)。
关于每种协议如RMI/Dubbo/Web service等它们在调用refer方法生成Invoker实例的细节和上一章节所描述的类似。
4. 满眼都是Invoker
由于Invoker是Dubbo领域模型中非常重要的一个概念,很多设计思路都是向它靠拢。这就使得Invoker渗透在整个实现代码里,对于刚开始接触Dubbo的人,确实容易给搞混了。
下面我们用一个精简的图来说明最重要的两种Invoker:服务提供Invoker和服务消费Invoker:
#服务消费者代码
public class DemoClientAction {
private DemoService demoService;
public void setDemoService(DemoService demoService) {
this.demoService = demoService;
}
public void start() {
String hello = demoService.sayHello("world" + i);
}
#服务提供者代码
public class DemoServiceImpl
implements DemoService
{
public String sayHello(String name) throws RemoteException
{
return "Hello " + name;
}
}
上面这个类会被封装成为一个AbstractProxyInvoker实例,并新生成一个Exporter实例。这样当网络通讯层收到一个请求后,会找到对应的Exporter实例,并调用它所对应的AbstractProxyInvoker实例,从而真正调用了服务提供者的代码。
Dubbo里还有一些其他的Invoker类,但上面两种是最重要的。
5. ExtensionLoader的完整分析
ExtensionLoader是Dubbo中一个非常重要的类,刚接触Dubbo源码的人看这个类的时候也多少会有点困惑,这个类非常重要,它就像是厨房里的“大厨”,按照用户的随时需要把各种“食材”烹调出来。
我们结合具体代码详细说一下ExtensionLoader的实现,下面是ServiceConfig类里的一行代码:
private static final Protocol protocol = ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();
上面代码的程序流程图如下所示(假定是第一次执行这行代码):
在这个过程中最重要的两个方法是getExtensionClasses和createAdaptiveExtensionClass(图中红色部分),下面详细对这两个方法进行分析:
#getExtensionClasses
这个方法主要读取META-INF/services/目录下对应文件内容,在本示例代码中,是读取META-INF/services/com.alibaba.dubbo.rpc.Protocol文件中的内容,具体内容如下:
com.alibaba.dubbo.registry.support.RegistryProtocol
com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper
com.alibaba.dubbo.rpc.protocol.ProtocolListenerWrapper
com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol
com.alibaba.dubbo.rpc.protocol.injvm.InjvmProtocol
com.alibaba.dubbo.rpc.protocol.rmi.RmiProtocol
com.alibaba.dubbo.rpc.protocol.hessian.HessianProtocol
com.alibaba.dubbo.rpc.protocol.webservice.WebServiceProtocol
它分析该文件中的每一行(每一行对应一个类),分析这些类,如果发现有哪个类的Annotation是@Adaptive,则找到对应的AdaptiveClass了,但由于Protocol文件里没有哪个类的Annotation是@Adaptive,所以在这个例子中该方法没找到对应的AdaptiveClass。
#createAdaptiveExtensionClass
该方法是在getExtensionClasses方法找不到AdaptiveClass的情况下被调用,该方法主要是通过字节码的方式在内存中新生成一个类,它具有AdaptiveClass的功能,Protocol就是通过这种方式获得AdaptiveClass类的。
AdaptiveClass类的作用是能在运行时动态判断具体是要调用哪个类的方法,更多关于AdaptiveClass的内容请参考Dubbo官方文档。
相关推荐
《Dubbo源码分析系列》是一份深入探讨Java开源框架Dubbo核心原理和技术细节的资料。Dubbo,作为阿里巴巴的一款高性能、轻量级的服务治理框架,它为分布式系统提供了服务发现、调用、负载均衡、容错等关键功能。这份...
在分布式系统中,Dubbo作为一个高性能、轻量级的Java RPC框架,它的核心功能包括服务发布和服务引用。本文将深入源码,详细解析这两个关键过程,帮助你理解Dubbo是如何在服务提供者和服务消费者之间建立通信桥梁的。...
综上所述,通过对Dubbo源码的详细分析,我们可以了解到它不仅仅是一个简单的RPC框架,而是涵盖了服务治理、集群容错、负载均衡等多个方面的复杂系统。希望以上解析能够帮助读者更深入地理解Dubbo的内部工作原理和...
4. **服务监控**:Dubbo提供了监控中心,可以收集服务调用的性能数据,包括QPS、RT、异常率等,帮助开发者分析和优化服务性能。开发者可以通过监控中心的界面查看服务调用情况,及时发现问题。 5. **测试与部署**:...
Zookeeper 是一个分布式的,开放源码的分布式应用程序协调服务,它作为一个中心服务器,用于存储和管理服务节点信息,实现服务发现和服务配置。在 Dubbo 中,Zookeeper 作为注册中心,服务提供者向其注册服务,服务...
`Registry`负责与注册中心交互,`Protocol`处理服务的暴露和引用,`Invoker`是服务调用的抽象,实现了服务的全生命周期管理。 三、远程调用(RPC) Dubbo的RPC实现主要包括服务接口的代理、序列化、网络传输等环节...
在本项目中,我们主要...通过分析和实现这些关键部分,你可以深入理解Dubbo的设计理念,为后续的微服务开发和优化打下坚实基础。同时,这样的实践也有助于你掌握分布式系统中的核心概念和技术,提升个人的技术素养。
通过对Dubbo服务注册、发布和消费源码的深入分析,我们可以更清晰地了解Dubbo如何实现服务间的通信,这对于优化服务性能、排查问题以及扩展自定义功能都具有重要的指导意义。同时,这也反映出Dubbo的设计理念——...
本次我们将通过分析Dubbo 2.7.2的源码,来深入了解其设计理念和实现机制,帮助开发者更好地理解和运用这个强大的工具。 一、Dubbo架构概览 Dubbo的核心架构基于服务提供者(Provider)、消费者(Consumer)、注册...
1. **ServiceConfig和服务引用(ReferenceConfig)**:这两个类是Dubbo的核心配置类,分别用于服务提供者和服务消费者的配置。 2. **ProtocolConfig**:定义服务调用协议,包括端口、连接数等配置。 3. **...
Dubbo是一款由阿里巴巴开源的高性能Java RPC框架,它在分布式系统中起到了服务调用的...通过对Dubbo的深入学习和源码分析,我们可以提升分布式系统的设计和运维能力,为构建高可用、高并发的微服务架构打下坚实基础。
13. Refer&export过程分析:研究了Dubbo中服务的暴露(export)和引用(refer)的流程,包括调用顺序、生成Invoker的过程、Registry的使用等。 14. 集群和容错处理:描述了Dubbo中的集群机制,包括路由服务、负载...
1. **Refer&export**:Dubbo中的服务引用和暴露过程。主要包括调用顺序、生成Invoker、暴露服务等步骤。 2. **Registry**:Dubbo的服务注册中心,用于服务的注册与发现。主要包括: - RegistryFactory和Registry:...
通过分析源码,我们可以了解Dubbo如何通过Spring整合,如何定义和消费服务,以及服务注册、发现、调用等过程。同时,配合文档,能更全面地掌握Dubbo的各种特性,为实际项目中的应用打下坚实基础。在实践中,不断探索...
它采用Java语言编写,通过提供API和XML配置,使得开发者能够轻松地实现服务的暴露、引用、调用等操作。2.5.4版本是Dubbo的一个稳定版本,修复了多个已知问题,并优化了性能,为开发者提供了更稳定可靠的环境。 二、...
8. 代理:分析Dubbo中JDK代理和Javaassist代理的实现原理和使用场景。 9. 远程调用流程:理解Dubbo的通信过程、序列化和编解码机制。 10. 过程分析:对Refer和export过程、Registry过程、服务的发布和引用进行详细...
4. **监控中心(Monitor)**:监控中心收集服务的调用统计信息,用于性能分析和故障排查。Dubbo-monitor-simple-2.4.3-sources.jar提供了基础的监控功能实现。 二、Dubbo工作流程 1. **服务发布**:服务提供者启动...
这个实例旨在帮助初学者快速入门,理解Dubbo的核心概念和工作原理,通过源码分析深入掌握其内部机制。 一、Dubbo架构概览 Dubbo的核心组件包括服务提供者(Provider)、服务消费者(Consumer)、注册中心...
9. **源码分析**:可能包含部分关键类或方法的源码解析,帮助理解 Dubbo 内部的工作机制。 10. **最佳实践**:可能会分享一些 Dubbo 使用中的最佳实践和注意事项,以避免常见问题。 综上所述,这个压缩包内容应是...
2. 实现服务接口。 3. 配置服务提供者,指定接口、实现类、注册中心等信息。 4. 启动服务提供者,将服务暴露到注册中心。 而 "dubbo_consume_demo" 文件则包含了服务消费者的示例,主要流程为: 1. 引入服务提供者...