【Dubbo实战】 Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务（二）

妖狐艹你老母 2022-06-01 06:09 130阅读 0赞

# Dubbo与Zookeeper、Spring整合使用 #

Dubbo采用全Spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。

## 一：单机模式安装zookeeper ##

1,下载zookeeper注册中心，下载地址：[http://www.apache.org/dyn/closer.cgi/zookeeper/][http_www.apache.org_dyn_closer.cgi_zookeeper] 下载后解压即可，进入E:\\zookeeper-3.3.6\\zookeeper-3.3.6\\bin，

双击zkServer.cmd启动注册中心服务。

zkServer.sh【Linux】或zkServer.cmd【Windows】

2,在你执行启动脚本之前，还有几个基本的配置项需要配置一下，Zookeeper的配置文件在 conf 目录下，这个目录下有 zoo\_sample.cfg 和 log4j.properties，你需要做的就是将zoo\_sample.cfg 改名为 zoo.cfg，因为 Zookeeper在启动时会找这个文件作为默认配置文件。下面详细介绍一下，这个配置文件中各个配置项的意义。

![Center][]

•tickTime：这个时间是作为Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。

•dataDir：顾名思义就是 Zookeeper保存数据的目录，默认情况下，Zookeeper 将写数据的日志文件也保存在这个目录里。

•dataLogDir：顾名思义就是Zookeeper 保存日志文件的目录

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

配置好后，zookeeper会监听本机的2181端口。

当这些配置项配置好后，你现在就可以启动 Zookeeper 了，启动后要检查 Zookeeper 是否已经在服务，可以通过 netstat – ano 命令查看是否有你配置的 clientPort 端口号在监听服务。

## 二：服务提供者 ##

定义服务接口:(该接口需单独打包，在服务提供方和消费方共享)

**\[java\]**  [view plain][]   [copy][view plain]

[print][view plain] [?][view plain]

1.  **package** com.unj.dubbotest.provider;  
2.    
3.  **import** java.util.List;  
4.    
5.  **public** **interface** DemoService \{  
6.    
7.      String sayHello(String name);  
8.    
9.      **public** List getUsers();  
10.   
11. \}

在服务提供方实现接口：(对服务消费方隐藏实现)

**\[java\]**  [view plain][]   [copy][view plain]

[print][view plain] [?][view plain]

1.  **package** com.unj.dubbotest.provider.impl;  
2.    
3.  **import** java.util.ArrayList;  
4.  **import** java.util.List;  
5.    
6.  **import** com.unj.dubbotest.provider.DemoService;  
7.    
8.  **public** **class** DemoServiceImpl **implements** DemoService \{  
9.    
10.     **public** String sayHello(String name) \{  
11.         **return** "Hello " + name;  
12.     \}  
13.   
14.     **public** List getUsers() \{  
15.         List list = **new** ArrayList();  
16.         User u1 = **new** User();  
17.         u1.setName("hejingyuan");  
18.         u1.setAge(20);  
19.         u1.setSex("f");  
20.   
21.         User u2 = **new** User();  
22.         u2.setName("xvshu");  
23.         u2.setAge(21);  
24.         u2.setSex("m");  
25.   
26.           
27.         list.add(u1);  
28.         list.add(u2);  
29.           
30.         **return** list;  
31.     \}  
32. \}

用Spring配置声明暴露服务：

**\[html\]**  [view plain][]   [copy][view plain]

[print][view plain] [?][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****beans** xmlns="http://www.springframework.org/schema/beans"  
3.      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
4.      xsi:schemaLocation="http://www.springframework.org/schema/beans  
5.          http://www.springframework.org/schema/beans/spring-beans.xsd  
6.          http://code.alibabatech.com/schema/dubbo  
7.          http://code.alibabatech.com/schema/dubbo/dubbo.xsd  
8.          "**>**  
9.    
10.       
11.     **<****bean** id="demoService" class="com.unj.dubbotest.provider.impl.DemoServiceImpl" **/>**  
12.   
13.       
14.     **<****dubbo:application** name="xs\_provider" **/>**  
15.   
16.       
17.       
18.       
19.       
20.     **<****dubbo:registry** address="zookeeper://192.168.24.213:2181" **/>**  
21.   
22.       
23.     **<****dubbo:protocol** name="dubbo" port="20880" **/>**  
24.   
25.       
26.     **<****dubbo:service** interface="com.unj.dubbotest.provider.DemoService"  
27.         ref="demoService" **/>**  
28.   
29. **</****beans****>**

加载Spring配置，启动服务（或者将项目建为web项目，然后在web.xml中配置好spring的启动，然后扔到tomcat中即可提供服务）：

**\[java\]**  [view plain][]   [copy][view plain]

[print][view plain] [?][view plain]

1.  **package** com.unj.dubbotest.provider.impl;  
2.    
3.  **import** org.springframework.context.support.ClassPathXmlApplicationContext;  
4.    
5.  **public** **class** Provider \{  
6.    
7.      **public** **static** **void** main(String\[\] args) **throws** Exception \{  
8.          ClassPathXmlApplicationContext context = **new** ClassPathXmlApplicationContext(  
9.                  **new** String\[\] \{ "applicationContext.xml" \});  
10.         context.start();  
11.         System.in.read(); // 为保证服务一直开着，利用输入流的阻塞来模拟  
12.     \}  
13. \}

## 三：服务消费者 ##

通过Spring配置引用远程服务：

**\[html\]**  [view plain][]   [copy][view plain]

[print][view plain] [?][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****beans** xmlns="http://www.springframework.org/schema/beans"  
3.      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
4.      xsi:schemaLocation="http://www.springframework.org/schema/beans  
5.          http://www.springframework.org/schema/beans/spring-beans.xsd  
6.          http://code.alibabatech.com/schema/dubbo  
7.          http://code.alibabatech.com/schema/dubbo/dubbo.xsd  
8.          "**>**  
9.    
10.       
11.     **<****dubbo:application** name="hjy\_consumer" **/>**  
12.   
13.       
14.       
15.     **<****dubbo:registry** address="zookeeper://192.168.24.213:2181" **/>**  
16.   
17.       
18.     **<****dubbo:reference** id="demoService"  
19.         interface="com.unj.dubbotest.provider.DemoService" **/>**  
20.   
21. **</****beans****>**

调用服务测试：

**\[java\]**  [view plain][]   [copy][view plain]

[print][view plain] [?][view plain]

1.  **package** com.alibaba.dubbo.demo.pp;  
2.    
3.  **import** java.util.List;  
4.    
5.  **import** org.springframework.context.support.ClassPathXmlApplicationContext;  
6.    
7.  **import** com.unj.dubbotest.provider.DemoService;  
8.    
9.  **public** **class** Consumer \{  
10.   
11.     **public** **static** **void** main(String\[\] args) **throws** Exception \{  
12.         ClassPathXmlApplicationContext context = **new** ClassPathXmlApplicationContext(  
13.                 **new** String\[\] \{ "applicationContext.xml" \});  
14.         context.start();  
15.   
16.         DemoService demoService = (DemoService) context.getBean("demoService");  
17.         String hello = demoService.sayHello("hejingyuan");  
18.         System.out.println(hello);  
19.   
20.         List list = demoService.getUsers();  
21.         **if** (list != **null** && list.size() > 0) \{  
22.             **for** (**int** i = 0; i < list.size(); i++) \{  
23.                 System.out.println(list.get(i));  
24.             \}  
25.         \}  
26.         System.in.read();  
27.     \}  
28.   
29. \}

测试结果：

![Center 1][]

# 附：Dubbo的管理页面 #

需要下载：dubbo-admin-2.5.3的war包

下载地址：[http://download.csdn.net/detail/u013286716/7041185][http_download.csdn.net_detail_u013286716_7041185]

操作如下：

1，替换掉tomcat/webapps下自带的ROOT文件夹内容（即替换tomcat的启动主页），将下载的war包解压到webapps/ROOT中，直接替换即可

注意：jdk不要使用1.8，本次实验使用的为1.6

2，启动tomcat，访问ip:8080即可或者如果是本地的话使用localhost:8080

输入用户名密码，在E:\\apache-tomcat-7.0.6-dubbo\\webapps\\ROOT\\WEB-INF下的dubbo.properties文件中即可查看到，如：

![Center 2][]

3，访问 [http://192.168.24.213:38080/][http_192.168.24.213_38080]

![Center 3][]

4，启动我们的服务提供者和消费者即可查看到

![Center 4][]

![Center 5][]

# 整体说明： #

Zookeeper（注册中心）部署到213的机子上，服务提供者和服务消费者均在215的机子上运行，当然我们也可以分别将服务提供者和服务消费者部署到不同的两台机子上。

优点：

服务提供者和服务消费者只需要知道注册中心即可，它们之间打交道需通过注册中心这个第三方，只要是注册中心中已经注册的服务，我们均可以使用，实现了服务提供者和服务消费者间的解耦。

[http_www.apache.org_dyn_closer.cgi_zookeeper]: http://www.apache.org/dyn/closer.cgi/zookeeper/
[Center]: /images/20220601/233113d464a54049965610a14d92972b.png
[view plain]: http://blog.csdn.net/hejingyuan6/article/details/47403299#
[Center 1]: /images/20220601/ccc9744b1f3849b69d914e27f3200393.png
[http_download.csdn.net_detail_u013286716_7041185]: http://download.csdn.net/detail/u013286716/7041185
[Center 2]: /images/20220601/40178e31a4cd4f27a85e5edf7d014717.png
[http_192.168.24.213_38080]: http://192.168.24.213:38080/
[Center 3]: /images/20220601/80b16a6425a94e0a9c61e00b4701c72d.png
[Center 4]: /images/20220601/0d252aac6e4946ba83734297faa80ce9.png
[Center 5]: /images/20220601/06482282025c4684945f382df5adac67.png

发表评论取消回复

表情：

评论列表（有 0 条评论，130人围观）

还没有评论，来说两句吧...

相关阅读

相关 springboot整合Dubbo和Zookeeper实现分布式开发

springboot整合Dubbo和Zookeeper 1、Zookeeper的安装 1. Zookeeper概述

灰太狼/ 2022年12月26日 11:13/ 0 赞/ 86 阅读

相关 SpringBoot整合分布式Dubbo+Zookeeper

1.理论概述 1.1.分布式分布式系统是若干独立计算机的集合，这些计算机对于用户来讲就像单个系统。由多个系统集成成一个整体，提供多个功能，组合成一个板块，用户

左手的ㄟ右手/ 2022年09月04日 03:55/ 0 赞/ 124 阅读

相关 Dubbo学习总结（4）——Dubbo基于Zookeeper实现分布式实例

入门实例解析第一：provider-提供服务和相应的接口创建DemoService接口 \[java\] [view plain][]

一时失言乱红尘/ 2022年06月03日 01:27/ 0 赞/ 128 阅读

相关【Dubbo实战】 Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务（二）

Dubbo与Zookeeper、Spring整合使用 Dubbo采用全Spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加

妖狐艹你老母/ 2022年06月01日 06:09/ 0 赞/ 131 阅读

相关基于Dubbo框架构建分布式服务（二）

Dubbo服务集群容错假设我们使用的是单机模式的Dubbo服务，如果在服务提供方（Provider）发布服务以后，服务消费方（Consumer）发出一次调用请求，恰好这次由

青旅半醒/ 2022年05月19日 05:12/ 0 赞/ 218 阅读

相关基于Dubbo的分布式服务日志追踪实现

日志系统中的`MDC`可以在服务内部提供很好的日志追踪支持。 MDC.put(C.LOG.TRACE_ID, "唯一标识串"); 但是分布式（RPC）的情况下

叁歲伎倆/ 2022年02月14日 10:57/ 0 赞/ 215 阅读

相关 SpringBoot+Dubbo+Zookeeper整合搭建简单的分布式应用

为什么要使用分布式系统？容错减少延迟/提高性能可用性负载均衡总而言之，其实目的只有一个，”用户体验“。什么是分布式系统？分布式系统是由使用分

男娘i/ 2022年01月20日 11:13/ 0 赞/ 174 阅读

相关《SpringBoot+Dubbo+Zookeeper整合搭建简单的分布式应用》

为什么要使用分布式系统？容错减少延迟/提高性能可用性负载均衡总而言之，其实目的只有一个，”用户体验“。什么是分布式系统？分布式系统是由使用分发中间件

「爱情、让人受尽委屈。」/ 2022年01月11日 14:23/ 0 赞/ 156 阅读

相关（十六）springmvc+mybatis+dubbo+zookeeper分布式架构整合 - dubbo服务接口定义

在前面的章节中，我们着手介绍了dubbo的相关知识，在这个基础之上，我们可以考虑将dubbo服务应用于我们的分布式系统了，从今天开始，我们会详细介绍如何将dubbo和sprin

约定不等于承诺〃/ 2021年09月20日 12:20/ 0 赞/ 224 阅读

相关 Dubbo框架应用之（四）--Dubbo基于Zookeeper实现分布式实例

入门实例解析第一：provider-提供服务和相应的接口创建DemoService接口 package com.unj.dubbotest.provider; im...

系统管理员/ 2021年01月07日 11:28/ 0 赞/ 657 阅读