四个步骤 

1 搭建zookeeper消息中心 

2 搭建dubbo服务端代码 

3 写dubbo客户端代码 

4 dubbo提供的dubbo-admin-2.5.4.war 管理控制台 

一，搭建zookeeper


1 下载zookeeper安装文件 
    zookeeper-3.3.6.tar.gz 
   这里提供一个百度网盘的下载地址http://pan.baidu.com/s/1gexxfvP 

2  执行命令 tar zxvf zookeeper-3.4.6.tar.gz 解压, 

3 到 zookeeper-3.3.6/conf 目录下 

   把zoo_sample.cfg 复制一份为zoo.cfg,作为默认配置文件




4 配置说明 

tickTime：这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。 
dataDir：顾名思义就是 Zookeeper 保存数据的目录，默认情况下，Zookeeper 将写数据的日志文件也保存在这个目录里。 
clientPort：这个端口就是客户端连接 Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求。 

我的配置: 端口2181是默认配置

 

 

5 在zookper-3.3.6/bin目录下执行 

    ./zkServer.sh start 启动zookeeper

 


6 验证zookeeper是否启动 

     使用netstat -lpn | grep 2181 
     如果有端口号, 说明已经启动

 

 

二 DubboServer 工程

1，pom.xml

Xml代码   收藏代码
  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/maven-v4_0_0.xsd">  
  3.   <modelVersion>4.0.0</modelVersion>  
  4.   <groupId>com.zhang.dubboServer</groupId>  
  5.   <artifactId>dubboServer</artifactId>  
  6.   <packaging>war</packaging>  
  7.   <version>0.0.1-SNAPSHOT</version>  
  8.   <name>dubboServer Maven Webapp</name>  
  9.   <url>http://maven.apache.org</url>  
  10.   <dependencies>  
  11.     <dependency>  
  12.       <groupId>junit</groupId>  
  13.       <artifactId>junit</artifactId>  
  14.       <version>3.8.1</version>  
  15.       <scope>test</scope>  
  16.     </dependency>  
  17.     <dependency>    
  18.         <groupId>javax.servlet</groupId>    
  19.         <artifactId>servlet-api</artifactId>    
  20.         <version>2.4</version>    
  21.       </dependency>    
  22.       <dependency>    
  23.         <groupId>javax.servlet.jsp</groupId>    
  24.         <artifactId>jsp-api</artifactId>    
  25.         <version>2.1</version>    
  26.       </dependency>  
  27.       <dependency>  
  28.         <groupId>org.springframework</groupId>  
  29.         <artifactId>spring-context</artifactId>  
  30.          <version>4.1.6.RELEASE</version>  
  31.      </dependency>  
  32.       <dependency>    
  33.         <groupId>org.springframework</groupId>    
  34.         <artifactId>spring-context</artifactId>    
  35.         <version>4.1.6.RELEASE</version>    
  36.       </dependency>    
  37.       <dependency>    
  38.         <groupId>org.springframework</groupId>    
  39.         <artifactId>spring-webmvc</artifactId>    
  40.         <version>4.1.6.RELEASE</version>    
  41.       </dependency>  
  42.       <dependency>    
  43.         <groupId>jstl</groupId>    
  44.         <artifactId>jstl</artifactId>    
  45.         <version>1.2</version>    
  46.     </dependency>   
  47.     <dependency>  
  48.         <groupId>dubbo</groupId>  
  49.         <artifactId>dubbo</artifactId>  
  50.         <version>2.5.3</version>  
  51.     </dependency>  
  52.     <dependency>  
  53.       <groupId>javassist</groupId>  
  54.       <artifactId>javassist</artifactId>  
  55.       <version>3.15.0-GA</version>  
  56.       <classifier>GA</classifier>  
  57.     </dependency>  
  58.     <dependency>  
  59.         <groupId>netty</groupId>  
  60.         <artifactId>netty</artifactId>  
  61.         <version>3.2.5.Final</version>  
  62.     </dependency>  
  63.     <dependency>  
  64.         <groupId>log4j</groupId>  
  65.         <artifactId>log4j</artifactId>  
  66.         <version>1.2.17</version>  
  67.     </dependency>  
  68.     <dependency>  
  69.         <groupId>zkclient</groupId>  
  70.         <artifactId>zkclient</artifactId>  
  71.         <version>0.4</version>  
  72.     </dependency>  
  73.     <dependency>  
  74.         <groupId>zookeeper</groupId>  
  75.         <artifactId>zookeeper</artifactId>  
  76.         <version>3.3.1</version>  
  77.     </dependency>  
  78.   </dependencies>  
  79.   <build>  
  80.     <finalName>dubboServer</finalName>  
  81.   </build>  
  82. </project>  

 

