Dubbo入门实战：Spring + Zookeeper + Dubbo

一、前言

了解Dubbo以后，自然要搭建一个简单的Demo实现。本文采用Dubbo与Zookeeper、Spring框架的整合。

主要是以下几个步骤：

1. 安装Zookeeper,启动；
2. 创建MAVEN项目，构建Dubbo+Zookeeper+Spring实现的简单Demo；
3. 安装Dubbo-admin，实现Dubbo服务治理。

二、Zookeeper 介绍与安装

Demo中的Dubbo注册中心采用的是Zookeeper。

为什么采用Zookeeper呢？

Zookeeper是一个分布式的服务框架，是树型目录服务的数据存储，能做到集群管理数据，这里能很好的作为Dubbo服务的注册中心。

Dubbo能与Zookeeper配合做到集群部署，当提供者出现断电等异常停机时，Zookeeper注册中心能自动删除提供者信息，当提供者重启时，能自动恢复注册数据，以及订阅请求。

具体的安装方法在此不一一叙述，可参考博文： 《ZooKeeper进阶（一）：Zookeeper简介》、《ZooKeeper进阶（二）：ZooKeeper的运行》。

安装完成后，进入到bin目录，并且启动zkServer.cmd，脚本中会启动一个java进程。

注：需要先启动zookeeper后，后续dubbo demo代码运行才能使用zookeeper注册中心的功能。

三、创建 MAVEN 项目

项目结构：
主要分三大模块：

• dubbo-api : 存放公共接口；
• dubbo-consumer :　调用远程服务；
• dubbo-provider : 提供远程服务。

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

1. 首先构建MAVEN项目，导入所需要的jar包依赖。 需要导入的有spring, dubbo, zookeeper等jar包。
2. 创建dubbo-api的MAVEN项目(有独立的pom.xml，用来打包供提供者、消费者使用)。
   在项目中定义服务接口：该接口需单独打包，在服务提供方和消费方共享。
   

package com.alibaba.dubbo.demo;
import java.util.List;
public interface DemoService {
    List<String> getPermissions(Long id);
}

3. 创建dubbo-provider的MAVEN项目(有独立的pom.xml，用来打包供消费者使用)。
   实现公共接口，此实现对消费者隐藏：

package com.alibaba.dubbo.demo.impl;
import com.alibaba.dubbo.demo.DemoService;
import java.util.ArrayList;
import java.util.List;
public class DemoServiceImpl implements DemoService {
    public List<String> getPermissions(Long id) {
        List<String> demo = new ArrayList<String>();
        demo.add(String.format("Permission_%d", id - 1));
        demo.add(String.format("Permission_%d", id));
        demo.add(String.format("Permission_%d", id + 1));
        return demo;
    }
}

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

用Spring配置声明暴露服务:

<?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://localhost:2181"/>
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!--使用 dubbo 协议实现定义好的 api.PermissionService 接口-->
    <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" 
ref="demoService" protocol="dubbo" />
    <!--具体实现该接口的 bean-->
    <bean id="demoService" class="com.alibaba.dubbo.demo.impl.DemoServiceImpl"/>
</beans>

启动远程服务：

package com.alibaba.dubbo.demo.impl;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;
public class Provider {
  public static void main(String[] args) throws IOException {
     ClassPathXmlApplicationContext context = new 
ClassPathXmlApplicationContext("provider.xml");
     System.out.println(context.getDisplayName() + ": here");
     context.start();
     System.out.println("服务已经启动...");
     System.in.read();
  }
}

4. 创建dubbo-consumer的MAVEN项目(可以有多个consumer，但是需要配置好)，调用所需要的远程服务：

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

<?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://localhost:2181"/>
    <!--使用 dubbo 协议调用定义好的 api.PermissionService 接口-->
    <dubbo:reference id="permissionService" 
interface="com.alibaba.dubbo.demo.DemoService"/>
</beans>

启动Consumer,调用远程服务：

package com.alibaba.dubbo.consumer;
import com.alibaba.dubbo.demo.DemoService;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Consumer {
    public static void main(String[] args) {
        //测试常规服务
        ClassPathXmlApplicationContext context =
new ClassPathXmlApplicationContext("consumer.xml");
        context.start();
        System.out.println("consumer start");
        DemoService demoService = context.getBean(DemoService.class);
        System.out.println("consumer");
        System.out.println(demoService.getPermissions(1L));
    }
}

5. 运行项目，先确保provider已被运行后再启动consumer模块：
   运行提供者：
   
   消费者成功调用提供者所提供的远程服务：
   
   当然，这只是一个模拟的项目，实际中有多提供者多消费者情况，比这要复杂的多，当然只有这样才能体现dubbo的特性。

四、Dubbo 管理控制台介绍

• 管理控制台功能
• 路由规则，动态配置，服务降级
• 访问控制，权重调整
• 负载均衡
  
  下载dubbo-admin，可自行根据网上介绍安装。大致做法就是将dubbo-admin中的某个文件夹内容替换到tomcat的webapps中，再运行tomcat即可。但我在实际操作中发现JDK8无法运行，后来找到一个JDK8可以实现的dubbo-admin版本，下载地址：点我下载

成功开启输入用户名、密码root后，即可进入控制台首页查看消费者提供者情况：
查看服务提供者：

查看服务消费者：

很遗憾，官方Dubbo网址早已不维护了，也出现了很多更新的Dubbo，比如当当网的Dubbox，可以自行了解。

五、拓展阅读

Zookeeper 下载地址: 点我下载

Dubbo-admin 下载地址: 点我下载

Dubbo-monitor 下载地址: 点我下载