Dubbo安装、与Zookeeper、Spring集成

浙江雁荡山

　　第一：介绍Dubbo背景
　　 
　　    
　　 
　　 
　　大规模服务化之前，应用可能只是通过RMI或Hessian等工具，简单的暴露和引用远程服务，通过配置服务的URL地址进行调用，通过F5等硬件进行负载均衡。
　　(1) 当服务越来越多时，服务URL配置管理变得非常困难，F5硬件负载均衡器的单点压力也越来越大。
　　此时需要一个服务注册中心，动态的注册和发现服务，使服务的位置透明。
　　并通过在消费方获取服务提供方地址列表，实现软负载均衡和Failover，降低对F5硬件负载均衡器的依赖，也能减少部分成本。
　　(2) 当进一步发展，服务间依赖关系变得错踪复杂，甚至分不清哪个应用要在哪个应用之前启动，架构师都不能完整的描述应用的架构关系。
　　这时，需要自动画出应用间的依赖关系图，以帮助架构师理清理关系。
　　(3) 接着，服务的调用量越来越大，服务的容量问题就暴露出来，这个服务需要多少机器支撑？什么时候该加机器？
　　为了解决这些问题，第一步，要将服务现在每天的调用量，响应时间，都统计出来，作为容量规划的参考指标。
　　其次，要可以动态调整权重，在线上，将某台机器的权重一直加大，并在加大的过程中记录响应时间的变化，直到响应时间到达阀值，记录此时的访问量，再以此访问量乘以机器数反推总容量。
　　 
　　第二：Dubbo的简介
　　Dubbo是一个分布式服务框架,解决了上面的所面对的问题，Dubbo的架构如图所示：

　　节点角色说明：
　　Provider: 暴露服务的服务提供方。
　　Consumer: 调用远程服务的服务消费方。
　　Registry: 服务注册与发现的注册中心。
　　Monitor: 统计服务的调用次调和调用时间的监控中心。
　　Container: 服务运行容器。
　　调用关系说明：
　　0. 服务容器负责启动，加载，运行服务提供者。
　　1. 服务提供者在启动时，向注册中心注册自己提供的服务。
　　2. 服务消费者在启动时，向注册中心订阅自己所需的服务。
　　3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
　　4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
　　5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。
　　Dubbo提供了很多协议，Dubbo协议、RMI协议、Hessian协议，我们查看Dubbo源代码，有各种协议的实现，如图所示：

　　我们之前没用Dubbo之前时，大部分都使用Hessian来使用我们服务的暴露和调用，利用HessianProxyFactory调用远程接口。
　　
上面是参考了Dubbo官方网介绍，接下来我们来介绍SpringMVC、Dubbo、Zookeeper整合使用。
　　第一步：在Linux上安装Zookeeper
　　1、首先，安装Zookeeper。
　　下载：zookeeper-3.4.6.tar.gz
　　官网地址：http://www.apache.org/dist/zookeeper/
　　个人收藏地址：http://download.csdn.net/detail/da_zhuang/8991771
　　2、创建zookeeper文件目录
　　mkdir zookeeper
　　拷贝zookeeper-3.4.6.tar.gz到指定文件夹
　　3、解压zookeeper-3.4.6.tar.gz
　　tar zxvf zookeeper-3.4.6.tar.gz
　　4、重点：
　　zookeeper-3.4.6/conf 下有一个文件zoo_sample.cfg的这个文件里面配置了监听客户端连接的端口等一些信息，Zookeeper 在启动时会找zoo.cfg这个文件作为默认配置文件,so我们复制一个名称为zoo.cfg的文件#cd zookeeper-3.4.6\conf
　　#cp zoo_sample.cfg zoo.cfg

 

　　启动tomcat
　　bin/startup.sh
　　访问：http://x.x.x.x:8080/显示登录页面 用户名和密码均为root，说明部署成功。
　　ps:若访问不成功，但可以ping通，关闭防火墙吧。service iptables stop
　　

 
　　SpringMVC与Dubbo的整合
　　本版本dubbo需要使用jdk1.7
 
环境使myeclipse maven
先说服务注册：
在api接口项目中增加一个接口。
因图已截好，dubboService首字母什么的请不要在意这些细节。



 
 
package com.kangzz.dubbo.service;

public interface dubboService {
    public String hello(String name);
}
导出jar包：file->export->java->jar file->选择项目->finish

将api项目导出jar包，导入服务项目中。
代码开始：


 
package com.kangzz.dubbo.service.impl;

import org.springframework.stereotype.Service;

import com.kangzz.dubbo.service.dubboService;
@Service
public class DubboServiceImpl implements dubboService{
    public String hello(String name) {   
        return "hello-"+name;
    }
}
pom引入jar包
       <!-- dubbo start -->
          <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.5.3</version>
            <exclusions> 
                <exclusion> 
                    <artifactId>spring</artifactId> 
                    <groupId>org.springframework</groupId> 
                </exclusion> 
            </exclusions>
        </dependency>
         <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.6</version>
         </dependency>
          <dependency>
              <groupId>com.github.sgroschupf</groupId>
             <artifactId>zkclient</artifactId>
             <version>0.1</version>
          </dependency>
        <!-- dubbo end -->
