【教程】dubbo+zookeeper项目Demo

超、凢脫俗 2022-04-23 05:48 235阅读 0赞

1.环境

jdk、maven等工具已安装。下面的例子基于eclipse，绿色版的zookeeper，win10系统。
工程GIT: https://github.com/ydfind/javademo/tree/master/maven/dubbo-demo

2.运行zookeeper

运行安装目录下“./bin/zkServer.cmd”，以启动zookper。
“./conf/zoo.cfg”配置文件可以配置一些属性，如下：
dataDir=D:\ProgramData\zookeeper
dataLogDir=D:\ProgramData\zookeeper\log
在这里插入图片描述

3.创建maven工程“dubbo-server”

目录结构和最终jar包，如下：
在这里插入图片描述在这里插入图片描述

1）ServerMain.java

  1. package com.ydfind;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
  6. import java.io.IOException;
  7. /**
  8.  * 
  9.  * @author Yudi
  10.  *
  11.  */
  12. public class ServerMain {
  13.     private static Logger logger = LoggerFactory.getLogger(ServerMain.class);
  14.     public static void main(String[] args) throws IOException {
  15.         logger.info("--------------------start------------------------");
  16.         try {
  18.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "dubbo.xml" });
  19.         context.start();
  20.         logger.info("任意按键退出");
  21.         System.in.read();
  22.         context.close();
  23.         logger.info("服务器正常关闭-----------------------------");
  24.         }catch(Exception e) {
  25.             logger.info("服务器报错了-------------------");
  26.             e.printStackTrace();
  27.         }
  28.     }
  29. }

2）ElasticService.java

  1. package com.ydfind.service;
  2. /**
  3.  * 
  4.  * @author Yudi
  5.  *
  6.  */
  7. public interface ElasticService {
  8.     String helloDubbo(String msg);
  9. }

3）ElasticServiceImpl.java

  1. package com.ydfind.service.impl;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  5. import com.ydfind.service.ElasticService;
  6. /**
  7.  * 
  8.  * @author Yudi
  9.  *
  10.  */
  11. public class ElasticServiceImpl implements ElasticService {
  13.     private static final Logger logger = LoggerFactory.getLogger(ElasticServiceImpl.class);
  15.     public String helloDubbo(String msg) {
  16.         logger.info("服务器收到:" + msg);
  17.         return "hi!" + msg;
  18.     }
  19. }

4）Dubbo.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"
  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">
  10.     <dubbo:application name="dubbo-server" owner="ydfind" />
  11.     <!-- zookeeper注册中心 -->
  12.     <dubbo:registry address="zookeeper://127.0.0.1:2181" />
  13.     <dubbo:protocol contextpath="dubbo" port="20881" />
  14.     <dubbo:monitor protocol="registry"/>
  16.     <!-- 服务具体实现 -->
  17.     <bean id="elasticService" class="com.ydfind.service.impl.ElasticServiceImpl" />
  19.     <!-- 向注册中心注册暴漏服务地址,注册服务 -->
  20.     <dubbo:service interface="com.ydfind.service.ElasticService" ref="elasticService" protocol="dubbo" timeout="50000"/>
  21. </beans>

5）log4j.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE log4j:configuration SYSTEM "./log4j.dtd">
  3. <log4j:configuration>
  4.     <appender name="consoleAppender" class="org.apache.log4j.ConsoleAppender">
  5.         <layout class="org.apache.log4j.PatternLayout">
  6.             <param name="ConversionPattern" value="[%-d{yyyy-MM-dd HH:mm:ss.SSS}][%p][%t] %X{operationName} %X{userId} - %m%n" />
  7.         </layout>
  8.     </appender>
  10.     <root>
  11.         <level value="INFO" />
  12.         <appender-ref ref="consoleAppender" />
  13.     </root>
  14. </log4j:configuration>

