dubbo、zookeeper和spring整合

一  zookeeper下载和操作

    1 下载zookeeper

       下载地址 https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/ 

        将下载的源码包上传到linux机器上(我的在/usr/local/zookeeper/目录下),并解压

        解压的根目录的conf文件夹下有一个zoo_sample.cfg

        使用命令:cp zoo_sample.cfg  zoo.cfg  复制一份 在启动的时候会加载配置文件

    2 操作zookeeper

${zookeeper path}/bin/zkServer.sh start            进入bin目录 执行服务脚本 默认监听2181端口 ${zookeeper path}/bin/zkServer.sh stop

二  项目搭建

       

  1  创建maven工程   下面创建4个模块

    api: 里面写服务接口

    service: 写api里面接口的实现类

    provider: 服务提供者  暴露服务  接收消费者的请求之后  调用实现类返回数据

    customer: 服务消费者  调用provider暴露的服务

    这里面provider和customer要发送接收请求,所以使用工程

    api和service里面只有一些类,使用工程就行了

  2  在api里面写一个接口

public interface TestRPC {     public Map<String,String> test(); }

  3  在service里 写实现类

     首先 在service的pom文件加入api模块的依赖

public class TestRPCimpl implements TestRPC {     public Map<String, String> test(){         System.out.println("hello world");         Map<String, String> map = new HashMap<String, String>();         map.put("hello", "dubbo");         map.put("hello", "zookeeper");         return map;     } }

  4  provider服务提供者

    4.1 pom文件加入这些依赖后   再加入service模块的依赖

<properties>     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>     <org.springframework.version>4.3.12.RELEASE</org.springframework.version>     <jackson.version>2.9.3</jackson.version> </properties> <dependencies> <dependency> <groupId>javax.servlet</groupId> <artifactId>javax.servlet-api</artifactId> <version>3.1.0</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${org.springframework.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> <version>${org.springframework.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${org.springframework.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>${org.springframework.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${org.springframework.version}</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-core</artifactId> <version>${jackson.version}</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>${jackson.version}</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-annotations</artifactId> <version>${jackson.version}</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.3</version> <exclusions> <exclusion> <artifactId>spring</artifactId> <groupId>org.springframework</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.8</version> <exclusions> <exclusion> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>1.2.16</version> </dependency> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> </dependencies>

    4.2  spring配置文件applicationContext.xml(这里面 配置dubbo 暴露服务) 

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <!-- 用于配置当前应用信息，不管该应用是提供者还是消费者 --> <dubbo:application name="test_provider" /> <!-- 使用zookeeper注册中心暴露服务地址 ip为第一步启动zookeeper的linux机器ip 默认端口2181 --> <dubbo:registry address="zookeeper://192.168.0.202:2181" /> <!-- 协议配置，用于配置提供服务的协议信息 --> <dubbo:protocol name="dubbo" port="20880"/> <!-- 声明需要暴露的服务接口 --> <dubbo:service interface="org.dubbo_zk.api.TestRPC" ref="testRpc" /> <!-- 具体的实现bean --> <bean id="testRpc" class="org.dubbo_zk.service.TestRPCimpl" /> </beans>

 4.3 spring-mvc.xml配置

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:task="http://www.springframework.org/schema/task" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd" default-lazy-init="false"> <mvc:annotation-driven> <!-- 消息转换器 --> <mvc:message-converters register-defaults="true"> <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter"> <property name="supportedMediaTypes" value="text/html;charset=UTF-8" /> </bean> </mvc:message-converters> </mvc:annotation-driven> <!-- 静态资源 --> <mvc:resources mapping="/resources/**" location="/resources/" /> <!-- 启动SpringMVC的注解功能，完成请求和注解POJO的映射 --> <bean class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter"> <property name="messageConverters"> <list> <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter"> <property name="supportedMediaTypes"> <list> <value>text/plain;charset=UTF-8</value> </list> </property> </bean> </list> </property> </bean> </beans>

 4.4  web.xml文件

<!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd" > <web-app> <display-name>dubbo_zk-provider</display-name> <context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath*:applicationContext.xml</param-value> </context-param> <listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener> <servlet> <servlet-name>dubbo_provider_Servlet</servlet-name> <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class> <init-param> <param-name>contextConfigLocation</param-name> <param-value>classpath*:spring-mvc.xml</param-value> </init-param> <load-on-startup>1</load-on-startup> </servlet> <servlet-mapping> <servlet-name>dubbo_provider_Servlet</servlet-name> <url-pattern>/</url-pattern> </servlet-mapping> </web-app>

5  customer消费者

   5.1  pom文件

    加入4.1中的依赖后  加入api模块的依赖

    5.2  applicationContex.xml文件

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">     <!-- 提供方应用信息，用于计算依赖关系 --> <dubbo:application name="test_consumer" /> <!-- 使用zookeeper注册中心暴露服务地址 ip为第一步启动zookeeper的linux机器ip 默认端口2181 --> <dubbo:registry address="zookeeper://192.168.0.202:2181" /> <!-- 声明需要暴露的服务接口 --> <dubbo:reference interface="org.dubbo_zk.api.TestRPC" id="testRpc" check="false" /> </beans>

    5.3  spring-mvc.xml文件

    和4.3的一样

    5.4  web.xml文件

    和4.4的一样

    5.5  写controller类  远程调用服务

@Controller public class TestRPCustomer { @Resource private TestRPC testRPC; @RequestMapping("/test") public @ResponseBody Map<String,String> test(){ Map<String,String> map = testRPC.test(); Set<String> set = map.keySet(); for(String s:set) { System.out.println(s+":"+map.get(s)); } return testRPC.test(); } }

这个时候整个项目搭建完成了  

可以下载看一下代码  https://github.com/hello-piper/piper

可以放到tomcat中  请求一下了

6  dubbo的监控页面

   项目启动之后,我们可以打开dubbo的监控页面看一下 消费者和提供者的状态

    这个把我坑的好惨   网上有人提供了一个dubbo-admin-2.6.0.war的包  说放到tomcat中就可以了

    我下载了他们的war包后却怎么也访问不到页面 

    后来想了一下   官网都下载不到这个war包  这些人怎么找到的呢    带着这个疑问找度娘

    这有一个小哥说了怎么自己生成一个war包  https://www.cnblogs.com/xhkj/p/7407092.html 

    把官网上的github地址的项目下载下来    在dos窗口 进入目录的dubbo-admin目录  使用maven打包工具 

    之后会生成一个war包  讲这个包放到tomcat中就行了