码迷，mamicode.com
首页 > 编程语言 > 详细

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

时间：2016-02-14 18:26:12      阅读：302      评论：0      收藏：0      [点我收藏+]

标签：

 

    这里最熟悉的就是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 实战 （转）

标签：

原文地址：http://www.cnblogs.com/zhengah/p/5189412.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！