6）pom.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/xsd/maven-4.0.0.xsd">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <groupId>com.ydfind</groupId>
  5.     <artifactId>dubbo-server</artifactId>
  6.     <version>0.0.1-SNAPSHOT</version>
  8.     <properties>
  9.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  10.     </properties>
  12.     <dependencies>
  13.         <!-- spring begin -->
  14.         <dependency>
  15.             <groupId>org.springframework</groupId>
  16.             <artifactId>spring-context</artifactId>
  17.             <version>4.1.6.RELEASE</version>
  18.         </dependency>
  19.         <!-- spring end -->
  20.         <!-- dubbo begin -->
  21.         <dependency>
  22.             <groupId>com.alibaba</groupId>
  23.             <artifactId>dubbo</artifactId>
  24.             <version>2.5.3</version>
  25.         </dependency>
  26.         <!-- dubbo end -->
  27.         <!-- 注册中心zookeeper begin -->
  28.         <dependency>
  29.             <groupId>org.apache.zookeeper</groupId>
  30.             <artifactId>zookeeper</artifactId>
  31.             <version>3.3.6</version>
  32.         </dependency>
  33.         <!-- 注册中心zookeeper end -->
  34.         <!-- log begin -->
  35.         <dependency>
  36.             <groupId>commons-logging</groupId>
  37.             <artifactId>commons-logging</artifactId>
  38.             <version>1.1.1</version>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>log4j</groupId>
  42.             <artifactId>log4j</artifactId>
  43.             <version>1.2.16</version>
  44.             <exclusions>
  45.                 <exclusion>
  46.                     <groupId>com.sun.jdmk</groupId>
  47.                     <artifactId>jmxtools</artifactId>
  48.                 </exclusion>
  49.                 <exclusion>
  50.                     <groupId>com.sun.jmx</groupId>
  51.                     <artifactId>jmxri</artifactId>
  52.                 </exclusion>
  53.                 <exclusion>
  54.                     <artifactId>jms</artifactId>
  55.                     <groupId>javax.jms</groupId>
  56.                 </exclusion>
  57.                 <exclusion>
  58.                     <artifactId>mail</artifactId>
  59.                     <groupId>javax.mail</groupId>
  60.                 </exclusion>
  61.             </exclusions>
  62.         </dependency>
  63.         <!-- log end -->
  64.         <!-- other begin -->
  65.         <dependency>
  66.             <groupId>org.jboss.netty</groupId>
  67.             <artifactId>netty</artifactId>
  68.             <version>3.2.0.Final</version>
  69.         </dependency>
  70.         <dependency>
  71.             <groupId>com.101tec</groupId>
  72.             <artifactId>zkclient</artifactId>
  73.             <version>0.8</version>
  74.         </dependency>
  75.         <!-- other end -->
  76.     </dependencies>
  77. </project>

4.maven的jar工程“dubbo-client”

注意
需要把dubbo-server的包加入

在这里插入图片描述在这里插入图片描述

1）ClientMain.java

  1. package com.ydfind;
  2. import org.slf4j.Logger;
  3. import org.slf4j.LoggerFactory;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. import com.ydfind.service.ElasticService;
  6. /**
  7.  * 
  8.  * @author Yudi
  9.  *
  10.  */
  11. public class ClientMain {
  12.     private static Logger logger = LoggerFactory.getLogger(ClientMain.class);
  14.     public static void main(String[] args) {
  15.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "dubbo.xml" });
  16.         try {
  17.             context.start();
  18.             ElasticService service = (ElasticService) context.getBean("elasticService");
  19.             logger.info(service.helloDubbo("world"));
  20.             context.close();
  21.             logger.info("客户端正确结束了");
  22.         } catch (Exception e) {
  23.             logger.info("客户端 报错了");
  24.             e.printStackTrace();
  25.         }
  26.     }
  27. }

2）dubbo.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"
  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">
  10.     <dubbo:application name="consumer-of-dubbo-demo" />
  12.     <dubbo:registry address="zookeeper://127.0.0.1:2181" />
  14.     <!-- 向注册中心订阅服务 -->
  15.     <dubbo:reference id="elasticService" interface="com.ydfind.service.ElasticService" />
  17. </beans>

