dubbo 的rpc 詳情 - dubbo 的rpc,spring,RPC,maven,雲原生,雲計算數據科學探索者博客

最近想學習一下dubbo，看了很多前輩們的文章和資料，現對自己的理解做個總結：

要説dubbo就先了解一下RPC：

概念：

RPC（Remote Procedure Call）：遠程過程調用，是一種通過網絡從遠程計算機程序上請求服務，而不需要了解底層網絡技術的協議。它使得在本地調用遠端的程序就好像是在調用本地的程序一樣。

RPC協議假定某些傳輸協議是存在的，如TCP或UDP，為通信程序之間攜帶信息數據。在OSI網絡通信模型（七層模型）中，RPC跨越了傳輸層和應用層。RPC使得開發包括網絡分佈式多程序在內的應用程序更加容易。

RPC調用過程：

dubbo 的rpc_maven

客户端以本地服務方式調用服務
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的技術架構圖如下：

dubbo 的rpc_spring_02

我們解釋一下這個架構圖：

a、Consumer服務消費者（花錢的），Provider服務提供者（給錢的），Container服務容器（領錢的地方）。

b、服務提供者先啓動，然後註冊服務（registry）。

c、Monitor這是一個監控，圖中虛線表明Consumer 和Provider通過異步的方式發送消息至Monitor，Consumer和Provider會將信息存放在本地磁盤，平均1min會發送一次信息。Monitor在整個架構中是可選的。

d、Monitor功能需要單獨配置，不配置或者配置以後，Monitor掛掉並不會影響服務的調用。

3、Dubbo服務消費者調用過程

dubbo 的rpc_spring_03

上圖是服務消費的主過程：

首先通過 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中）

總的項目結構為

dubbo 的rpc_dubbo 的rpc_04

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}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjrt</artifactId>
            <version>1.6.11</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.6.11</version>
        </dependency>
    </dependencies>
   <modules>
    <module>demo-api</module>
    <module>dubbo-consumer</module>
    <module>dubbo-provider</module>
   </modules>
</project>

2. 在demo-api中定義服務接口（注意服務提供方和消費方都需要依賴這個項目）

package com.test;

public interface DemoService{  
     String sayHello(String name);  
}

3. 服務提供方實現

項目結構
實現接口

package com.test;
import org.springframework.stereotype.Service;

import com.test.DemoService;
@Service("demoService")
public class DemoServiceImpl implements DemoService{

    @Override
    public String sayHello(String name) {
        // TODO Auto-generated method stub
        return name; 
    }  
}

聲明暴露服務：

<?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:application name="dubbo_provider"  />  

    <!-- 使用zookeeper註冊中心暴露服務地址 -->  
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />   

    <!-- 用dubbo協議在20880端口暴露服務 -->  
    <dubbo:protocol name="dubbo" port="20880" />  

    <!-- 聲明需要暴露的服務接口 -->  
    <dubbo:service interface="com.test.DemoService" ref="demoService" />  
</beans>

在springmvc.xml中掃描service註解並將dubbo-provider.xml中的相關的dubbo配置引入進來

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:util="http://www.springframework.org/schema/util" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/aop   
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd   
        http://www.springframework.org/schema/beans   
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd   
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd   
        http://www.springframework.org/schema/util 
        http://www.springframework.org/schema/util/spring-util-4.0.xsd"
    default-autowire="byName">

    <aop:aspectj-autoproxy />
    <context:component-scan base-package="com.test" />
    <import resource="classpath:dubbo-provider.xml" />
</beans>

加載Spring配置，啓動服務：

package com.test;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Test {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:springmvc.xml");
        context.start();

        System.out.println("Dubbo provider start...");

        try {
            System.in.read();   // 按任意鍵退出
        } catch (IOException e) {
            e.printStackTrace();
        } 
    }
}

　　4. 服務消費者實現

項目結構
在dubbo-consumer.xml中聲明所所需要消費的服務

<?xml versinotallow="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:application name="dubbo_consumer" />       
      <!-- 使用multicast廣播註冊中心暴露發現服務地址 -->    
    <dubbo:registry  protocol="zookeeper" address="zookeeper://127.0.0.1:2181" />         
      <!-- 生成遠程服務代理，可以和本地bean一樣使用demoService -->    
    <dubbo:reference id="demoService" interface="com.test.DemoService" />    
</beans>

在springmvc.xml中掃描service註解並將dubbo-consumer.xml中的相關的dubbo配置引入進來

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:util="http://www.springframework.org/schema/util" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/aop   
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd   
        http://www.springframework.org/schema/beans   
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd   
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd   
        http://www.springframework.org/schema/util 
        http://www.springframework.org/schema/util/spring-util-4.0.xsd"
    default-autowire="byName">

    <aop:aspectj-autoproxy />
    <context:component-scan base-package="com.test" />
    <import resource="classpath:/dubbo-consumer.xml" />
</beans>

加載Spring配置，調用服務：

package com.test;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Test {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "classpath:springmvc.xml" });

        context.start();
        DemoService demoService = (DemoService) context.getBean("demoService");

        System.out.println(demoService.sayHello("哈哈哈"));
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

如果出現以下結果則調用成功
通過dubbo-admin管理後台可以看到服務的提供方與消費方

本文章為轉載內容，我們尊重原作者對文章享有的著作權。如有內容錯誤或侵權問題，歡迎原作者聯繫我們進行內容更正或刪除文章。

數據科學探索者博客

數據科學探索者博客

博客 / 詳情

dubbo 的rpc

消費端的初始化過程

消費端的服務引用過程

1. 服務提供方和消費方都需要的包（這裏我新建的maven工程為pom工程，將共同的項目依賴寫到pom.xml中）

2. 在demo-api中定義服務接口（注意服務提供方和消費方都需要依賴這個項目）

3. 服務提供方實現

發佈評論

Product

Company

Support

Company

博客 / 詳情

dubbo 的rpc

消費端的初始化過程

消費端的服務引用過程

1. 服務提供方和消費方都需要的包（這裏我新建的maven工程為pom工程，將共同的項目依賴寫到pom.xml中）

2. 在demo-api中定義服務接口（注意服務提供方和消費方都需要依賴這個項目）

3. 服務提供方實現

發佈 評論

發佈評論