dubbo+zookeeper 实战Demo

讲解一下当前流行的分布式开发所用到分布式服务框架dubbo和zookeeper。
至于这两个框架到底是做什么的。自行百度吧，懒得写了

先来一张，企业级大型网站的架构图

其中红色部分就是我们这次要讲解的，随着网站的规模不断扩大，业务逻辑不断复杂，负载逐渐增加，企业级的架构将各个业务模块拆分成多个应用，部署到不同的服务器，然后使用RPC或者其他的远程调用方式实现各个服务器的远程调用，以及用dubbo或者nigx实现负载均衡。

下面我们用dubbo+zookeeper实现，一个简单地分布式的java应用集群，在集群间实现远程调用。

看图

这次一共有三个项目

DubboPro:生产者（发布远程服务，供别人调用）
DubboCus:消费者（就是调用别人发布的远程服务）
DubboInterface:接口项目

#######PS:生产者和消费正可以同时存在于一个java应用，这里便于学习，我们将他们分开

DubboInterface 接口项目

里面定义的是我们要提供的服务所依赖的接口，因为dubbo所提供的远程调用时基于代理实现的，所以提供服务的应用必须要继承接口才能实现。还有一个是Person实体类，这是我们一会要用到的，这里要注意，远程调用要传输java的对象（实体），必须是可序列换的。下面，请看代码！

package com.zhongcheng.dubbo.interf;

import com.zhongcheng.dubbo.model.Person;

/**
 * Hello world!
 *
 */
public interface GetPerson {

    String speak(Person person);
}


package com.zhongcheng.dubbo.interf;

import com.zhongcheng.dubbo.model.Person;

public interface GrowAge {

    Person growPersonAge(Person person);

}


package com.zhongcheng.dubbo.model;

import java.io.Serializable;

public class Person implements Serializable {

    /**
     * 
     */
    private static final long serialVersionUID = -7408906574534643319L;

    private String age;

    private String name;

    public String getAge() {
        return age;
    }

    public void setAge(String age) {
        this.age = age;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

}
<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.zhongcheng</groupId>
  <artifactId>DubboInterface</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>DubboInterface</name>
  <url>http://maven.apache.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <dependencies>
  </dependencies>
</project>

到这，这个工程就结束了，使用 mvn install打包到本地，我们一会在其他两个项目中会用到

mvn install

DubboPro:生产者

生产者在dubbo负责生，提供远程调用的服务，
先看下项目结构，其中有一个接口的实现类，和一个spring的配置文件（dubbo是依赖spring的），

package com.zhongcheng.dubbo.pro;

import com.zhongcheng.dubbo.interf.GetPerson;
import com.zhongcheng.dubbo.model.Person;

public class GetPersonImpl implements GetPerson {

    public String speak(Person person) {
        String s="Hello Dubbo!,My name is "+person.getName();
        return s;
    }

}

<?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-hello-pro"  />  
    
    <dubbo:provider registry="zk1" protocol="mydubbo"  />
   
    <!-- 使用multicast广播注册中心暴露服务地址 -->  
   <!--  <dubbo:registry address="multicast://224.5.6.7:1234" /> -->  
   
    <!-- 使用zookeeper注册中心暴露服务地址 -->  
    <dubbo:registry id="zk1" address="zookeeper://127.0.0.1:2181" />  
   
    <!-- 用dubbo协议在20880端口暴露服务 -->  
    <dubbo:protocol id="mydubbo" name="dubbo" port="20880" />  
   
    <!-- 声明需要暴露的服务接口 -->  
    <dubbo:service interface="com.zhongcheng.dubbo.interf.GetPerson" ref="getPerson" />  
   
    <!-- 和本地bean一样实现服务 -->  
    <bean id="getPerson" class="com.zhongcheng.dubbo.pro.GetPersonImpl" />  
</beans> 


<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.zhongcheng</groupId>
  <artifactId>DubboPro</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>DubboPro</name>
  <url>http://maven.apache.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <dependencies>
  
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>
    
    
    <dependency>
      <groupId>com.zhongcheng</groupId>
      <artifactId>DubboInterface</artifactId>
      <version>0.0.1-SNAPSHOT</version>
    </dependency>
    
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.4.10</version>
    </dependency>
    
    <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
    <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.5</version>
    </dependency>
    
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-core</artifactId>
      <version>3.2.8.RELEASE</version>
    </dependency>
    
    
        <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-beans</artifactId>
      <version>3.2.8.RELEASE</version>
    </dependency>
    
  </dependencies>
</project>

这样完成了，主要的工作都在配置文件中，接口实现类只负责业务的逻辑，这时，我们就可以启动了，当然这时一个javaApplcation程序，需要主函数，我们需要配置一下，看图

执行应用，这时我们就可以去zookeeper看下，我们的在dubbo中注册的服务是否已经被存放到节点中

在zcClient中使用ls和get命令

ls /

图中可以看到，我们发布的接口已经到zookeeper的/dubbo节点中了，下面我们就可以使用消费者调用了

DubboCus:消费者

消费者我服调用远程服务，先看下项目的结构

这里只有一个测试类和spring的配置文件，直接看代码

package com.zhongcheng.dubbo.pro;

import com.zhongcheng.dubbo.interf.GetPerson;
import com.zhongcheng.dubbo.model.Person;

public class GetPersonImpl implements GetPerson {

    public String speak(Person person) {
        String s="Hello Dubbo!,My name is "+person.getName();
        return s;
    }

}


<?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-hello-pro"  />  
    
    <dubbo:provider registry="zk1" protocol="mydubbo"  />
   
    <!-- 使用multicast广播注册中心暴露服务地址 -->  
   <!--  <dubbo:registry address="multicast://224.5.6.7:1234" /> -->  
   
    <!-- 使用zookeeper注册中心暴露服务地址 -->  
    <dubbo:registry id="zk1" address="zookeeper://127.0.0.1:2181" />  
   
    <!-- 用dubbo协议在20880端口暴露服务 -->  
    <dubbo:protocol id="mydubbo" name="dubbo" port="20880" />  
   
    <!-- 声明需要暴露的服务接口 -->  
    <dubbo:service interface="com.zhongcheng.dubbo.interf.GetPerson" ref="getPerson" />  
   
    <!-- 和本地bean一样实现服务 -->  
    <bean id="getPerson" class="com.zhongcheng.dubbo.pro.GetPersonImpl" />  
</beans> 


<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.zhongcheng</groupId>
  <artifactId>DubboPro</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>DubboPro</name>
  <url>http://maven.apache.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <dependencies>
  
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>
    
    
    <dependency>
      <groupId>com.zhongcheng</groupId>
      <artifactId>DubboInterface</artifactId>
      <version>0.0.1-SNAPSHOT</version>
    </dependency>
    
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.4.10</version>
    </dependency>
    
    <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
    <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.5</version>
    </dependency>
    
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-core</artifactId>
      <version>3.2.8.RELEASE</version>
    </dependency>
    
    
        <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-beans</artifactId>
      <version>3.2.8.RELEASE</version>
    </dependency>
    
  </dependencies>
</project>

成功了！！！！
写的太粗略了，就当学习笔记吧，

dubbo+zookeeper 实战Demo

看图

DubboInterface 接口项目

DubboPro:生产者

DubboCus:消费者

推荐阅读更多精彩内容