分布式dubbox入门实例(包括zookeeper下载安装配置)

深碍√TFBOYSˉ_ 2022-05-17 10:52 153阅读 0赞

### 注册中心zookeeper ###

**1.简介**  
ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。  
官方推荐使用 zookeeper 注册中心。注册中心负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小。  
Zookeeper 是 Apacahe Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为Dubbox 服务的注册中心，工业强度较高，可用于生产环境。

**2.安装步骤**

*  第一步：安装 jdk（参考以前笔记）
 *  第二步：下载 zookeeper-3.4.10.tar.gz：  
    [https://mirrors.cnnic.cn/apache/zookeeper][https_mirrors.cnnic.cn_apache_zookeeper]  
    使用CRT工具上传的话 Alt+P 进入SFTP ，输入put d:\\zookeeper-3.4.10.tar.gz 上传或者直接拖拽过去
 *  第三步：解压缩压缩包并将文件夹改名复制到/usr/chenlf下

tar -zxvf zookeeper-3.4.10.tar.gz #解压
    mv zookeeper-3.4.10 zookeeper #重命名
    mkdir chenllf #在usr下创建目录
    cp -rf /home/itcast/zookeeper /usr/chenllf/ #copy到chenlf目录下

*  第四步：进入 zookeeper-3.4.10 目录，创建 data 文件夹。

mkdir data

*  第五步：进入conf目录 ，把 zoo\_sample.cfg 改名为 zoo.cfg

cd conf
    mv zoo_sample.cfg zoo.cfg

*  第六步：打开zoo.cfg , 修改 data 属性：dataDir=/usr/chenllf/zookeeper/data

[root@localhost data]# pwd
    /usr/chenllf/zookeeper/data #获取data路径
    [root@localhost data]# vi ../conf/zoo.cfg

3) 启动服务  
![命令][70]

*  进入bin目录，启动服务输入命令

./zkServer.sh start

*  输出以下内容表示启动成功  
    ![启动成功][70 1]
 *  相关命令：  
    启动服务： ./zkServer.sh start  
    停止服务： ./zkServer.sh stop  
    查看状态： ./zkServer.sh status

### DEMO ###

#### 1. 服务提供者 代码 ####

1)创建maven项目  
2)引入pom.xml相关依赖

<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>cn.chen.demo</groupId>
      <artifactId>dubbox-server</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>war</packaging>
    
      
      <properties>      
            <spring.version>4.2.4.RELEASE</spring.version>
      </properties>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-beans</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-webmvc</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jdbc</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-aspects</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jms</artifactId>
                <version>${spring.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context-support</artifactId>
                <version>${spring.version}</version>
            </dependency>   
            
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.8.4</version>            
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.10</version>
            </dependency>
            <dependency>
                <groupId>com.github.sgroschupf</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.1</version>
            </dependency>
    
            <dependency>
                <groupId>javassist</groupId>
                <artifactId>javassist</artifactId>
                <version>3.11.0.GA</version>
            </dependency>
    
        </dependencies>
       <build>  
          <plugins>
              <plugin>  
                  <groupId>org.apache.maven.plugins</groupId>  
                  <artifactId>maven-compiler-plugin</artifactId>  
                  <version>2.3.2</version>  
                  <configuration>  
                      <source>1.7</source>  
                      <target>1.7</target>  
                  </configuration>  
              </plugin>  
              <plugin>
                    <groupId>org.apache.tomcat.maven</groupId>
                    <artifactId>tomcat7-maven-plugin</artifactId>
                    <configuration>
                        
                        <port>8081</port>
                        
                        <path>/</path>
                    </configuration>
              </plugin>
          </plugins>  
        </build>
    </project>

3)创建WEB-INF并引入web.xml配置文件

4)引入spring配置文件 applicationContext-server.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:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 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/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    
       
        <dubbo:application name="dubbox-server"></dubbo:application>
        
        <dubbo:registry address="zookeeper://192.168.111.130:2181"></dubbo:registry>
        
        <dubbo:annotation package="cn.chen.demo.service.impl"></dubbo:annotation>
    
    </beans>

5)编写接口及实现类

