Dubbo + Zookeeper

系统管理员 2022-05-19 14:24 140阅读 0赞

最近在学习一个分布式项目，使用到了`dubbo`，之前没有使用过，体验一下，分布式项目地址：[点击这里][Link 1]

使用[dubbo官网][dubbo]的一张图来介绍下`dubbo`（本人才开始学习，如有错误，欢迎指正）：

![20180322102544516][]

*  Registry：**注册中心**，相当于**房产中介**，服务提供者和使用者都需要在这里注册/使用服务，我使用`zookeeper`实现。
 *  Monitor：**监控中心**，相当于**房产局**，它可以统计服务提供者和服务使用者的一些信息，及他们之间的关系，我使用`dubbo admin`实现。
 *  Provider：**服务提供者**，相当于**房东**，提供服务。
 *  Consumer：**服务消费者**，想当于**租户**，使用服务。

下面我通俗的解释下dubbo的整个流程，我**将服务比喻成房子**：

**start**：dubbo一启动，房东想好自己准备要租出去的房子

**register**：房东将房子拿到房产中介那边进行登记，并留下自己的联系方式

**subscribe**：租户告诉房产中介自己想租一个什么样的房子

**notify**：房产中介回复给租户符合条件的房子的房东的联系方式

**invoke**：租户拿着联系方式去找房东租房子

**count**：房产局全程监控着房东和租户之间的交易

其中：

*  start、register、subscribe在dubbo服务一启动就完成了
 *  notify、count是异步执行的
 *  invoke是同步执行的

## 一、搭建java和tomcat环境 ##

这一步比较简单，直接跳过，不会的可以看下这篇文章：[Linux搭建JavaWeb开发环境（Java、Tomcat、MySQL）][Linux_JavaWeb_Java_Tomcat_MySQL]

--------------------

## 二、搭建zookeeper ##

我使用的是`zookeeper-3.5.2-alpha`，[点我下载][Link 2]。

下载后将其解压：

wxs@ubuntu:~$ sudo tar zxf zookeeper-3.5.2-alpha.tar.gz
    wxs@ubuntu:~$ sudo mv zookeeper-3.5.2-alpha /usr
    wxs@ubuntu:~$ cd /usr/zookeeper-3.5.2-alpha
    wxs@ubuntu:/usr/zookeeper-3.5.2-alpha$ ls
    bin          ivysettings.xml       recipes
    build.xml    ivy.xml               src
    CHANGES.txt  lib                   zookeeper-3.5.2-alpha.jar
    conf         LICENSE.txt           zookeeper-3.5.2-alpha.jar.asc
    contrib      NOTICE.txt            zookeeper-3.5.2-alpha.jar.md5
    dist-maven   README_packaging.txt  zookeeper-3.5.2-alpha.jar.sha1
    docs

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11

在zookper文件夹下建立`logs`文件夹和`data`文件夹用于存放日志和数据：

wxs@ubuntu:/usr/zookeeper-3.5.2-alpha$ sudo mkdir data
    wxs@ubuntu:/usr/zookeeper-3.5.2-alpha$ sudo mkdir logs

*  1
 *  2

进入`conf`目录，复制一份`zoo_sample.cfg`为`zoo.cfg`，对其进行修改：

wxs@ubuntu:/usr/zookeeper-3.5.2-alpha$ cd conf/
    wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/conf$ cp zoo_sample.cfg zoo.cfg
    wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/conf$ vim zoo.cfg

*  1
 *  2
 *  3

配置下`dataDir`和`dataLogDir`的路径，为之前创建的两个文件夹的路径，`clientPort`使用默认的2181端口即可：   
![2018032209423299][]

我使用的时单机模式，没有配集群，这样就可以了。

进入到`bin`目录，启动服务即可：

wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh start
    ZooKeeper JMX enabled by default
    Using config: /usr/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg
    Starting zookeeper ... STARTED
    wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/bin$ ./zkServer.sh status
    ZooKeeper JMX enabled by default
    Using config: /usr/zookeeper-3.5.2-alpha/bin/../conf/zoo.cfg
    Client port found: 2181. Client address: localhost.
    Mode: standalone

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9

**小心踩坑：**

执行`./zkServer.sh start`时不要加`sudo`，如果root用户配置文件没有配`JAVA_HOME`会出现找不到`JAVA_HOME`！

