最近想学习一下dubbo,看了很多前辈们的文章和资料,现对自己的理解做个总结:

要说dubbo就先了解一下RPC:

概念:

RPC(Remote Procedure Call):远程过程调用,是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。它使得在本地调用远端的程序就好像是在调用本地的程序一样。

RPC协议假定某些传输协议是存在的,如TCP或UDP,为通信程序之间携带信息数据。在OSI网络通信模型(七层模型)中,RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

RPC调用过程:

  • 客户端以本地服务方式调用服务
  • client stub作为代理,然后处理调用与调用的参数
  • client stub发送调用到远端的系统,通过TCP或UDP
  • server stub处理client stub发过来的调用与参数
  • server stub调用真正提供的服务
  • server stub处理回复,然后发送给客户端

Dubbo

1、什么是dubbo :Dubbo是阿里巴巴SOA服务化治理方案的核心框架,是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。

   soa:“面向服务架构”,它提供的是一种架构风格和理念,而并非是一种技术或者产品。SOA提倡将不同应用程序的业务功能封装成“服务”并宿主起来,通常以接口和契约的形式暴露并提供给外界应用访问(通过交换消息),达到不同系统可重用的目的。

 2、Dubbo的技术架构图如下:

我们解释一下这个架构图:

a、Consumer服务消费者(花钱的),Provider服务提供者(给钱的),Container服务容器(领钱的地方)。

b、服务提供者先启动,然后注册服务(registry)。

c、Monitor这是一个监控,图中虚线表明Consumer 和Provider通过异步的方式发送消息至Monitor,Consumer和Provider会将信息存放在本地磁盘,平均1min会发送一次信息。Monitor在整个架构中是可选的。

d、Monitor功能需要单独配置,不配置或者配置以后,Monitor挂掉并不会影响服务的调用。

 

3、Dubbo服务消费者调用过程

 

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

首先通过 ReferenceConfig 类的 private void init() 方法会先检查初始化所有的配置信息后,调用 private T createProxy(Map map) 创建代理,消费者最终得到的是服务的代理, 在 createProxy 接着调用 Protocol 接口实现的 Invoker refer(Class type, URL url) 方法生成 Invoker 实例(如上图中的红色部分),这是服务消费的关键。接下来把 Invoker 通过 ProxyFactory 代理工厂转换为客户端需要的接口(如: HelloWorld ),创建服务代理并返回。

消费端的初始化过程

1、把服务引用的信息封装成URL并注册到zk注册中心;

2、监听注册中心的服务的上下线;

3、连接服务提供端,创建NettyClient对象;

4、将这些信息包装成DubboInvoker消费端的调用链,创建消费端Invoker实例的服务代理并返回;

消费端的服务引用过程

1、经过负载均衡策略,调用提供者;

2、选择其中一个服务的URL与提供者netty建立连接,使用ProxyFactory 创建远程通信,或者本地通信的,Invoker发到netty服务端;

3、服务器端接收到该Invoker信息后,找到对应的本地Invoker,处理Invocation请求;

4、获取异步,或同步处理结果;

  • 异步 不需要返回值:直接调用ExchangeClient.send()方法;
  • 同步 需要返回值:使用ExchangeClient.request()方法,返回一个ResponseFuture,一直阻塞到服务端返回响应结果;

 

 4、最简单的dubbo实例

1. 服务提供方和消费方都需要的包(这里我新建的maven工程为pom工程,将共同的项目依赖写到pom.xml中)

  • 总的项目结构为
    这里写图片描述

  • pom.xml文件内容为

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.test</groupId>
  <artifactId>dubbo-demo</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>pom</packaging>

   <properties>
        <motan.version>0.3.0</motan.version>
        <!-- 在阿里巴巴内部广泛使用的GA版本为:2.4.9,强烈推荐此版本 -->
        <dubbo.version>2.5.3</dubbo.version>
        <dubbox.version>2.8.4</dubbox.version>
        <spring.version>4.3.6.RELEASE</spring.version>
        <java.version>1.7</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
      <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.5.3</version>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!-- spring相关 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-web</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-orm</artifactId>
            <version>${spring.version}</
版权声明:本文为lixiangfei原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/lixiangfei/p/9732800.html