正文 

当前位置： 首页 > java > java框架

[dubbo实战]dubbo+zookeeper+spring实战（转）

     2022-03-27     726

关键词：

 

    这里最熟悉的就是spring了，项目中应用很多。dubbo是一个实现分布式的框架，zookeeper是注册中心。给我的感觉就像多对多关系的两者表，zookeeper相当于第三张表维护关系。下面通过一个小程序加深认识。

一、安装zookeeper

     去官网下载zookeeper， 然后解压到目录中，我解压到了E:zookeeper-3.3.6,在启动zookeeper之前，首先找到conf文件夹下的 zoo_sample.cfg，重新命名为zoo.cfg,网上说zookeeper启动的时候这个文件会是默认的配置文件。接下来到bin目录下，双击 启动zkServer.cmd，启动成功了如下：

  技术分享

  建的项目是maven项目，所以jar包的依赖都通过maven引用的，项目通过spring容器管理。

二、Server

  项目结构图：

  技术分享

1.接口

[java] view plain copy print?
  1. package com.mor.server.dubbo.service;  
  2.   
  3. /** 
  4.  * 服务端接口 
  5.  * @author zx 
  6.  * @date 2015年8月17日 下午3:19:12 
  7.  */  
  8. public interface DemoServer {  
  9.   
  10.     String sayHello(String str);  
  11.   
  12. }  


2.实现

[java] view plain copy print?
  1. package com.mor.server.dubbo.service;  
  2.   
  3. import java.util.Date;  
  4.   
  5. /** 
  6.  * 服务端接口实现类 
  7.  * @author zx 
  8.  * @date 2015年8月17日 下午3:18:52 
  9.  */  
  10. public class DemoServerImpl implements DemoServer {  
  11.   
  12.     public String sayHello(String str) {  
  13.         str = "Hello " + str + "  2:" + new Date();  
  14.         System.err.println("server:" + str);  
  15.         return str;  
  16.     }  
  17. }  


3.pom文件

[html] view plain copy print?
  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  2.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  
  3.   <modelVersion>4.0.0</modelVersion>  
  4.   
  5.   <groupId>com.mor.maven</groupId>  
  6.   <artifactId>dubboserver</artifactId>  
  7.   <version>0.0.1</version>  
  8.   <packaging>jar</packaging>  
  9.   
  10.   <name>dubboserver</name>  
  11.   <url>http://maven.apache.org</url>  
  12.   
  13.   <properties>  
  14.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
  15.     <spring.version>3.1.4.RELEASE</spring.version>  
  16.     <slf4j.version>1.6.6</slf4j.version>  
  17.   </properties>  
  18.   
  19.   <dependencies>  
  20.     <dependency>  
  21.       <groupId>junit</groupId>  
  22.       <artifactId>junit</artifactId>  
  23.       <version>3.8.1</version>  
  24.       <scope>test</scope>  
  25.     </dependency>  
  26.     <!-- Spring -->  
  27.     <dependency>  
  28.         <groupId>org.springframework</groupId>  
  29.         <artifactId>spring-aop</artifactId>  
  30.         <version>${spring.version}</version>  
  31.     </dependency>  
  32.     <dependency>  
  33.         <groupId>org.springframework</groupId>  
  34.         <artifactId>spring-asm</artifactId>  
  35.         <version>${spring.version}</version>  
  36.     </dependency>  
  37.     <dependency>  
  38.         <groupId>org.springframework</groupId>  
  39.         <artifactId>spring-core</artifactId>  
  40.         <version>${spring.version}</version>  
  41.     </dependency>  
  42.     <dependency>  
  43.         <groupId>org.springframework</groupId>  
  44.         <artifactId>spring-beans</artifactId>  
  45.         <version>${spring.version}</version>  
  46.     </dependency>  
  47.     <dependency>  
  48.         <groupId>org.springframework</groupId>  
  49.         <artifactId>spring-context</artifactId>  
  50.         <version>${spring.version}</version>  
  51.     </dependency>  
  52.     <dependency>  
  53.         <groupId>org.springframework</groupId>  
  54.         <artifactId>spring-expression</artifactId>  
  55.         <version>${spring.version}</version>  
  56.     </dependency>  
  57.     <!-- spring end -->  
  58.     <!-- log -->  
  59.         <dependency>  
  60.             <groupId>log4j</groupId>  
  61.             <artifactId>log4j</artifactId>  
  62.             <version>1.2.16</version>  
  63.         </dependency>  
  64.         <dependency>  
  65.             <groupId>org.slf4j</groupId>  
  66.             <artifactId>slf4j-api</artifactId>  
  67.             <version>${slf4j.version}</version>  
  68.         </dependency>  
  69.         <dependency>  
  70.             <groupId>org.slf4j</groupId>  
  71.             <artifactId>slf4j-log4j12</artifactId>  
  72.             <version>${slf4j.version}</version>  
  73.         </dependency>  
  74.     <!-- dubbo -->  
  75.     <dependency>  
  76.       <groupId>com.alibaba</groupId>  
  77.       <artifactId>dubbo</artifactId>  
  78.       <version>2.5.3</version>  
  79.     </dependency>  
  80.     <!-- zkclient  -->  
  81.     <dependency>  
  82.       <groupId>com.github.sgroschupf</groupId>  
  83.       <artifactId>zkclient</artifactId>  
  84.       <version>0.1</version>  
  85.     </dependency>  
  86.     <!--  zookeeper -->  
  87.     <dependency>  
  88.       <groupId>org.apache.zookeeper</groupId>  
  89.       <artifactId>zookeeper</artifactId>  
  90.       <version>3.3.6</version>  
  91.     </dependency>  
  92.   </dependencies>  
  93.    
  94.    <build>    
  95.         <finalName>dubbo-demo</finalName>  
  96.         <plugins>    
  97.             <!-- 非多个资源配置 start-->  
  98.             <plugin>    
  99.                 <groupId>org.apache.maven.plugins</groupId>    
  100.                 <artifactId>maven-compiler-plugin</artifactId>    
  101.                 <version>2.1</version>    
  102.                 <configuration>    
  103.                     <source>1.5</source>    
  104.                     <target>1.5</target>    
  105.                     <encoding>UTF-8</encoding>    
  106.                     <failOnError>false</failOnError>    
  107.                 </configuration>    
  108.             </plugin>  
  109.             <!-- 非多个资源配置 end-->  
  110.         </plugins>    
  111.     </build>  
  112. </project>  

  通过maven引用需要的jar包
