dubbo+zookeeper+dubboadmin环境搭建

hacklab

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文件
  

• 
  
  • 　　
    
    
    # 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文件，然后进行配置，默认属性配置如下：
  
  
  • dubbo.registry.address=zookeeper://127.0.0.1:2181
    
  • dubbo.admin.root.password=root
    
  • dubbo.admin.guest.password=guest
    
  
  
  
• 然后启动tomcat（zookeeper已启动，此步tomcat要访问zookeeper，如果zk没有启动，tomcat会一直等待其启动）。在浏览器中输入localhost：8080，进入监控中心的管理界面（默认管理员账户密码为：root，root）
  

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

• 服务提供者和服务消费者简单的示例：下面是eclipse平台下的服务提供者和服务消费者java项目截图
  

　　

• service的代码：（consumer和provider中的Service接口一样，其包名也要保持一致）
  

• 
  
  • 　　
    
    
    1 package com.renhq.dubbotest.provider;
    2 publicinterfaceService{
    3 String sayHello(String name);
    4 }
    
  
  

• ServiceIm的代码：
  

• 
  
  • 　　
    
    
    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 <?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 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 <?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的配置：

• <!--在没有注册中心，直接暴露提供者的情况下，即：-->
  
• <dubbo:serviceinterface="com.renhq.dubbotest.provider.Service"ref="demoService"registry="N/A"/>
  

        consumer.xml的配置：

• <!--直连引用服务：在没有注册中心，直连提供者的情况下-->
  
• <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
  

　　　　
　　



来自为知笔记(Wiz)　　




附件列表