本文采用Dubbo与Zookeeper、Spring框架的整合。整个项目的代码已经上传到我的github https://github.com/wangyuanjun008/wyj-dubbo-demo.git 欢迎查看。
主要是以下几个步骤:

  1. 安装Zookeeper,启动;
  2. 创建MAVEN项目,构建Dubbo+Zookeeper+Spring实现的简单Demo;
  3. 安装Dubbo-admin,实现监控。

一:Zookeeper介绍与安装

本Demo中的Dubbo注册中心采用的是Zookeeper。为什么采用Zookeeper呢?

1
2
3
Zookeeper是一个分布式的服务框架,是树型的目录服务的数据存储,能做到集群管理数据 ,这里能很好的作为Dubbo服务的注册中心。
Dubbo能与Zookeeper做到集群部署,当提供者出现断电等异常停机时,Zookeeper注册中心能自动删除提供者信息,当提供者重启时,能自动恢复注册数据,以及订阅请求

到官网下载并安装到windows上,可参考博文: http://blog.csdn.net/tlk20071/article/details/52028945
我使用的是docker容器,在docker上下载zooleeper镜像,然后使用如下命令创建并启动zookeeper容器,映射与本机的端口号

1
docker run --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 -d zookeeper:latest

zookeeper

我之前下载过,所以我直接启动zookeeper容器

二:创建MAVEN项目

项目结构:
主要分三大模块:
dubbo-api : 存放公共接口;
dubbo-consumer : 调用远程服务;
dubbo-provider : 提供远程服务。
project

下面将详细叙述代码构建过程。

  1. 首先构建MAVEN项目,导入所需要的jar包依赖。
    需要导入的有spring, dubbo, zookeeper等jar包。
    (详情参看后面提供的项目代码)

  2. 建dubbo-api的MAVEN项目(有独立的pom.xml,用来打包供提供者消费者使用)。
    在项目中定义服务接口:该接口需单独打包,在服务提供方和消费方共享。
    api

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    package com.wyj.dubbo.demo;
    /**
    * 定义服务接口
    *
    *
    * @author:WangYuanJun
    * @date:2018年1月9日 下午9:03:40
    */
    public interface DemoService {
    String sayHello(String name);
    }
  3. 创建dubbo-provider的MAVEN项目(有独立的pom.xml,用来打包供消费者使用)。

    实现公共接口,此实现对消费者隐藏:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    package com.wyj.dubbo.demo.provider;
    import com.wyj.dubbo.demo.DemoService;
    /**
    * 服务提供者实现服务定义
    *
    *
    * @author:WangYuanJun
    * @date:2018年1月9日 下午9:07:16
    */
    public class DemoServiceImpl implements DemoService {
    public String sayHello(String name) {
    return "Hello " + name;
    }
    }

    需加入公共接口所在的依赖
    provider-pom

    用Spring配置声明暴露服务

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    <?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-admin 或 dubbo-monitor 会显示这个名字,方便辨识 -->
    <dubbo:application name="demotest-provider" owner="programmer"
    organization="dubbox" />
    <!--使用 zookeeper 注册中心暴露服务,注意要先开启 zookeeper -->
    <dubbo:registry address="zookeeper://192.168.99.100:2181" />
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!--使用 dubbo 协议实现定义好的 api.PermissionService 接口 -->
    <dubbo:service interface="com.wyj.dubbo.demo.DemoService"
    ref="demoService" protocol="dubbo" />
    <!--具体实现该接口的 bean -->
    <bean id="demoService" class="com.wyj.dubbo.demo.provider.DemoServiceImpl" />
    </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
    package com.wyj.dubbo.demo.provider;
    import java.io.IOException;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    /**
    * 启动服务提供者
    *
    *
    * @author:WangYuanJun
    * @date:2018年1月9日 下午9:10:38
    */
    public class Provider {
    public static void main(String[] args) throws IOException {
    ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("dubbo-provider.xml");
    System.out.println(classPathXmlApplicationContext.getDisplayName() + ": here");
    classPathXmlApplicationContext.start();
    System.out.println("服务已经启动...");
    System.in.read();
    }
    }
  4. 创建dubbo-consumer的MAVEN项目(可以有多个consumer,但是需要配置好)。
    调用所需要的远程服务:

    通过Spring配置引用远程服务:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    <?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="demotest-consumer" owner="programmer" organization="dubbox" />
    <!--向 zookeeper 订阅 provider 的地址,由 zookeeper 定时推送 -->
    <dubbo:registry address="zookeeper://192.168.99.100:2181" />
    <!--使用 dubbo 协议调用定义好的 api.demoService 接口 -->
    <dubbo:reference id="demoService" interface="com.wyj.dubbo.demo.DemoService" />
    </beans>

    启动Consumer,调用远程服务:

    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
    package com.wyj.dubbo.demo.consumer;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    import com.wyj.dubbo.demo.DemoService;
    /**
    * 启动服务消费者
    *
    *
    * @author:WangYuanJun
    * @date:2018年1月9日 下午10:00:33
    */
    public class Consumer {
    public static void main(String[] args) {
    ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("dubbo-consumer.xml");
    classPathXmlApplicationContext.start();
    DemoService demoService = (DemoService) classPathXmlApplicationContext.getBean("demoService");
    while (true) {
    try {
    Thread.sleep(1000);
    String hello = demoService.sayHello("world");
    System.out.println(hello);
    } catch (Throwable throwable) {
    throwable.printStackTrace();
    }
    }
    }
    }
  5. 运行项目,先确保provider已被运行后再启动consumer模块:
    运行提供者:
    provider

    消费者成功调用提供者所提供的远程服务:
    consumer