Dubbo學習筆記（一）—— 建立一個簡單的Dubbo入門專案演示HelloWorld

阿新 • • 發佈：2019-02-17

一、Dubbo簡介

1、dubbo是什麼？

▶ 一個分散式服務框架

▶ 一個RPC遠端服務呼叫方案

▶ 一個SOA服務治理方案

2、dubbo架構圖

3、節點說明

Provider：暴露服務的服務提供方

Consumer：呼叫遠端服務的服務消費方

Registry：發現並註冊服務的服務註冊中心

Monitor：統計服務呼叫次數和呼叫時間的監控中心

Container：服務的執行容器

4、呼叫流程說明

① 服務容器負責啟動、載入、執行服務提供方；

② 服務提供方在啟動時，向註冊中心註冊自己提供的服務；

③ 服務消費方在啟動時，向註冊中心訂閱自己所要消費的服務；

④ 註冊中心返回服務提供方的地址列表給服務消費方，如果有變更，註冊中心將基於長連線推送變更資料給服務消費方；

⑤ 服務消費方從服務提供方的地址列表中，基於軟負載均衡演算法，選一臺提供者進行呼叫，如果呼叫失敗，再選另一臺呼叫；

⑥ 服務消費方和提供方，在記憶體中統計呼叫次數和呼叫時間，定時第一分鐘傳送統計資料到監控中心。

二、啟動zookeeper作為dubbo的註冊中心

zookeeper是一個分散式的服務框架，是樹型的目錄服務的資料儲存，能做到管理叢集資料，dubbo與zookeeper一起可以做到叢集部署，當服務提供方出現異常或斷電停機時，zookeeper註冊中心能自動刪除提供者資訊，當提供方重啟時，能自動恢復註冊資料，以及訂閱請求。

三、在Linux下部署dubbo的監控中心（方便檢視服務提供方和消費方的情況）

1、下載dubbo-admin的war包

之前dubbo還沒有移交給apache時，在阿里巴巴的github上還可以找到dubbo-admin這個專案，我們只需要下載下來打成war包即可，但現在dubbo已經成為apache開源組織的一個頂級專案之一，在apache的github上不知道為什麼找不到dubbo-admin這個專案了，所以這裡推薦一個已經打包好的war包給大家下載，支援jdk8，下載地址：https://download.csdn.net/download/u010608720/9542675，如果沒有積分的話也可以去我的github上去下載：https://github.com/Alexshi5/dubbo-demo

2、將war包上傳到linux中然後部署到tomcat下面的webapps目錄中，然後啟動tomcat

[[email protected] ~]# cp dubbo-admin-2.8.4.war /usr/local/tomcat9/webapps/

3、zookeeper和tomcat都啟動後，在瀏覽器中訪問監控中心

如果無法訪問的，先檢查是不是linux的防火牆沒關，然後再依次檢查IP地址、埠號、專案名是否輸入錯誤，賬號密碼都是root，登陸之後的頁面如下圖所示：

四、建立dubbo專案

1、專案結構規劃（為了簡化demo，除了父專案打包方式為pom，其他三個子模組打包方式均為jar包，使用的maven原型為quickstart）

dubbo-parent：父專案

dubbo-api：存放所有公共介面的模組，服務提供方與服務消費方均依賴此模組

dubbo-provider：實現公共介面並提供服務的服務提供方所在模組

dubbo-consumer：消費服務的服務消費方所在的模組

2、建立父專案dubbo-parent，pom檔案內容如下

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <dubbo.version>2.5.8</dubbo.version>
        <zookeeper.version>3.4.6</zookeeper.version>
        <zkclient.version>0.1</zkclient.version>
    </properties>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
            </dependency>

            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>${zookeeper.version}</version>
                <type>pom</type>
            </dependency>

            <dependency>
                <groupId>com.github.sgroschupf</groupId>
                <artifactId>zkclient</artifactId>
                <version>${zkclient.version}</version>
            </dependency>

        </dependencies>
    </dependencyManagement>

3、建立子模組dubbo-api，pom檔案如下：

    <dependencies>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <type>pom</type>
        </dependency>

        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

    </dependencies>

① 在dubbo-api的包中建立一個介面DemoService，內容如下：

package com.mengfei.api;

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

② 進入到dubbo-api的根目錄，將dubbo-api打包成jar包安裝到本地的maven倉庫

4、建立子模組dubbo-provider，在pom檔案中新增dubbo-api的依賴

    <dependencies>
        <dependency>
            <groupId>${project.groupId}</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>${project.version}</version>
        </dependency>
    </dependencies>

① 在dubbo-provider的包中建立一個實現類，實現DemoService介面

package com.mengfei.provider;

import com.mengfei.api.DemoService;

public class DemoServiceImpl implements DemoService {
    public String sayHello(String name) {
        return "Hello" + name;
    }
}

② 在src/main目錄下建立一個resources目錄，並在此目錄下建立一個dubbo-provider.xml檔案，內容如下：

<?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"></dubbo:application>
    <!--使用zookeeper服務中心註冊服務，要先啟動zookeeper
        register:false代表只訂閱，不註冊
        subscribe:false代表只註冊，不訂閱
        check:false代表註冊中心不存在時，不報錯
        address:配置zookeeper的ip和埠號，叢集用逗號隔開
    -->
    <dubbo:registry address="zookeeper://192.168.188.130:2181" subscribe="false" check="false"></dubbo:registry>
    <!--用dubbo協議在29999埠暴露服務-->
    <dubbo:protocol name="dubbo" port="29999"></dubbo:protocol>
    <!--要註冊的服務介面-->
    <dubbo:service interface="com.mengfei.api.DemoService" ref="demoService"></dubbo:service>
    <!--實現介面的實現類-->
    <bean id="demoService" class="com.mengfei.provider.DemoServiceImpl"></bean>
</beans>

③ 在dubbo-provider的包中建立一個測試類ProviderTest，用來載入spring的配置檔案，啟動服務提供方，內容如下：

package com.mengfei.provider;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ProviderTest {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:dubbo-provider.xml");
        context.start();
        System.out.println("服務已經啟動！");
        System.in.read();//在控制檯按任意鍵退出
    }
}

④ 啟動main方法就啟動了服務提供方，這時檢視dubbo-admin監控中心

5、建立子模組dubbo-consumer，在pom檔案中新增dubbo-api的依賴

<dependencies>
        <dependency>
            <groupId>${project.groupId}</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>${project.version}</version>
        </dependency>
    </dependencies>

① 在src/main目錄下建立resources目錄，並在此目錄下建立dubbo-consumer.xml檔案，內容如下：

<?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-consumer"/>
    <!--向註冊中心訂閱服務，由zookeeper定時推送-->
    <dubbo:registry address="zookeeper://192.168.188.130:2181"/>
    <!--引用已經註冊的服務-->
    <dubbo:reference id="demoService" interface="com.mengfei.api.DemoService"/>
</beans>

② 在dubbo-consumer的包中建立測試類ConsumerTest，用於載入spring的配置檔案，啟動服務消費方

package com.mengfei.consumer;

import com.mengfei.api.DemoService;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ConsumerTest {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:dubbo-consumer.xml");
        context.start();
        DemoService demoService = (DemoService) context.getBean("demoService");
        String hello = demoService.sayHello("World");
        System.out.println(hello);
        System.in.read();//在控制檯按任意鍵退出
    }
}

③ 啟動main方法就啟動了服務消費方，檢視dubbo-consumer監控中心如下：

④ 檢視控制檯輸出結果

演示結束！

參考：