zookeeper、dubbo整合搭建rpc（基于springMVC）

客官°小女子只卖身不卖艺 2022-07-16 10:40 102阅读 0赞

## 1、zookeeper ##

1.1 安装jdk1.7  
1.2 安装zookeeper  
下载地址：[http://zookeeper.apache.org/][http_zookeeper.apache.org]  
范例zookeeper版本：zookeeper-3.4.9 （官方稳定版本）  
解压缩至根目录  
1.2.1、并重新命名目录名称为“zoo”。  
1.2.2、重命名C:\\zoo\\conf 下的“zoo\_sample.cfg”文件为”zoo.cfg”。  
1.2.3、双击“C:\\zoo\\bin”的zkServer.cmd。（此时为单例模式运行）

## 2、创建rpc分布式服务器（提供者）、消费服务器、接口 ##

**整体图例：**![这里写图片描述][20161015150016572]

dubbo-api（接口定义）：普通的maven项目  
dubbo-service（提供者）：基于maven创建的j2ee项目  
dubbo-web（消费者）：基于maven创建的j2ee项目

**2.1 dubbo-api**

**dubbo-api的项目结构**  
![这里写图片描述][20161015151017993]  
说明：一般“src/test/java”source Folder 在maven项目不使用，但一般保留完整的目录结构。

**dubbo-api的pom文件**

**dubbo-api的UserService类**

package com.dubbo.service;
    
    public interface UserService {
        public String getName(String name);
    }

**2.2 dubbo-service**

目录图例：![这里写图片描述][20161015151937272]  
（上图中红色区域为创建或修改）

**dubbo-service项目下的UserServiceImpl.java**

package com.dubbo.service.impl;
    
    public class UserServiceImpl implements com.dubbo.service.UserService { 
    
        @Override
        public String getName(String name) {
            return "name is:" + name;
        }
    }

**dubbo-service的applicationContext.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-4.0.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        
        <dubbo:application name="service_provider" />
    
        
        <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    
        
        <dubbo:protocol name="dubbo" port="28080" />
    
        <dubbo:service interface="com.dubbo.service.UserService" ref="userService" />
        <bean id="userService" class="com.dubbo.service.impl.UserServiceImpl" />
    </beans>

**dubbo-service的web.xml**

<?xml version="1.0" encoding="UTF-8"?>
    <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
    
      <display-name>dubbo-service</display-name>
      <welcome-file-list>
        <welcome-file>index.jsp</welcome-file>
      </welcome-file-list>
      <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
      </listener>
      <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:applicationContext.xml</param-value>
      </context-param>
    </web-app>

**dubbo-service的pom**

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>com.dubbo</groupId>
        <artifactId>dubbo-service</artifactId>
        <packaging>war</packaging>
        <version>0.0.1-SNAPSHOT</version>
        <name>dubbo-service Maven Webapp</name>
        <url>http://maven.apache.org</url>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <spring.vesion>4.3.2.RELEASE</spring.vesion>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
                <version>1.7.2</version>
            </dependency>
    
            <dependency>
                <groupId>javax</groupId>
                <artifactId>javaee-api</artifactId>
                <version>7.0</version>
            </dependency>
    
            <dependency>
                <groupId>org.glassfish.web</groupId>
                <artifactId>javax.servlet.jsp.jstl</artifactId>
                <version>1.2.2</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.8</version>
                <exclusions>
                    <exclusion>
                        <artifactId>log4j</artifactId>
                        <groupId>log4j</groupId>
                    </exclusion>
                </exclusions>
            </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.javassist</groupId>
                <artifactId>javassist</artifactId>
                <version>3.18.1-GA</version>
            </dependency>
    
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.9</version>
            </dependency>
    
            <dependency>
                <groupId>org.aspectj</groupId>
                <artifactId>aspectjweaver</artifactId>
                <version>1.6.9</version>
            </dependency>
            <dependency>
                <groupId>commons-pool</groupId>
                <artifactId>commons-pool</artifactId>
                <version>1.5.3</version>
            </dependency>
            <dependency>
                <groupId>commons-collections</groupId>
                <artifactId>commons-collections</artifactId>
                <version>3.2</version>
            </dependency>
    
            <dependency>
                <groupId>commons-httpclient</groupId>
                <artifactId>commons-httpclient</artifactId>
                <version>3.1</version>
            </dependency>
    
            <dependency>
                <groupId>com.dubbo</groupId>
                <artifactId>dubbo-api</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-core</artifactId>
                <version>${spring.vesion}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-web</artifactId>
                <version>${spring.vesion}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-webmvc</artifactId>
                <version>${spring.vesion}</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-instrument-tomcat</artifactId>
                <version>${spring.vesion}</version>
            </dependency>
    
        </dependencies>
        <build>
            <finalName>dubbo-service</finalName>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <version>3.1</version>
                    <configuration>
                        <source>1.7</source>
                        <target>1.7</target>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    </project>

2.3 dubbo-web项目

项目图例：![这里写图片描述][20161015153005773]

**dubbo-web的IndexController.java文件**

package com.dubbo.web.controller;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import com.dubbo.service.UserService;
    
    @Controller
    public class IndexController {
    
    
        @Autowired
        private UserService userService;
    
        @RequestMapping(value = "/index", produces = "text/plain;charset=UTF-8")
        @ResponseBody
        public String index(HttpServletRequest request, HttpServletResponse response) {
    
            String name = "";
            if (request.getParameter("name") != null)
                name = request.getParameter("name");
    
            String result = userService.getName(name);
            return result;
        }
    
    }

**applicationContext.xml**

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
    
        <import resource="dubbo-config.xml" />
        <import resource="spring-servlet.xml" />    
    </beans>

**dubbo-config.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:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
        <dubbo:application name="web_consumer" />
        
        <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    
        <dubbo:reference interface="com.dubbo.service.UserService" id="userService" check="false" />
    </beans>

**spring-servlet.xml**

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc" 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/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
    
        <context:component-scan base-package="com.dubbo" />
    
        <mvc:annotation-driven />
    
    </beans>

**dubbo-web的web.xml文件**

<?xml version="1.0" encoding="UTF-8"?>
    <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
    
        <display-name>dubbo-controller</display-name>
        <welcome-file-list>
            <welcome-file></welcome-file>
        </welcome-file-list>
    
        <servlet>
            <servlet-name>dispatcher</servlet-name>
            <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
            <init-param>
                <param-name>contextConfigLocation</param-name>
                <param-value>classpath:applicationContext.xml</param-value>
            </init-param>
            <load-on-startup>0</load-on-startup>
        </servlet>
    
        <servlet-mapping>
            <servlet-name>dispatcher</servlet-name>
            <url-pattern>/</url-pattern>
        </servlet-mapping>
    
    </web-app>

**dubbo-web的pom文件**

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.dubbo</groupId>
        <artifactId>dubbo-web</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>war</packaging>
    
        <name>dubbo-web</name>
        <url>http://maven.apache.org</url>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <org.springframework.version>4.3.2.RELEASE</org.springframework.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>3.8.1</version>
                <scope>test</scope>
            </dependency>
    
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
                <version>1.7.2</version>
            </dependency>
    
            <dependency>
                <groupId>javax</groupId>
                <artifactId>javaee-api</artifactId>
                <version>7.0</version>
            </dependency>
    
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-core</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.glassfish.web</groupId>
                <artifactId>javax.servlet.jsp.jstl</artifactId>
                <version>1.2.2</version>
            </dependency>
    
            <dependency>
                <groupId>org.codehaus.jackson</groupId>
                <artifactId>jackson-mapper-asl</artifactId>
                <version>1.9.13</version>
            </dependency>
    
            <dependency>
                <groupId>net.sf.json-lib</groupId>
                <artifactId>json-lib</artifactId>
                <version>2.4</version>
                <classifier>jdk15</classifier>
            </dependency>
    
            <dependency>
                <groupId>org.javassist</groupId>
                <artifactId>javassist</artifactId>
                <version>3.18.1-GA</version>
            </dependency>
    
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.9</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.8</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.slf4j</groupId>
                        <artifactId>slf4j-log4j12</artifactId>
                    </exclusion>
                </exclusions>
            </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>com.dubbo</groupId>
                <artifactId>dubbo-api</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
    
        </dependencies>
        <build>
            <finalName>dubbo-web</finalName>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <version>3.1</version>
                    <configuration>
                        <source>1.7</source>
                        <target>1.7</target>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    </project>

## 总结 ##

由于dubbo是深度依赖netty版本的，目前dubbo2.5.3依赖的是netty.3.7.0 ，netty4的机制与netty3差别较大。

至此项目整合完成。  
将dubo-service和dubbo-web两个项目添加到tomcat中运行  
打开浏览器地址：[http://localhost:8080/dubbo-web/index?name=zoo][http_localhost_8080_dubbo-web_index_name_zoo] ，完成测试。

基于maven创建springMVC可参考：[http://blog.csdn.net/yeness/article/details/52092278][http_blog.csdn.net_yeness_article_details_52092278]

**整合代码地址**：[http://download.csdn.net/detail/yeness/9657863][http_download.csdn.net_detail_yeness_9657863]

**protobuf-rpc-pro （第二款rpc）：**  
maven地址：[https://mvnrepository.com/artifact/com.googlecode.protobuf-rpc-pro/protobuf-rpc-pro-duplex][https_mvnrepository.com_artifact_com.googlecode.protobuf-rpc-pro_protobuf-rpc-pro-duplex]  
说明：Protobuf RPC Pro is a java protocol buffers RPC implementation featuring bidirectional RPC calls and TCP socket connection re-use and the option of secure communications.

**zoroc ice（第三款rpc）**：[https://zeroc.com/][https_zeroc.com]

[http_zookeeper.apache.org]: http://zookeeper.apache.org/
[20161015150016572]: /images/20220716/1623f27ef60f4216b985889e3f09789a.png
[20161015151017993]: /images/20220716/f1b0339b5b5c40a28c9332a0f5bb9be8.png
[20161015151937272]: /images/20220716/38852fc87d18403d80dcf26d10802c41.png
[20161015153005773]: /images/20220716/eea8f33546294979b3802f8750b6edc8.png
[http_localhost_8080_dubbo-web_index_name_zoo]: http://localhost:8080/dubbo-web/index?name=zoo
[http_blog.csdn.net_yeness_article_details_52092278]: http://blog.csdn.net/yeness/article/details/52092278
[http_download.csdn.net_detail_yeness_9657863]: http://download.csdn.net/detail/yeness/9657863
[https_mvnrepository.com_artifact_com.googlecode.protobuf-rpc-pro_protobuf-rpc-pro-duplex]: https://mvnrepository.com/artifact/com.googlecode.protobuf-rpc-pro/protobuf-rpc-pro-duplex
[https_zeroc.com]: https://zeroc.com/