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.   

       package com.renhq.dubbotest.provider;
      publicinterfaceService{
      String sayHello(String name);
      }
  • ServiceIm的代码:
    1.   

       package com.renhq.dubbotest.providerIm;
      import java.io.IOException;
      import org.springframework.context.support.ClassPathXmlApplicationContext;
      import com.renhq.dubbotest.provider.Service;
      publicclassServiceImimplementsService{
      publicString sayHello(String name){
      return"Hello "+ name;
      }
      publicstaticvoid main(String[] args)throwsIOException{
      ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext("provider.xml");
      context.start();
      System.in.read();
      }
      }
  • provider.xml的配置:
    1.   

       <?xml version="1.0" encoding="UTF-8"?>
      <beansxmlns="http://www.springframework.org/schema/beans"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
      xsi:schemaLocation="http://www.springframework.org/schema/beans
      http://www.springframework.org/schema/beans/spring-beans.xsd
      http://code.alibabatech.com/schema/dubbo
      http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
      <!-- 提供方应用信息,用于计算依赖关系 -->
      <dubbo:applicationname="hello-world-provider"/>
      <!-- 使用multicast广播注册中心暴露服务地址
      <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
      <!-- 用dubbo协议在20880端口暴露服务 -->
      <dubbo:protocolname="dubbo"port="20888"/>
      <!-- 使用zookeeper注册中心暴露服务地址 -->
      <dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>
      <!-- 声明需要暴露的服务接口 -->
      <dubbo:serviceinterface="com.renhq.dubbotest.provider.Service"ref="demoService"/>
      <!-- 和本地bean一样实现服务 -->
      <beanid="demoService"class="com.renhq.dubbotest.providerIm.ServiceIm"/>
      </beans>
  • Consumer的代码:
    1.   

       package com.renhq.dubbotest.comsumer;
      import java.io.IOException;
      import java.util.Collections;
      import java.util.HashMap;
      import java.util.Map;
      import org.springframework.context.support.ClassPathXmlApplicationContext;
      import com.renhq.dubbotest.provider.Service;
      publicclassConsumer{
      publicstaticvoid main(String[] args)throwsIOException{
      ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext("consumer.xml");
      context.start();
      // System.out.println("----------------nihao ----------------------"); // 显示调用结果
      Service demoService =(Service) context.getBean("demoService");// 获取远程服务代理
      String hello = demoService.sayHello("world");// 执行远程方法
      System.out.println(hello);// 显示调用结果
      System.in.read();
      }
      }
  • consumer.xml的配置:
    1.   

       <?xml version="1.0" encoding="UTF-8"?>
      <beansxmlns="http://www.springframework.org/schema/beans"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
      xsi:schemaLocation="http://www.springframework.org/schema/beans
      http://www.springframework.org/schema/beans/spring-beans.xsd
      http://code.alibabatech.com/schema/dubbo
      http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
      <!-- 消费方应用名,用于计算依赖关系,不是匹配条件,不要与提供方一样 -->
      <dubbo:applicationname="consumer-of-helloworld-app"/>
      <!-- 使用multicast广播注册中心暴露发现服务地址 -->
      <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
      <!-- 使用zookeeper注册中心暴露服务地址 -->
      <dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>
      <!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
      <dubbo:referenceid="demoService"interface="com.renhq.dubbotest.provider.Service"/>
      </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

  

附件列表

最新文章

  1. 为什么C#中ref和out 关键字 ?
  2. Windows10 如何删掉内置的 skype ?
  3. 机器人操作系统(ROS)教程4:ROS的框架【转】
  4. Canu Quick Start(快速使用Canu)
  5. php 滑动验证码
  6. 如何动态添加和删除一个div
  7. vs2012 aspx 没有设计视图了?
  8. SCIP读书笔记(1)
  9. cocos2d-x创建工程批处理
  10. leetcode第40题--First Missing Positive
  11. Socket编程实践(13) --UNIX域协议
  12. VUE v-for问题
  13. Java 开源博客 Solo 1.9.0 发布 - 新皮肤
  14. tensorflow, TypeError:&#39;Tensor&#39; object is not callable
  15. Mysql innodb_fast_shutdown
  16. 宝塔使用FTP的问题
  17. 还有看不懂的java语句?
  18. what&#39;s the python之异常处理
  19. spfa 单源最短路究极算法
  20. 上机题目(0基础)- Java网络操作-打印网页(Java)

热门文章

  1. 解决没有referenced Libraries的方法
  2. 使用Intellij Idea打开项目不能显示树形目录
  3. 使用ES6的Promise 解决回调函数。
  4. 33 python 并发编程之IO模型
  5. 统计日志中ip出现的次数
  6. php 中改变字符编码的函数 是 iconv()
  7. LeetCode Second Minimum Node In a Binary Tree
  8. [转]HTTP详解(1)-工作原理
  9. [转]Angular移除不必要的$watch之性能优化
  10. Ubuntu下部署GitLab-——基于14.04系统