Dubbo安装、与Zookeeper、Spring集成

第一：介绍Dubbo背景

大规模服务化之前，应用可能只是通过RMI或Hessian等工具，简单的暴露和引用远程服务，通过配置服务的URL地址进行调用，通过F5等硬件进行负载均衡。

(1) 当服务越来越多时，服务URL配置管理变得非常困难，F5硬件负载均衡器的单点压力也越来越大。

此时需要一个服务注册中心，动态的注册和发现服务，使服务的位置透明。

并通过在消费方获取服务提供方地址列表，实现软负载均衡和Failover，降低对F5硬件负载均衡器的依赖，也能减少部分成本。

(2) 当进一步发展，服务间依赖关系变得错踪复杂，甚至分不清哪个应用要在哪个应用之前启动，架构师都不能完整的描述应用的架构关系。

这时，需要自动画出应用间的依赖关系图，以帮助架构师理清理关系。

(3) 接着，服务的调用量越来越大，服务的容量问题就暴露出来，这个服务需要多少机器支撑？什么时候该加机器？

为了解决这些问题，第一步，要将服务现在每天的调用量，响应时间，都统计出来，作为容量规划的参考指标。

其次，要可以动态调整权重，在线上，将某台机器的权重一直加大，并在加大的过程中记录响应时间的变化，直到响应时间到达阀值，记录此时的访问量，再以此访问量乘以机器数反推总容量。

第二：Dubbo的简介

Dubbo是一个分布式服务框架,解决了上面的所面对的问题，Dubbo的架构如图所示：

Dubbo安装、与Zookeeper、Spring集成

节点角色说明：

Provider: 暴露服务的服务提供方。

Consumer: 调用远程服务的服务消费方。

Registry: 服务注册与发现的注册中心。

Monitor: 统计服务的调用次调和调用时间的监控中心。

Container: 服务运行容器。

调用关系说明：

0. 服务容器负责启动，加载，运行服务提供者。

1. 服务提供者在启动时，向注册中心注册自己提供的服务。

2. 服务消费者在启动时，向注册中心订阅自己所需的服务。

3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

Dubbo提供了很多协议，Dubbo协议、RMI协议、Hessian协议，我们查看Dubbo源代码，有各种协议的实现，如图所示：

Dubbo安装、与Zookeeper、Spring集成

我们之前没用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

更多命令：http://blog.csdn.net/xiaolang85/article/details/13021339

启动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的注册中心地址。

Dubbo安装、与Zookeeper、Spring集成

启动tomcat

bin/startup.sh

访问：http://x.x.x.x:8080/显示登录页面用户名和密码均为root，说明部署成功。

ps:若访问不成功，但可以ping通，关闭防火墙吧。service iptables stop

Dubbo安装、与Zookeeper、Spring集成

SpringMVC与Dubbo的整合

本版本dubbo需要使用jdk1.7

环境使myeclipse maven 先说服务注册：在api接口项目中增加一个接口。因图已截好，dubboService首字母什么的请不要在意这些细节。

Dubbo安装、与Zookeeper、Spring集成

package com.kangzz.dubbo.service;

public interface dubboService {

public String hello(String name);

} 导出jar包：file->export->java->jar file->选择项目->finish 将api项目导出jar包，导入服务项目中。代码开始：

Dubbo安装、与Zookeeper、Spring集成

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包

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<artifactId>spring</artifactId>

<groupId>org.springframework</groupId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

</dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

</dependency>

红色字体部分为解决dubbo jar包与Spring3.1的版本冲突。多说不说，配置文件开始。applicationContext.xml

Dubbo安装、与Zookeeper、Spring集成

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 inter 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，启动项目就能看到如下界面了：

Dubbo安装、与Zookeeper、Spring集成

下面是消费者了。同样，第一步是jar包引入。自定义api jar包及dubbo需要的jar包需要导入。

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<artifactId>spring</artifactId>

<groupId>org.springframework</groupId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

</dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

</dependency>

Dubbo安装、与Zookeeper、Spring集成

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

<value>jdbc/mysql</value>

</property>

</bean>

</property>

<props>

<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>

</props>

</property>

<list>

<value>com.kangzz.*.entity</value>

<value>com.kangzz.*.*.entity</value>

</list>

</property>

<list>

<value>classpath:/com/kangzzentity**/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 inter id="dubboService"></dubbo:reference>

</beans> 配置消费者tomcat

Tomcat1端口分配表(tomcat1全部采用默认配置)

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

Tomcat2端口分配表

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

tomcat启动。

查看消费者信息

Dubbo安装、与Zookeeper、Spring集成

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

Dubbo安装、与Zookeeper、Spring集成

Dubbo安装、与Zookeeper、Spring集成

继续阅读

27 Best Free Eclipse Plug-ins for Java Developer to be ProductiveCode Quality PluginsText Editor PluginsDependency ManagementVersion Control Integration PluginsFramework Development Continuous Integration Related PluginsOther Utility Plugins

Java String.format方法的简单使用

neo4j之cypher使用文档

Ambari介绍和架构原理

GitHub连夜封杀！这份阿里 10W 字内部 Java 字面试手册到底有多强？

spark/scala关于【资源文件】加载方法概述外部文件加载方案测试资源文件打包入jar包中小结

NOSQL安全攻击

mybatis_入门程序Mybatis入门

AOP编程_Android优雅权限框架(1)概念基础，2021金三银四前言正文大纲正文

测试面试题整理

Effective Java 8:通用程序设计

OOM三种类型

工厂模式-三种类型

【递归】高效率求2的n次幂

win10本地scala和spark安装安装scala安装spark

scala (3) Function 和 Method