//1.接口
    package cn.chen.demo.service;
    
    public interface UserService { 
        String getName();
    }
    
    //2.实现类
    package cn.chen.demo.service.impl;
    
    import com.alibaba.dubbo.config.annotation.Service;
    
    import cn.chen.demo.service.UserService;
    
    @Service // 注解选的是dubbo的@service,这里需要对外发布并注册到zookeeper注册中心
    public class UserServiceImpl implements UserService{ 
    
        public String getName() {
            return "testDubboxService";
        }
    
    }

#### 2.服务消费者 代码 ####

pom.xml 同上，只需修改端口即可

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" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5">  
       
        <filter>
            <filter-name>CharacterEncodingFilter</filter-name>
            <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
            <init-param>
                <param-name>encoding</param-name>
                <param-value>utf-8</param-value>
            </init-param>
            <init-param>  
                <param-name>forceEncoding</param-name>  
                <param-value>true</param-value>  
            </init-param>  
        </filter>
        <filter-mapping>
            <filter-name>CharacterEncodingFilter</filter-name>
            <url-pattern>/*</url-pattern>
        </filter-mapping>   
    
      <servlet>
        <servlet-name>springmvc</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>classpath:springmvc.xml</param-value>
        </init-param>
      </servlet>
    
      <servlet-mapping>
        <servlet-name>springmvc</servlet-name>
        <url-pattern>/*</url-pattern>
      </servlet-mapping>
    
    </web-app>

springmvc.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:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 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/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    
    
        <mvc:annotation-driven >
            
            <mvc:message-converters register-defaults="false">
                <bean class="org.springframework.http.converter.StringHttpMessageConverter">  
                    <constructor-arg value="UTF-8" />
                </bean>  
            </mvc:message-converters>   
        </mvc:annotation-driven>
    
        
        <dubbo:application name="dubbox-web"></dubbo:application>
        
        <dubbo:registry address="zookeeper://192.168.111.130:2181"></dubbo:registry>
        
        <dubbo:annotation package="cn.chen.demo.controller"></dubbo:annotation>
    
    </beans>

controller

package cn.chen.demo.controller;
    
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.alibaba.dubbo.config.annotation.Reference;
    
    import cn.chen.demo.service.UserService;
    
    @RestController
    @RequestMapping("/user")
    public class UserController { 
    
        @Reference // 引用注入|远程注入
        private UserService userService;
    
        @RequestMapping("/showName")
        private String showName() {
            return userService.getName();
        }
    }

service接口

package cn.chen.demo.service;
    
    public interface UserService { 
    
        String getName();
    }

#### 3. 测试 ####

先启动 zookeeper注册中心  
再启动 dubbox-server 服务者项目  
最后启动 dubbox-web 消费者项目  
启动成功后访问： [http://localhost:8090/user/showName][http_localhost_8090_user_showName]  
能够正常访问，搭建成功！

#### 4. 管理端安装 ####

1)下载dubbox-master.zip源码  
[https://github.com/dangdangdotcom/dubbox][https_github.com_dangdangdotcom_dubbox]  
2)解压并在命令符下进入dubbo-admin目录 ，输入maven命令生成target

mvn package -Dmaven.skip.test=true

3)在安装了zookeeper的linux下载解压tomcat并将打包好的dubbo-admin-2.8.4.war丢到webapps底下，运行tomcat（我这里重命名层dubbo-admin）  
访问 [http://192.168.111.130:8080/dubbo-admin][http_192.168.111.130_8080_dubbo-admin]  
用户名、密码均为root

![正常访问][70 2]

结束~~~

[https_mirrors.cnnic.cn_apache_zookeeper]: https://mirrors.cnnic.cn/apache/zookeeper
[70]: /images/20220517/3dd6c28fd9bd4b7fb63edd8baadb6939.png
[70 1]: /images/20220517/b088681b588345509d1f018fc08d3a9c.png
[http_localhost_8090_user_showName]: http://localhost:8090/user/showName
[https_github.com_dangdangdotcom_dubbox]: https://github.com/dangdangdotcom/dubbox
[http_192.168.111.130_8080_dubbo-admin]: http://192.168.111.130:8080/dubbo-admin
[70 2]: /images/20220517/e2c9a97001d44ff4b12957926505330b.png