红色字体部分为解决dubbo jar包与Spring3.1的版本冲突。
多说不说，配置文件开始。applicationContext.xml



 
 
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
<!-- 提供方应用名称信息，这个相当于起一个名字，我们dubbo管理页面比较清晰是哪个应用暴露出来的 -->
   <dubbo:application name="dubbo_provider"></dubbo:application>
   <!-- 用dubbo协议在20881端口暴露服务 --> 
    <dubbo:protocol name="dubbo" port="20881" />
   <!-- 使用zookeeper注册中心暴露服务地址 --> 
   <dubbo:registry address="zookeeper://192.168.8.129:2181" check="false" subscribe="false" register=""/>
  <!-- 要暴露的服务接口 --> 
  <dubbo:service interface="com.kangzz.dubbo.service.dubboService" ref="dubboService" />

　　说明：
　　dubbo:registry 标签一些属性的说明：
　　1）register是否向此注册中心注册服务，如果设为false，将只订阅，不注册。
　　2）check注册中心不存在时，是否报错。
　　3）subscribe是否向此注册中心订阅服务，如果设为false，将只注册，不订阅。
　　4）timeout注册中心请求超时时间(毫秒)。
　　5）address可以Zookeeper集群配置，地址可以多个以逗号隔开等。
　　dubbo:service标签的一些属性说明：
　　1）interface服务接口的路径
　　2）ref引用对应的实现类的Bean的ID
　　3）registry向指定注册中心注册，在多个注册中心时使用，值为<dubbo:registry>的id属性，多个注册中心ID用逗号分隔，如果不想将该服务注册到任何registry，可将值设为N/A
　　4）register 默认true ，该协议的服务是否注册到注册中心。
服务端就配置好了，添加到tomcat，启动项目就能看到如下界面了：



 
 
下面是消费者了。
同样，第一步是jar包引入。
自定义api jar包及dubbo需要的jar包需要导入。
<!-- dubbo start -->
          <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.5.3</version>
            <exclusions> 
                <exclusion> 
                    <artifactId>spring</artifactId> 
                    <groupId>org.springframework</groupId> 
                </exclusion> 
            </exclusions>
        </dependency>
         <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.6</version>
         </dependency>
          <dependency>
              <groupId>com.github.sgroschupf</groupId>
             <artifactId>zkclient</artifactId>
             <version>0.1</version>
          </dependency>
        <!-- dubbo end -->




 
 
 
 @Controller
@RequestMapping("/dubbo")
public class DubboAction {
    @Autowired
    private dubboService dubboService;
    @RequestMapping(value = "/hello.action")
    public String index(Model model){
         String name=dubboService.hello("zz");
         System.out.println("xx=="+name);
         return "";
    }
}
applicationContext.xml文件配置：
<?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:aop="http://www.springframework.org/schema/aop"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    xmlns:tx="http://www.springframework.org/schema/tx"
    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://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd 
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd 
            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
            http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
            http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd">
    <description>Spring公共配置文件</description>
   
    <!-- dataSource -->
    <bean id="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiName">
            <value>jdbc/mysql</value>
        </property>
        <property name="resourceRef" value="true"></property>
    </bean>
    <bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
        <property name="dataSource">
            <ref bean="dataSource" />
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
                <prop key="hibernate.show_sql">true</prop>
            </props>
        </property>
        <property name="packagesToScan">
            <list>
                <value>com.kangzz.*.entity</value>
                <value>com.kangzz.*.*.entity</value>
            </list>
        </property>
        <property name="mappingLocations">
            <list>
                <value>classpath:/com/kangzz/**/entity/*.hbm.xml</value>
                <value>classpath:/com/kangzz/**/**/entity/*.hbm.xml</value>
            </list>
        </property>
    </bean>
    <context:component-scan base-package="com.kangzz"></context:component-scan>
    <dubbo:application name="dubbo_consumer"></dubbo:application>
   <!-- 使用zookeeper注册中心暴露服务地址 --> 
   <dubbo:registry address="zookeeper://192.168.8.129:2181" check="false"></dubbo:registry>
     <!-- 要引用的服务 --> 
   <dubbo:reference interface="com.kangzz.dubbo.service.dubboService" id="dubboService"></dubbo:reference>
</beans>
配置消费者tomcat
Tomcat1端口分配表(tomcat1全部采用默认配置)

端口	端口号
关闭指令端口	8005
http端口	8080
https端口	8443
Ajp端口	8009

Tomcat2端口分配表

端口	端口号
关闭指令端口	8006
http端口	8081
https端口	8444
Ajp端口	8010

　　tomcat启动。
　　查看消费者信息
　　

 
　　浏览器访问http://localhost:8081/PersonalProjectCus/dubbo/hello.action