4.spring配置文件

    先引入dubbo的标签

[html] view plain copy print?
  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"  
  4.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans  
  6.         http://www.springframework.org/schema/beans/spring-beans.xsd  
  7.         http://code.alibabatech.com/schema/dubbo  
  8.         http://code.alibabatech.com/schema/dubbo/dubbo.xsd  
  9.         ">       
  10.     <dubbo:application name="hello-world-app" />  
  11.     <dubbo:registry  protocol="zookeeper"  address="192.168.24.140:2181"  />  
  12.     <dubbo:protocol name="dubbo" port="20880" />       
  13.     <dubbo:service interface="com.mor.server.dubbo.service.DemoServer" ref="demoService" />       <!-- 和本地bean一样实现服务 -->  
  14.     <bean id="demoService" class="com.mor.server.dubbo.service.DemoServerImpl" />  
  15. </beans>  

5.执行入口

[java] view plain copy print?
  1. package com.mor.main;  
  2. import java.io.IOException;  
  3.   
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;  
  5.   
  6. /** 
  7.  * 服务器的执行入口 
  8.  * @author zx 
  9.  * @date 2015年8月17日 下午3:17:33 
  10.  */  
  11. public class Main {  
  12.       
  13.     public static void main(String[] args) throws IOException {  
  14.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "applicationProvider.xml" });  
  15.         context.start();  
  16.         System.out.println("按任意键退出");  
  17.         System.in.read();  
  18.     }  
  19.   
  20. }  

  

三、Client

  项目结构图：

  技术分享

1.接口同服务端

2.调用接口

[java] view plain copy print?
  1. package com.mor.server.dubbo.service;  
  2.   
  3. import java.util.Date;  
  4.   
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;  
  6.   
  7. public class ChatAction {  
  8.       
  9.     public void SayHello(){   
  10.     ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "applicationConsumer.xml" });  
  11.     context.start();  
  12.     DemoServer demoServer = (DemoServer) context.getBean("demoService");  
  13.     System.out.println("client:"+demoServer.sayHello("zx"+"1:"+new Date())+"3:"+new Date());  
  14.     }  
  15. }  

3.pom文件引用的jar都相同，只是修改一下基本的配置就可以了。

4.spring配置文件

 