3）log4j.xml

同上

4）pom.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/xsd/maven-4.0.0.xsd">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <groupId>com.ydfind</groupId>
  5.     <artifactId>dubbo-client</artifactId>
  6.     <version>0.0.1-SNAPSHOT</version>
  8.     <properties>
  9.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  10.     </properties>
  12.     <dependencies>
  13.         <!-- spring begin -->
  14.         <dependency>
  15.             <groupId>org.springframework</groupId>
  16.             <artifactId>spring-context</artifactId>
  17.             <version>4.1.6.RELEASE</version>
  18.         </dependency>
  19.         <!-- spring end -->
  21.         <!-- dubbo begin -->
  22.         <dependency>
  23.             <groupId>com.alibaba</groupId>
  24.             <artifactId>dubbo</artifactId>
  25.             <version>2.5.3</version>
  26.         </dependency>
  27.         <!-- dubbo end -->
  29.         <!-- 注册中心zookeeper begin -->
  30.         <dependency>
  31.             <groupId>org.apache.zookeeper</groupId>
  32.             <artifactId>zookeeper</artifactId>
  33.             <version>3.3.6</version>
  34.         </dependency>
  35.         <!-- 注册中心zookeeper end -->
  37.         <!-- log begin -->
  38.         <dependency>
  39.             <groupId>log4j</groupId>
  40.             <artifactId>log4j</artifactId>
  41.             <version>1.2.16</version>
  42.             <exclusions>
  43.                 <exclusion>
  44.                     <groupId>com.sun.jdmk</groupId>
  45.                     <artifactId>jmxtools</artifactId>
  46.                 </exclusion>
  47.                 <exclusion>
  48.                     <groupId>com.sun.jmx</groupId>
  49.                     <artifactId>jmxri</artifactId>
  50.                 </exclusion>
  51.                 <exclusion>
  52.                     <artifactId>jms</artifactId>
  53.                     <groupId>javax.jms</groupId>
  54.                 </exclusion>
  55.                 <exclusion>
  56.                     <artifactId>mail</artifactId>
  57.                     <groupId>javax.mail</groupId>
  58.                 </exclusion>
  59.             </exclusions>
  60.         </dependency>
  61.         <!-- log end -->
  63.         <!-- other begin -->
  64.         <dependency>
  65.             <groupId>com.101tec</groupId>
  66.             <artifactId>zkclient</artifactId>
  67.             <version>0.8</version>
  68.         </dependency>
  69.         <dependency>
  70.             <groupId>com.ydfind</groupId>
  71.             <artifactId>dubbo-server</artifactId>
  72.             <version>0.0.1-SNAPSHOT</version>
  73.         </dependency>
  74.         <!-- other end -->
  75.     </dependencies>
  76. </project>

5.运行测试

  • 1）运行zookeeper；
  • 2）运行dubbo-server的ServerMain.java；
  • 3）运行dubbo-client的ClientMain.java；
  • 4）将输出：
    在这里插入图片描述在这里插入图片描述
    注意：zookeeper和dubbo-server不能关闭，否则dubbo-client无法运行成功；

发表评论

表情：
评论列表 （有 0 条评论，235人围观）

还没有评论，来说两句吧...

相关阅读

    相关 开源商城项目前端demo

    大家都知道，我每天最重要的事就是帮大家在GitHub上挖掘出最受程序员欢迎的开源项目，这不，今天GitHub热榜上又有一个项目成功引起了小编的注意——mall-swarm 之

    女爷i女爷i/ 0 赞/ 223 阅读

    相关 Vue项目demo汇总

    vue慢慢的成为了前端最受欢迎的框架之一，在很多项目之中开发都能用得到，如今也已经发展到3.0了，可能是因为这个框架可以提高工作效率，因此受到大家的追捧，在之前的文章里面也说过

    小灰灰小灰灰/ 0 赞/ 182 阅读