码迷,mamicode.com
首页 > 其他好文 > 详细

dubbo+zookeeper+dubboadmin环境搭建

时间:2015-07-17 18:16:20      阅读:1413      评论:0      收藏:0      [点我收藏+]

标签:

4、环境搭建

4.1、zookeeper注册中心的配置安装(在windows平台下,Linux类似,见官方文档)(Redis注册中心安装简易注册中心安装简易监控中心安装见官方文档

  • 下载zookeeper包(zookeeper-3.3.6.tar.gz),ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、名字服务、分布式同步、组服务等。
  • 将下载的包解压,然后在.\zookeeper-3.3.6\conf\路径下找到:zoo_sample.cfg文件,这个是配置的实例文件,复制此文件建立:zoo.cfg文件
    1.   
      # The number of milliseconds of each tick//ZK中的一个时间单元2000ms
      tickTime=2000
      # The number of ticks that the initial
      # synchronization phase can take//Leader允许Follower在initLimit时间内完成初始化工作。
      initLimit=10
      # The number of ticks that can pass between
      # sending a request and getting an acknowledgement
      syncLimit=5
      # the directory where the snapshot is stored.\\就是把内存中的数据存储成快照文件snapshot的目录
      dataDir=E:\\dubbo\\zookeeperB\\data
      # the port at which the clients will connect
      clientPort=2181
      

        

  • 然后就可以启动zk了点击\bin\路径下面的zkServer.cmd
        技术分享
        运行:
        技术分享

4.2、监控中心的安装配置

  • 首先下载tomacat,安装配置(略)
  • 下载dubbo-admin包(dubbo-admin-2.5.4-SNAPSHOT.war
  • 找到 tomcat安装路径下的 .\webapps\ROOT目录,然后清空里面的所有文件
  • dubbo-admin包(dubbo-admin-2.5.4-SNAPSHOT.war)解压到此文件中
  • 在解压的文件中找到\WEB-INF文件夹下的dubbo.properties文件,然后进行配置,默认属性配置如下:
    1. dubbo.registry.address=zookeeper://127.0.0.1:2181
    2. dubbo.admin.root.password=root
    3. dubbo.admin.guest.password=guest
  • 然后启动tomcat(zookeeper已启动,此步tomcat要访问zookeeper,如果zk没有启动,tomcat会一直等待其启动)。在浏览器中输入localhost:8080,进入监控中心的管理界面(默认管理员账户密码为:root,root)技术分享

4.3、服务提供者和消费者:

  • 服务提供者和服务消费者简单的示例:下面是eclipse平台下的服务提供者和服务消费者java项目截图
   技术分享技术分享
  • service的代码:(consumer和provider中的Service接口一样,其包名也要保持一致
    1.   
      1 package com.renhq.dubbotest.provider;
      2 publicinterfaceService{
      3 String sayHello(String name);
      4 }
  • ServiceIm的代码:
    1.   
       1 package com.renhq.dubbotest.providerIm;
       2 import java.io.IOException;
       3 import org.springframework.context.support.ClassPathXmlApplicationContext;
       4 import com.renhq.dubbotest.provider.Service;
       5 publicclassServiceImimplementsService{
       6 publicString sayHello(String name){
       7 return"Hello "+ name;
       8 }
       9 publicstaticvoid main(String[] args)throwsIOException{
      10 ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext("provider.xml");
      11 context.start();
      12 System.in.read();
      13 }
      14 }

       

  • provider.xml的配置:
    1.   
       1 <?xml version="1.0" encoding="UTF-8"?>
       2 <beansxmlns="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:applicationname="hello-world-provider"/>
      11 <!-- 使用multicast广播注册中心暴露服务地址
      12 <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
      13 <!-- 用dubbo协议在20880端口暴露服务 -->
      14 <dubbo:protocolname="dubbo"port="20888"/>
      15 <!-- 使用zookeeper注册中心暴露服务地址 -->
      16 <dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>
      17 <!-- 声明需要暴露的服务接口 -->
      18 <dubbo:serviceinterface="com.renhq.dubbotest.provider.Service"ref="demoService"/>
      19 <!-- 和本地bean一样实现服务 -->
      20 <beanid="demoService"class="com.renhq.dubbotest.providerIm.ServiceIm"/>
      21 </beans>

       

  • Consumer的代码:
    1.   
       1 package com.renhq.dubbotest.comsumer;
       2 import java.io.IOException;
       3 import java.util.Collections;
       4 import java.util.HashMap;
       5 import java.util.Map;
       6 import org.springframework.context.support.ClassPathXmlApplicationContext;
       7 import com.renhq.dubbotest.provider.Service;
       8 publicclassConsumer{
       9 publicstaticvoid main(String[] args)throwsIOException{
      10 ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext("consumer.xml");
      11 context.start();
      12 // System.out.println("----------------nihao ----------------------"); // 显示调用结果
      13 Service demoService =(Service) context.getBean("demoService");// 获取远程服务代理
      14 String hello = demoService.sayHello("world");// 执行远程方法
      15 System.out.println(hello);// 显示调用结果
      16 System.in.read();
      17 }
      18 }

       

  • consumer.xml的配置:
    1.   
       1 <?xml version="1.0" encoding="UTF-8"?>
       2 <beansxmlns="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:applicationname="consumer-of-helloworld-app"/>
      11 <!-- 使用multicast广播注册中心暴露发现服务地址 -->
      12 <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
      13 <!-- 使用zookeeper注册中心暴露服务地址 -->
      14 <dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>
      15 <!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
      16 <dubbo:referenceid="demoService"interface="com.renhq.dubbotest.provider.Service"/>
      17 </beans>

       

  • 没有注册中心情况下服务提供者和服务消费者的链接:
        provider.xml的配置:
  1. <!--在没有注册中心,直接暴露提供者的情况下,即:-->
  2. <dubbo:serviceinterface="com.renhq.dubbotest.provider.Service"ref="demoService"registry="N/A"/>
        consumer.xml的配置:
  1. <!--直连引用服务:在没有注册中心,直连提供者的情况下-->
  2. <dubbo:referenceid="demoService"interface="com.renhq.dubbotest.provider.Service"url="dubbo://192.168.1.103:20880/com.renhq.dubbotest.provider.Service"/>
  • 运行结果(先运行provider项目进行服务注册,再运行consumer项目访问服务):provider:

     技术分享

  • consumer

  技术分享





附件列表

 

dubbo+zookeeper+dubboadmin环境搭建

标签:

原文地址:http://www.cnblogs.com/renhq/p/4654925.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!