wxs@ubuntu:/usr/zookeeper-3.5.2-alpha/bin$ sudo ./zkServer.sh start
    Error: JAVA_HOME is not set and java could not be found in PATH.

*  1
 *  2

**相关命令：**

> 启动服务：start 停止服务： stop 重启服务； restart 查看状态：status

--------------------

## 三、搭建dubbo监控中心 ##

**版本要求：**

请使用`dubbo-admin-2.5.6.war`及以上版本，否则会不支持JDK1.8！

下载链接：[点击这里][Link 3]

**小心踩坑：**

如果你的`zookeeper`和`dubbo-admin`在一台服务器上，`dubbo-admin`不用修改任何内容！

如果不在一台服务器上，将war包解压后，修改项目`/WEF-INF/dubbo.properties`文件，将zookeeper地址改为其所在服务器的地址（这里同时能修改root用户和guest用户的密码）。

![20180322143242449][]

--------------------

## 四、配置项目 ##

这里牵扯到项目代码，如果看不懂，可以下载文章开头的项目源码，或者直接使用官方提供的`dubbo-demo`，更为简单。

首先给服务提供方和服务使用方导入依赖包：

<properties>
            <dubbo.version>2.6.1</dubbo.version>
            <zookeeper.version>3.5.2-alpha</zookeeper.version>
            <curator.version>4.0.1</curator.version>
    </properties>
    
    
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        
        <exclusions>
            <exclusion>
                <groupId>org.springframework</groupId>
                <artifactId>spring</artifactId>
            </exclusion>
            <exclusion>
                <groupId>org.jboss.netty</groupId>
                <artifactId>netty</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <type>pom</type>
    </dependency>
    
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
    </dependency>

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24
 *  25
 *  26
 *  27
 *  28
 *  29
 *  30
 *  31
 *  32
 *  33
 *  34
 *  35
 *  36
 *  37

还需要在相关配置文件加上`dubbo`的`bean`的头部约束，将下面的添加到bean头部即可：

xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    
    http://code.alibabatech.com/schema/dubbo
    http://code.alibabatech.com/schema/dubbo/dubbo.xsd

*  1
 *  2
 *  3
 *  4

### 4.1 服务提供方代码 ###

对于服务提供方，如果我们想要`TbItemService`对外提供服务：

package jit.wxs.service.impl;
    
    import jit.wxs.pojo.TbItem;
    import jit.wxs.mapper.TbItemMapper;
    import jit.wxs.service.TbItemService;
    import com.baomidou.mybatisplus.service.impl.ServiceImpl;
    import org.springframework.stereotype.Service;
    
    /**
     * <p>
     * 商品表 服务实现类
     * </p>
     *
     * @author jitwxs
     * @since 2018-03-21
     */
    @Service
    public class TbItemServiceImpl extends ServiceImpl<TbItemMapper, TbItem> implements TbItemService {
    
    }

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20

需要修改spring关于service的配置文件，加入`dubbo`的配置信息：

<?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"
           xmlns:context="http://www.springframework.org/schema/context"
           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
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd">
    
        
        <context:component-scan base-package="jit.wxs.service"/>
    
        
        
        <dubbo:application name="e3-manager" />
        
        <dubbo:registry protocol="zookeeper" address="192.168.30.145:2181" />
        
        <dubbo:protocol name="dubbo" port="20880" />
        
        <dubbo:service interface="jit.wxs.service.TbItemService" ref="tbItemServiceImpl" timeout="600000"/>
    </beans>

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24
 *  25
 *  26
 *  27
 *  28

*  `dubbo:application`：提供方的应用名
 *  `dubbo:registry`：注册中心的类型和地址
 *  `dubbo:protocol`：这个服务要暴露在哪个端口上（使用方根据这个端口使用服务）
 *  `dubbo:service`：设置暴露的服务的接口，ref为该接口的bean，timeout为超时时间

### 4.2 服务使用方代码 ###

服务使用方，我使用`Spring MVC`来实现，修改Spring MVC的配置文件，加入dubbo的配置：

