Dubbo安装、与Zookeeper、Spring集成 -

da_zhuang

浏览: 5985 次
性别:
来自: 北京

最近访客更多访客>>

zhangyan_0123

sanqiandai

w1985g

lanhaifeng1991

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

2015-08 ( 4)
更多存档...

Dubbo安装、与Zookeeper、Spring集成

博客分类：

Dubbo

第一：介绍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

1.tickTime：CS通信心跳数

Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。tickTime以毫秒为单位。

tickTime=2000

2.initLimit：LF初始通信时限
集群中的follower服务器(F)与leader服务器(L)之间初始连接时能容忍的最多心跳数（tickTime的数量）。

initLimit=5

3.syncLimit：LF同步通信时限
集群中的follower服务器与leader服务器之间请求和应答之间能容忍的最多心跳数（tickTime的数量）。

syncLimit=2

4.dataDir：数据文件目录
Zookeeper保存数据的目录，默认情况下，Zookeeper将写数据的日志文件也保存在这个目录里。

dataDir=/home/michael/opt/zookeeper/data

5.dataLogDir：日志文件目录
Zookeeper保存日志文件的目录。

dataLogDir=/home/michael/opt/zookeeper/log

6.clientPort：客户端连接端口
客户端连接 Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求。

clientPort=2333

7.服务器名称与地址：集群信息（服务器编号，服务器地址，LF通信端口，选举端口）
这个配置项的书写格式比较特殊，规则如下：

server.N=YYY:A:B

其中N表示服务器编号，YYY表示服务器的IP地址，A为LF通信端口，表示该服务器与集群中的leader交换的信息的端口。B为选举端口，表示选举新 leader时服务器间相互通信的端口（当leader挂掉时，其余服务器会相互通信，选择出新的leader）。一般来说，集群中每个服务器的A端口都是一样，每个服务器的B端口也是一样。但是当所采用的为伪集群时，IP地址都一样，只能时A端口和B端口不一样。
下面是一个非伪集群的例子：

server.0=233.34.9.144:2008:6008
server.1=233.34.9.145:2008:6008
server.2=233.34.9.146:2008:6008
server.3=233.34.9.147:2008:6008

下面是一个伪集群的例子：

server.0=127.0.0.1:2008:6008
server.1=127.0.0.1:2007:6007
server.2=127.0.0.1:2006:6006
server.3=127.0.0.1:2005:6005

常用命令：

1. 启动ZK服务: sh bin/zkServer.sh start
2. 查看ZK服务状态: sh bin/zkServer.sh status
3. 停止ZK服务: sh bin/zkServer.sh stop
4. 重启ZK服务: sh bin/zkServer.sh restart

启动Zookeeper：bin/zkServer.sh start

Zookeeper的安装和配置完成。

第二步：配置dubbo-admin的管理页面，方便我们管理页面

Dubbo安装：

官网下载dubbo文件。

个人收藏下载地址：http://download.csdn.net/detail/da_zhuang/8991663

可直接解压运行，前提当然是jdk环境变量...

webapps/ROOT/WEB-INF下，dubbo.properties文件中。

其中address为zookeeper的注册中心地址。

启动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包

<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 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:application name="dubbo_provider"></dubbo:application>
   
    <dubbo:protocol name="dubbo" port="20881" />
   
   <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包需要导入。

@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>

    
    <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>
   
   <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全部采用默认配置)