基于Dubbo+ZooKeeper的分布式服务的实现

摘要：调用流程服务容器负责启动，加载，运行服务提供者。服务提供者在启动时，向注册中心注册自己提供的服务。注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。这就是分布式服务注册中心的由来。

一款分布式服务框架

高性能和透明化的RPC远程服务调用方案。这里简单介绍一下RPC，所谓RPC就是远程过程调用，全称为Romate Procedure Protocol Call，顾名思义其实就是一种协议。

RPC是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型中，RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。
RPC采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。

SOA服务治理方案
SOA是一种面向服务的框架或者说是架构

Provider: 暴露服务的服务提供方。
Consumer: 调用远程服务的服务消费方。
Registry: 服务注册与发现的注册中心。
Monitor: 统计服务的调用次数和调用时间的监控中心。

调用流程
0.服务容器负责启动，加载，运行服务提供者。
1.服务提供者在启动时，向注册中心注册自己提供的服务。
2.服务消费者在启动时，向注册中心订阅自己所需的服务。
3.注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
4.服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
5.服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心

通过将服务统一管理起来，可以有效地优化内部应用对服务发布/使用的流程和管理。服务注册中心可以通过特定协议来完成服务对外的统一。这就是分布式服务注册中心的由来。

Multicast注册中心

Zookeeper注册中心

Redis注册中心

Simple注册中心

接下来我们就是基于Dubbo+Zookeeper+Spring的方式来做一个关于分布式部署的练习，相信通过这个例子大家就可以大致理解Dubbo+Zookeeper的执行流程。

具体安装过程可以进入以下网址，一步一步跟着提示操作就可以完成Zookeeper的安装：
http://blog.csdn.net/tlk20071...
安装完成后，进入到bin目录，并且启动zkServer.cmd，这个脚本中会启动一个java进程：成功以后会启动一个DOS界面，如下图所示：

创建父工程
创建一个名为DubboDemo的maven工程

创建服务接口以及服务提供者和服务消费者模块
在父工程下分别创建三个名为dubbo-api,dubbo-provider,dubbo-consumer的maven module

编写代码实现功能
【1】在模块dubbo-api中创建一个名为com.alibaba.dubbo.demo的包，在包下创建一个名为DemoService的接口，该接口下的代码如下：

package com.alibaba.dubbo.demo;
import java.util.List;

public interface DemoService {

   List getPermissions(Long id);

}

【2】在模块dubbo-provider中创建一个名为com.alibaba.dubbo.demo.impl的包，在该包下新建一个名为DemoServiceImpl并实现DemoService接口，该类代码如下：
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 getPermissions(Long id) {
       List demo = new ArrayList();
       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;
   }

}

【3】添加spring配置文件名为provider.xml(位于src目录下)，配置文件具体内容如下：

【4】编写服务提供方启动类，具体代码如下：

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();
       }
   }
      

【5】完成服务消费者所需功能

在demo-consumer模块中创建名为com.alibaba.dubbo.consumer的包并在该包下创建一个名为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));
    }
} 

【6】配置服务消费者的配置文件

  在demo-consumer模块中创建一个名为consumer.xml的文件，该文件的具体内容如下：
    

    
    
    
    
    

【1】首先启动Zookeeper安装目录中bin文件夹下的名为zkServer的Windows脚本文件
【2】启动服务端，即启动服务端启动类的main方法
【3】启动客户端，即启动服务消费者端的main方法

注意事项：

注意各个模块之间的依赖
dubbo-provider和dubbo-consumer模块都需要依赖dubbo-api模块，还有就是这三个maven module最好都加入对于spring依赖。具体依赖可参考我发布的源码及资料。

项目资料下载链接（注：附Zookeeper的安装文件）：
链接：https://pan.baidu.com/s/120eC... 密码：wllg