2.web.xml
Xml代码   收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2.   
  3. <web-app  
  4.         xmlns="http://java.sun.com/xml/ns/javaee"  
  5.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  6.         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"  
  7.         version="3.0"  
  8.         metadata-complete="false">  
  9.     <context-param>  
  10.         <param-name>contextConfigLocation</param-name>  
  11.         <param-value>/WEB-INF/spring/springmvc-config.xml;classpath*:dubbo/*.xml</param-value>  
  12.     </context-param>  
  13.     <listener>  
  14.         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>  
  15.     </listener>  
  16.     <servlet>  
  17.         <servlet-name>DispatcherServlet</servlet-name>  
  18.         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>  
  19.         <init-param>  
  20.             <param-name>contextConfigLocation</param-name>  
  21.             <param-value>/WEB-INF/spring/springmvc-config.xml</param-value>  
  22.         </init-param>  
  23.         <load-on-startup>1</load-on-startup>  
  24.         <async-supported>true</async-supported>  
  25.     </servlet>  
  26.   
  27.     <servlet-mapping>  
  28.         <servlet-name>DispatcherServlet</servlet-name>  
  29.         <url-pattern>/</url-pattern>  
  30.     </servlet-mapping>  
  31.       
  32.     <filter>  
  33.          <filter-name>CharacterEncodingFilter</filter-name>  
  34.           <filter-class>  
  35.             org.springframework.web.filter.CharacterEncodingFilter  
  36.          </filter-class>  
  37.          <async-supported>true</async-supported>  
  38.          <init-param>  
  39.                 <param-name>encoding</param-name>  
  40.                 <param-value>UTF-8</param-value>  
  41.          </init-param>  
  42.          <init-param>  
  43.               <param-name>forceEncoding</param-name>  
  44.               <param-value>true</param-value>  
  45.          </init-param>  
  46.     </filter>  
  47.     <filter-mapping>  
  48.          <filter-name>CharacterEncodingFilter</filter-name>  
  49.          <url-pattern>/*</url-pattern>  
  50.     </filter-mapping>   
  51.   
  52.   
  53. </web-app>  
 3,spring和dubbo配置文件
Xml代码   收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>  
  2. <beans:beans xmlns="http://www.springframework.org/schema/mvc"  
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  4.     xmlns:beans="http://www.springframework.org/schema/beans"  
  5.     xmlns:context="http://www.springframework.org/schema/context"  
  6.     xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd  
  7.         http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd  
  8.         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">  
  9.   
  10.   
  11.     <!-- Handles HTTP GET requests for /resources/** by efficiently serving up static resources in the ${webappRoot}/resources directory -->  
  12.     <resources mapping="/resources/**" location="/resources/" />  
  13.   
  14.     <!-- Enables the Spring MVC @Controller programming model -->  
  15.     <annotation-driven ></annotation-driven>  
  16.     <!--spring 自动扫描com.zhang下边的所有类  -->  
  17.     <context:component-scan base-package="com.zhang" />  
  18.   
  19.     <context:property-placeholder location="classpath:config.properties" />  
  20.     <!-- 自定义配置Service -->  
  21.     <beans:bean id="sayHelloService" class="com.zhang.service.demoImpl"/>  
  22.       
  23.       
  24. </beans:beans>  
 
Xml代码   收藏代码
  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" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"    
  4.     xsi:schemaLocation="http://www.springframework.org/schema/beans    
  5.         http://www.springframework.org/schema/beans/spring-beans.xsd    
  6.         http://code.alibabatech.com/schema/dubbo    
  7.         http://code.alibabatech.com/schema/dubbo/dubbo.xsd  
  8.         ">    
  9.     <!-- 系统项目名 -->    
  10.     <dubbo:application name="DubboDemo" />    
  11.     
  12.     <!-- 注册中心 -->    
  13.     <dubbo:registry protocol="zookeeper" address="${able_zookeeper}"  />    
  14.     <!-- 是否纳入调用统计报表（可选） -->  
  15.     <dubbo:monitor protocol="registry"/>  
  16.       
  17.     <!-- 协议 -->  
  18.     <dubbo:protocol name="dubbo" port="31581" />  
  19.   
  20.     <!-- 服务者与消费者的默认配置 -->  
  21.     <!-- 延迟到Spring初始化完成后，再暴露服务,服务调用超时设置为6秒,超时不重试   -->    
  22.     <dubbo:provider delay="-1" timeout="6000" retries="0"/>  
  23.     <dubbo:consumer timeout="6000" retries="0"/>  
  24. </beans>  
 
Xml代码   收藏代码
  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" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"    
  4.     xsi:schemaLocation="http://www.springframework.org/schema/beans    
  5.         http://www.springframework.org/schema/beans/spring-beans.xsd    
  6.         http://code.alibabatech.com/schema/dubbo    
  7.         http://code.alibabatech.com/schema/dubbo/dubbo.xsd  
  8.         ">  
  9.     <dubbo:service interface="com.zhang.service.demo" ref="sayHelloService"  timeout="3000" protocol="dubbo"/>  
  10. </beans>      
config.properties
Java代码   收藏代码
  1. #able_zookeeper  
  2. able_zookeeper=192.168.50.42:2181  
4,java代码 一个接口一个实现类
Java代码   收藏代码
  1. package com.zhang.service;  
  2.   
  3. public interface demo {  
  4.     public String sayHello();  
  5. }  
 
Java代码   收藏代码
  1. package com.zhang.service;  
  2.   
  3. public class demoImpl implements demo {  
  4.   
  5.     @Override  
  6.     public String sayHello() {  
  7.         return "hello";  
  8.     }  
  9.   
  10. }  
 
 

三 DubboClient工程

 

1，pom.xml和web.xml，config.properties配置文件和DubboServer配置一样

2，增加一个消费者配置文件applicationContext-dubbo-consumer.xml，注：这里需要把服务提供者的jar包打入到客户端，打接口就可以

Xml代码   收藏代码
  1. <strong><?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" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"    
  4.     xsi:schemaLocation="http://www.springframework.org/schema/beans    
  5.         http://www.springframework.org/schema/beans/spring-beans.xsd    
  6.         http://code.alibabatech.com/schema/dubbo    
  7.         http://code.alibabatech.com/schema/dubbo/dubbo.xsd">  
  8.   
  9.     <dubbo:reference id="demo" interface="com.zhang.service.demo" check="false" protocol="dubbo"/>  
  10. </beans> </strong>  

 3，使用

Java代码   收藏代码
  1. <strong>package com.zhang.contr;  
  2.   
  3. import org.springframework.beans.factory.annotation.Autowired;  
  4.   
  5.   
  6. public class test {  
  7.     @Autowired  
  8.     private com.zhang.service.demo demo;  
  9.       
  10.     public String testD(){  
  11.         return demo.sayHello();  
  12.     }  
  13. }  
  14. </strong>  

 

 

四 dubbo-admin-2.5.4.war 管理控制台

    war包下载地址：http://pan.baidu.com/s/1i4xZamD

      把这个war包放到tomcat的webapps目录下 

      1 修改tomcat的端口号不要和其他服务冲突.

      2 修改 WEB-INF 下的dubbo.properties文件

 

      

 

     3 启动tomcat,访问.

 

 

     想看源码的提供一个github的访问地址

https://github.com/zqh1989/DubboDemo

 

Logo
向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

avatar 云原生

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

avatar 云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

avatar 云原生