[html] view plain copy print?
  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"  
  4.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  
  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans  
  6.         http://www.springframework.org/schema/beans/spring-beans.xsd  
  7.         http://code.alibabatech.com/schema/dubbo  
  8.         http://code.alibabatech.com/schema/dubbo/dubbo.xsd  
  9.         ">       
  10.     <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样  192.9.145.19:2181,192.9.145.19:2182,192.9.145.19:2183-->  
  11.     <dubbo:application name="consumer-of-helloworld-app" />       <!-- 使用multicast广播注册中心暴露发现服务地址 -->  
  12.     <dubbo:registry  protocol="zookeeper"  address="192.168.24.140:2181,,192.168.24.140:2182,192.168.24.140:2183" />         <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->  
  13.     <dubbo:reference id="demoService" interface="com.mor.server.dubbo.service.DemoServer" />  
  14. </beans>  



5.执行入口

[java] view plain copy print?
  1. package com.mor.client.dubbo.main;  
  2. import com.mor.server.dubbo.service.ChatAction;  
  3.   
  4. /** 
  5.  * 客户端的执行入口 
  6.  * @author zx 
  7.  * @date 2015年8月17日 下午3:18:00 
  8.  */  
  9. public class Main {  
  10.   
  11.     public static void main(String[] args) throws InterruptedException {  
  12.         int i=0;  
  13.         while(i++<100){  
  14.             ChatAction act = new ChatAction();  
  15.             act.SayHello();  
  16.             Thread.sleep(3000);  
  17.         }  
  18.     }  
  19.   
  20. }  


四、测试

  先启动zookeeper，再依次启动服务器和客户端。

  服务器启动成功如下：

 技术分享


客户端访问成功如下：

技术分享

五、总结

    运用dubbo能实现分布式，dubbo也是面向服务的架构。zookeeper做为注册中心，拿到服务器端暴露的接口，客户端也向zookeepe去注册，客户端需要什么服务注册中心就提供给客户端。这样客户端和服务端很好的解耦了。

dubbo实战dubbo+zookeeper+spring整合应用篇-dubbo基于zookeeper实现分布式服务

Dubbo与Zookeeper、Spring整合使用 Dubbo采用全spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。 一：单机模式安装zookeeper 1,下载zookeeper注册中... 查看详情

[dubbo实战]dubbo+zookeeper伪集群搭建

 zookeeper作为注册中心，服务器和客户端都要访问，如果有大量的并发，肯定会有等待。所以可以通过zookeeper集群解决。一、为什么需要zookeeper呢？   大部分分布式应用需要一个主控、协调器或者控制器来管理物理... 查看详情

dubbo实战dubbo+zookeeper+spring整合应用篇-dubbo基于zookeeper实现分布式服务（转）

 Dubbo与Zookeeper、Spring整合使用  Dubbo采用全Spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。 一：单机模式安装zookeeper  1,下载zo... 查看详情

springboot整合dubbo和zookeeper

SpringBoot整合Dubbo和Zookeeper SpringBoot整合Dubbo和Zookeeper环境介绍Zookeeper安装启动Dubboadmin搭建创建主maven项目创建子springboot项目 环境介绍zookeeper安装dubbo-admin查看管理注册中心服务提供者和消费者Zookeeper安装http://zookeeper.apache.... 查看详情

dubbo与zookeeper

...架要完成调度必须要有一个分布式的注册中心，官方推荐zookeeper,它存储着所有服务的元数据。dubbo服务开发流程，运行流程？zookeeper注册中心的作用？使用流程：第一步：要在系统中使用dubbo应该先搭建一个注册中心zookeeper。第... 查看详情

java学习---dubbo+zookeeper微服务架构(代码片段)

Dubbo+Zookeeper微服务架构1、ApacheDubbo概述 1.1、Dubbo简介 1.2、Dubbo的服务架构2、服务注册中心Zookeeper 2.1、ZooKeeper介绍 2.2、ZooKeeper安装 2.3、启动ZooKeeper3、ZooKeeper快速入门 3.1、服务提供方 3.2、服务消费方 3.3、问题思考4、Dub... 查看详情

dubbo与zookeeper集群配置

...srv#zk集群的时候dubbo只能这样配置dubbo.service.register.address=zookeeper://10.10.100.152:3181?backup=10.10.100.152:4181,10.10.100.152:5181#zk单点的话下面两种配置都可以#dubbo.service.register.address=zookeeper://$zookeeper.address#dubbo.service.register.address=zookeeper://10... 查看详情

