`
秋天的童话穷
  • 浏览: 79492 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Dubbo暴露服务和引用服务的实现源码分析

阅读更多

 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协议过程中,所碰到过的一些困难。

2. 服务提供者暴露一个服务的详细过程



 

 上图是服务提供者暴露服务的主过程:

首先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底层来实现,这就省了不少工作量。

 

3. 服务消费者消费一个服务的详细过程



 

 

上图是服务消费的主过程:

首先ReferenceConfig类的init方法调用Protocolrefer方法生成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);

     }

}
       上面代码中的’DemoService’就是上图中服务消费端的proxy,用户代码通过这个proxy调用其对应的Invoker(DubboInvoker、 HessianRpcInvoker、 InjvmInvoker、 RmiInvoker、 WebServiceInvoker中的任何一个),而该Invoker实现了真正的远程服务调用。

 

#服务提供者代码

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官方文档。

  • 大小: 43.9 KB
  • 大小: 40 KB
  • 大小: 30.9 KB
  • 大小: 22.3 KB
分享到:
评论
1 楼 闫昌盛 2017-05-19  
服务方异步通知消费方怎么实现的?

相关推荐

    dubbo源码分析系列

    《Dubbo源码分析系列》是一份深入探讨Java开源框架Dubbo核心原理和技术细节的资料。Dubbo,作为阿里巴巴的一款高性能、轻量级的服务治理框架,它为分布式系统提供了服务发现、调用、负载均衡、容错等关键功能。这份...

    dubbo的服务发布与服务引用

    在分布式系统中,Dubbo作为一个高性能、轻量级的Java RPC框架,它的核心功能包括服务发布和服务引用。本文将深入源码,详细解析这两个关键过程,帮助你理解Dubbo是如何在服务提供者和服务消费者之间建立通信桥梁的。...

    dubbo源码解析2

    综上所述,通过对Dubbo源码的详细分析,我们可以了解到它不仅仅是一个简单的RPC框架,而是涵盖了服务治理、集群容错、负载均衡等多个方面的复杂系统。希望以上解析能够帮助读者更深入地理解Dubbo的内部工作原理和...

    Dubbo+Zookeeper+SpringMVC实现分布式服务治理框架(附件含源码)

    4. **服务监控**:Dubbo提供了监控中心,可以收集服务调用的性能数据,包括QPS、RT、异常率等,帮助开发者分析和优化服务性能。开发者可以通过监控中心的界面查看服务调用情况,及时发现问题。 5. **测试与部署**:...

    dubbo 分布式搭建源码

    Zookeeper 是一个分布式的,开放源码的分布式应用程序协调服务,它作为一个中心服务器,用于存储和管理服务节点信息,实现服务发现和服务配置。在 Dubbo 中,Zookeeper 作为注册中心,服务提供者向其注册服务,服务...

    dubbo 源码

    `Registry`负责与注册中心交互,`Protocol`处理服务的暴露和引用,`Invoker`是服务调用的抽象,实现了服务的全生命周期管理。 三、远程调用(RPC) Dubbo的RPC实现主要包括服务接口的代理、序列化、网络传输等环节...

    自己手动实现dubbo源码

    在本项目中,我们主要...通过分析和实现这些关键部分,你可以深入理解Dubbo的设计理念,为后续的微服务开发和优化打下坚实基础。同时,这样的实践也有助于你掌握分布式系统中的核心概念和技术,提升个人的技术素养。

    dubbo笔记-服务注册发布以及消费源码分析

    通过对Dubbo服务注册、发布和消费源码的深入分析,我们可以更清晰地了解Dubbo如何实现服务间的通信,这对于优化服务性能、排查问题以及扩展自定义功能都具有重要的指导意义。同时,这也反映出Dubbo的设计理念——...

    dubbo-dubbo-2.7.2源码

    本次我们将通过分析Dubbo 2.7.2的源码,来深入了解其设计理念和实现机制,帮助开发者更好地理解和运用这个强大的工具。 一、Dubbo架构概览 Dubbo的核心架构基于服务提供者(Provider)、消费者(Consumer)、注册...

    dubbo-2.5.3源码

    1. **ServiceConfig和服务引用(ReferenceConfig)**:这两个类是Dubbo的核心配置类,分别用于服务提供者和服务消费者的配置。 2. **ProtocolConfig**:定义服务调用协议,包括端口、连接数等配置。 3. **...

    Dubbo RPC框架原理解析和源码

    Dubbo是一款由阿里巴巴开源的高性能Java RPC框架,它在分布式系统中起到了服务调用的...通过对Dubbo的深入学习和源码分析,我们可以提升分布式系统的设计和运维能力,为构建高可用、高并发的微服务架构打下坚实基础。

    dubbo源码解析

    13. Refer&export过程分析:研究了Dubbo中服务的暴露(export)和引用(refer)的流程,包括调用顺序、生成Invoker的过程、Registry的使用等。 14. 集群和容错处理:描述了Dubbo中的集群机制,包括路由服务、负载...

    dubbo2.0-源码阅读

    1. **Refer&export**:Dubbo中的服务引用和暴露过程。主要包括调用顺序、生成Invoker、暴露服务等步骤。 2. **Registry**:Dubbo的服务注册中心,用于服务的注册与发现。主要包括: - RegistryFactory和Registry:...

    dubbo示例源码及相关文档

    通过分析源码,我们可以了解Dubbo如何通过Spring整合,如何定义和消费服务,以及服务注册、发现、调用等过程。同时,配合文档,能更全面地掌握Dubbo的各种特性,为实际项目中的应用打下坚实基础。在实践中,不断探索...

    dubbo-2.5.4全套最新源码内容

    它采用Java语言编写,通过提供API和XML配置,使得开发者能够轻松地实现服务的暴露、引用、调用等操作。2.5.4版本是Dubbo的一个稳定版本,修复了多个已知问题,并优化了性能,为开发者提供了更稳定可靠的环境。 二、...

    dubbo源码解析 1 pdf2.0

    8. 代理:分析Dubbo中JDK代理和Javaassist代理的实现原理和使用场景。 9. 远程调用流程:理解Dubbo的通信过程、序列化和编解码机制。 10. 过程分析:对Refer和export过程、Registry过程、服务的发布和引用进行详细...

    dubbo源码包

    4. **监控中心(Monitor)**:监控中心收集服务的调用统计信息,用于性能分析和故障排查。Dubbo-monitor-simple-2.4.3-sources.jar提供了基础的监控功能实现。 二、Dubbo工作流程 1. **服务发布**:服务提供者启动...

    dubbo源码实例

    这个实例旨在帮助初学者快速入门,理解Dubbo的核心概念和工作原理,通过源码分析深入掌握其内部机制。 一、Dubbo架构概览 Dubbo的核心组件包括服务提供者(Provider)、服务消费者(Consumer)、注册中心...

    dubbo 服务搭建,源码,压缩包

    9. **源码分析**:可能包含部分关键类或方法的源码解析,帮助理解 Dubbo 内部的工作机制。 10. **最佳实践**:可能会分享一些 Dubbo 使用中的最佳实践和注意事项,以避免常见问题。 综上所述,这个压缩包内容应是...

    dubbo入门示例源码

    2. 实现服务接口。 3. 配置服务提供者,指定接口、实现类、注册中心等信息。 4. 启动服务提供者,将服务暴露到注册中心。 而 "dubbo_consume_demo" 文件则包含了服务消费者的示例,主要流程为: 1. 引入服务提供者...

Global site tag (gtag.js) - Google Analytics