Dubbo入門(2) - 簡單實踐

時間  2019-11-22
標籤 dubbo 入門 簡單 實踐 欄目 Dubbo 简体版
原文   原文鏈接

做者：不洗碗工做室 - Markluxjava

出處：Dubbo入門(2) - 簡單實踐mysql

版權歸做者全部，轉載請註明出處git

在瞭解什麼是分佈式框架以後，咱們須要上手實踐一下，來了解整個系統是如何運做起來的。github

本文抱着學習的目的來嘗試使用dubbo搭建一個簡單的分佈式服務，而且使用dubbokeeper來進行服務的監控。web

參考自：聊聊dubbo和最簡單的dubbo教程spring

準備工做

在正式使用dubbo以前，須要準備兩樣東西：sql

1. 服務註冊中心(ZooKeeper)

dubbo的消費方和服務方都須要在一個統一的註冊中心進行註冊才能使用，搭建一個zookeeper便可，固然你也能夠使用其餘的註冊中心並集成進去。數據庫

zookeeper的搭建流程很簡單，參考此文便可（僅僅是最簡單的單機版，並不複雜）。apache

2. 服務監控中心（dubbokeeper）

爲了監控整個分佈式服務的運行狀況，最好可以有一個可視化的管理和監控應用，這裏選用由dubboclub團隊開發的dubbokeeper，固然也能夠使用dubbo官方的dubboadmin項目。編程

因爲dubbokeeper的部署有些複雜，在這裏仍是簡要的描述一下，注意監控軟件並非必要的，可是爲了可以看到服務運行的效果，建議仍是部署一個。

部署流程參考此文

下載源碼

首先須要獲取dubbokeeper的源碼，能夠從github上獲取，git地址：

https://github.com/dubboclub/dubbokeeper
複製代碼

下面咱們假設將dubbokeeper克隆到了~/dubbokeeper這個目錄下。

修改配置

在此以前，首先須要肯定你要使用何種數據庫，dubbokeeper目前支持MySQL,MongoDB和Lucene三種數據儲存方案，咱們以MySQL爲例進行部署。

首先要填寫~/dubbokeeper/conf/dubbo-mysql.properties配置文件，下面給出比較重要的配置項說明：

dubbo.registry.address=zookeeper://localhost:2181 #註冊中心地址
dubbo.protocol.name=dubbo
dubbo.protocol.port=20884 #dubbo服務端口
dubbo.monitor.mysql.url=jdbc:mysql://localhost:3306/dubbo-monitor #mysql服務地址
dubbo.monitor.mysql.username=root
dubbo.monitor.mysql.password=secret #用戶名及密碼
複製代碼

接下來要填寫~/dubbokeeper/dubbokeeper-ui/src/main/resources/dubbo.properties配置文件中的註冊中心和網絡服務器類型等參數。

初始化數據庫

建立一個mysql數據庫，並運行~/dubbokeeper/doc/storage/mysql/sql/application.sql建立表結構。

編譯打包

執行~/dubbokeeper/install-mysql.sh進行打包，最終會生成target輸出目錄。

啓動部署

這一步要啓動幾個服務後才能去部署應用，注意順序

首先須要啓動zookeeper服務，注意端口的配置要和配置文件一致。

接下來執行target目錄下的mysql-dubbokeeper-server/bin/start-mysql.sh啓動儲存服務。

最後將target目錄下的mysql-dubbokeeper-ui中的war包複製到tomcat（本身部署）的webapps目錄下，啓動tomcat便會自動進行解壓和安裝，以後訪問http://localhost:8080/dubbokeeper-ui-1.0.1看到以下界面，即爲安裝成功。

建立API

如今正式開始編程。咱們將使用dubbo建立一個很是簡單的、只有一個消費者和一個服務提供方的例子。

首先第一步是建立雙方都須要依賴的數據交換定義，經過一個interface來實現。