基于zookeeper的dubbo注册中心

Zookeeper注册中心安装建议使用dubbo-2.3.3以上版本的zookeeper注册中心客户端。Zookeeper是ApacheHadoop的子项目，强度相对较好，建议生产环境使用该注册中心。Dubbo未对Zookeeper服务器端做任何侵入修改，只需安装原生的Zookeeper服务器即... 查看详情

基于zookeeper的dubbo注册中心

Zookeeper注册中心安装建议使用dubbo-2.3.3以上版本的zookeeper注册中心客户端。Zookeeper是ApacheHadoop的子项目，强度相对较好，建议生产环境使用该注册中心。Dubbo未对Zookeeper服务器端做任何侵入修改，只需安装原生的Zookeeper服务器即... 查看详情

dubbo+zookeeper

首先是整个项目结构图：dubbo-service:1packagecom.zto.service;23publicinterfaceSayHelloService{4publicStringhello(Stringname);5}SayHelloService.java1packagecom.zto.service.impl;23importcom.zto.service.SayHelloServ 查看详情

eosplatform+dubbo+zookeeper最佳实践

...流行的分布式服务框架，本文介绍如何使用EOSPlatform+Dubbo+Zookeeper实现分布式服务的开发与运行。1  环境准备1.1 环境选择EOSPlatform 6.7.1Zookeeper 3.4.5Dubbo 2.5.3Tomcat 5.5.271.2 搭建Zookeeper环境下载zookeep 查看详情

dubbo--基于zookeeper服务与spring集成

Dubbo Zookeeper Spring  1.部署dubbo服务管理中心2.搭建dubbo服务环境2.1pom.xml依赖2.2log4j.properties日志打印3.api模块定义公共接口4.dubbo-provider实现接口提供服务4.1DemoServiceImpl.java服务实现4.2dubbo-provider.xml服务配置4.3s 查看详情

dubbo-monitor为啥zookeeper会刷

...r=#dubbo.registry.address=multicast://224.5.6.7:1234dubbo.registry.address=zookeeper://113.52.182.149:54111?backup=113.52.182.150:54111#dubbo.registry.address=redis://127.0.0.1:6379#dubbo.registry.address=dubbo://127.0.0.1:9090dubbo.protocol.port=7070dubbo.jetty.port=54011dubbo.jetty.directory=$user... 查看详情

dubbo框架demo之dubbo-admin管理平台和zookeeper注册中心搭建(代码片段)

dubbo框架Demo之dubbo-admin管理平台和zookeeper注册中心搭建一、安装环境系统软件环境单机系统Centos7.3java:jdk1.8.0_181maven:apache-maven-3.5.4tomcat:apache-tomcat-8.5.30zookeeper：zookeeper-3.4.13Dubbo-admin：dubbo-admin-2.5.10.war环境简介 查看详情

springboot整合dubbo和zookeeper

...0.2.0，这使得其与SpringBoot项目整合变得更为简单方便。而Zookeeper在这里充当的是服务注册中心的角色，我们将各个微服务提供的服务通过Dubbo注册到Zookeeper中，然后服务消费者通过Dubb 查看详情

dubbo为啥用到了zookeeper

参考技术Azookeeper是Dubbo服务的注册中心，provider提供服务后注册在zookeeper上，consumer可以接口和版本信息从zookeeper中获取相应的服务，服务对于consumer来说完全透明，根本感知不到该接口是来自本地和provider，就像引用本地的一个b... 查看详情

dubbo的rpc远程过程调用+dubbo的负载均衡+zookeeper注册中心(代码片段)

文章目录Dubbo的RPC远程过程调用+Dubbo的负载均衡+Zookeeper注册中心分布式基础理论应用架构演变单一应用架构垂直应用架构分布式服务架构RPC远程过程调用dubbo核心概念环境搭建_zookeeper注册中心环境搭建_管理控制台编写提供... 查看详情

初步理解dubbo与zookeeper

...xff1a;https://wushaopei.github.io/  (你想要这里多有)一、dubbo与zookeeper的本质及其关系？Dubbo是管理中间层的工具，在业务层到数据仓库间有非常多服务的接入和服务提供者需要调度，dubbo提供一个框架解决这个问题。Zookeepe... 查看详情