<?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"
           xmlns:context="http://www.springframework.org/schema/context"
           xmlns:mvc="http://www.springframework.org/schema/mvc"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
            http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
            http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        
        <context:component-scan base-package="jit.wxs.web"/>
    
        
        <mvc:annotation-driven />
    
        
        
    
        
        <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
            <property name="prefix" value="/WEB-INF/jsp/" />
            <property name="suffix" value=".jsp" />
        </bean>
    
        
        
        <dubbo:application name="e3-manager-web"/>
        
        <dubbo:registry protocol="zookeeper" address="192.168.30.145:2181"/>
        
        <dubbo:reference interface="jit.wxs.service.TbItemService" id="tbItemService" />
    </beans>

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24
 *  25
 *  26
 *  27
 *  28
 *  29
 *  30
 *  31
 *  32
 *  33
 *  34
 *  35

*  `dubbo:application`： 使用方的应用名
 *  `dubbo:registry`：注册中心的类型和地址
 *  `dubbo:reference`：要使用的服务的接口，并将返回的注入bean，名称为id设的值

如果配置没有问题的话，现在使用方已经能够使用提供方提供的服务了，直接将`tbItemService`注入进来即可：

package jit.wxs.web;
    
    import jit.wxs.pojo.TbItem;
    import jit.wxs.service.TbItemService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    /**
     * <p>
     * 商品表 前端控制器
     * </p>
     *
     * @author jitwxs
     * @since 2018-03-21
     */
    @RestController
    @RequestMapping("/items")
    public class TbItemController {
        @Autowired
        private TbItemService tbItemService;
    
        @GetMapping("/{id}")
        public TbItem getItemById(@PathVariable Long id) {
            TbItem item = null;
            if(id != null) {
                item = tbItemService.selectById(id);
            }
    
            return item;
        }
    }

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24
 *  25
 *  26
 *  27
 *  28
 *  29
 *  30
 *  31
 *  32
 *  33
 *  34

--------------------

## 五、测试 ##

服务器上分别启动`zookper`和`tomcat`：

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9

wxs@ubuntu:/usr/apache-tomcat-8.5.28/bin$ ./startup.sh 
    Using CATALINA_BASE:   /usr/apache-tomcat-8.5.28
    Using CATALINA_HOME:   /usr/apache-tomcat-8.5.28
    Using CATALINA_TMPDIR: /usr/apache-tomcat-8.5.28/temp
    Using JRE_HOME:        /usr/jdk1.8.0_161/jre
    Using CLASSPATH:       /usr/apache-tomcat-8.5.28/bin/bootstrap.jar:/usr/apache-tomcat-8.5.28/bin/tomcat-juli.jar
    Tomcat started.

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7

使用下面命令可以持续显示`tomcat`的输出：

> wxs@ubuntu:/usr/apache-tomcat-8.5.28/bin$ tail -f ../logs/catalina.out

分别启动服务提供方的项目和服务使用方的项目：   
![2018032211294940][]

测试下`/items/{id}`这个API：   
![20180322113130841][]

成功！下面再访问下监控中心，因为监控中心和`zookeeper`在一台服务器上，我的tomcat部署在8888端口，即访问`192.168.30.145:8888/dubbo-admin`即可，用户名密码默认为root：

![20180322142406319][]

查看所有注册的服务：   
![20180322142709390][]

查看包括消费者和提供者的所有应用名：   
![20180322142715245][]

消费者、提供者详细信息：   
![20180322142720610][]

[Link 1]: https://github.com/jitwxs/e3mall
[dubbo]: http://dubbo.apache.org/
[20180322102544516]: /images/20220519/a5b1b98b3e324baca3b0989bb5b94900.png
[Linux_JavaWeb_Java_Tomcat_MySQL]: http://blog.csdn.net/yuanlaijike/article/details/78877830
[Link 2]: http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.5.2-alpha/zookeeper-3.5.2-alpha.tar.gz
[2018032209423299]: /images/20220519/4ce1cd795ea149879f185a0aa7507875.png
[Link 3]: https://download.csdn.net/download/yuanlaijike/10302261
[20180322143242449]: /images/20220519/7108a3e9bc0a4484bff09de52a2daae1.png
[2018032211294940]: /images/20220519/a1eb70150e724d1bbb77f461d98738db.png
[20180322113130841]: /images/20220519/c1e20ccdb3ef499d8e62017fe63885be.png
[20180322142406319]: /images/20220519/bf81b20fd83449a381185419bb62cc9d.png
[20180322142709390]: /images/20220519/ab8c909bfbf44e31ad60422c567f7f6f.png
[20180322142715245]: /images/20220519/3ab5a2077b7d4c759b94d563fc5e190b.png
[20180322142720610]: /images/20220519/7c80548542ec4a2db458891902d4703c.png