建立maven項目msa-demo-api，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.marklux</groupId>
    <artifactId>msa-demo-api</artifactId>
    <version>1.0-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>
</project>
複製代碼

而後在com.marklux.dubbo.demo包中添加DemoService接口，代碼以下：

package com.marklux.dubbo.demo;

/**
 * Created by lumin on 18/5/15.
 */
public interface DemoService {
    String sayHello(String name);
}
複製代碼

以後的服務提供方根據這個接口實現服務，消費者根據接口調用服務。（有點相似Thrift裏的IDL文件）

建立服務提供者

建立一個新的maven模塊msa-demo-provider，用於實現DemoService服務。模塊結構以下：

項目的pom.xml中須要添加對msa-demo-api模塊的依賴：

<?xml version="1.0" encoding="UTF-8"?>
<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.marklux</groupId>
    <artifactId>msa-demo-provider</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>com.marklux</groupId>
            <artifactId>msa-demo-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>
複製代碼

首先編寫DemoServiceImpl實現服務內容，代碼以下：

package com.marklux.dubbo.demo.impl;

import com.marklux.dubbo.demo.DemoService;
import org.springframework.stereotype.Service;

/**
 * Created by lumin on 18/5/15.
 */
@Service("demoService")
public class DemoServiceImpl implements DemoService {

    public String sayHello(String name) {
        return "Hello, " + name;
    }
}
複製代碼

接下來填寫msa-demo-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"  />

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

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

    <!-- 聲明須要暴露的服務接口 -->
    <dubbo:service interface="com.marklux.dubbo.demo.DemoService" ref="demoService" />
</beans>
複製代碼

而後填寫springmvc.xml，用於給入口類提供Spring服務容器的配置：

<?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.marklux.dubbo.demo" />
    <import resource="classpath:msa-demo-provider.xml" />
</beans>
複製代碼

最後在com.marklux.dubbo.demo.test包中添加測試啓動類，用於啓動服務：

package com.marklux.dubbo.demo.test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

/**
 * Created by lumin on 18/5/15.
 */
public class DemoServiceImplTest  {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring-mvc.xml");
        context.start();
        System.out.println("Dubbo Service started....");
        try {
            System.in.read();   // 按任意鍵退出
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
複製代碼

啓動DemoServiceImplTest類後服務就會註冊並啓動，這時候能夠在dubbokeeper中看到服務的狀態：

建立消費者

最後來建立一個調用服務的消費者，添加一個maven模塊msa-demo-client，pom.xml同上，添加對msa-demo-api模塊的依賴，注意並不須要msa-demo-provider的依賴。

模塊的結構以下：

只有一個測試的啓動類，代碼以下： 

package com.marklux.dubbo.demo.test;

import com.marklux.dubbo.demo.DemoService;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

/**
 * Created by lumin on 18/5/15.
 */
public class DemoServiceConsumerTest {

    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的配置文件msa-demo-client.xml和spring的配置文件springmvc.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" />
    <!-- 使用multicast廣播註冊中心暴露發現服務地址 -->
    <dubbo:registry  protocol="zookeeper" address="zookeeper://127.0.0.1:2181" />
    <!-- 生成遠程服務代理，能夠和本地bean同樣使用demoService -->
    <dubbo:reference id="demoService" interface="com.marklux.dubbo.demo.DemoService" />
</beans>
複製代碼
<?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.marklux.dubbo.demo" />
    <import resource="classpath:msa-demo-consumer.xml" />
</beans>
複製代碼

萬事俱備，如今啓動DemoServiceConsumerTest，能夠看到成功調用了DemoService：

在dubbokeeper中一樣能夠查看到其相關狀態：

小結

至此，一個最簡單的使用dubbo協議進行服務-調用的demo就完成了。能夠看到最顯著的特色是，在消費者中調用服務方提供的服務無需添加額外代碼，整個調用過程徹底透明。

另外借助dubbokeeper這樣的監控端，也更可以直觀的理解整個應用服務的分佈和運行狀況。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程