Dubbo入门（二）——IDEA下Dubbo+Zookeeper搭建

小鱼儿 2024-03-30 12:32 68阅读 0赞

#### 目录 ####

*  一、Zookeeper
 *   *  1.1 下载
     *  1.2 安装
     *  1.3 修改配置文件
     *  1.4 启动
 *  二、Dubbo插件搭建
 *  三、手动创建
 *   *  3.1 创建项目
     *   *  3.1.1 pom依赖
     *  3.2 api模块
     *   *  3.2.1 pom依赖
         *  3.2.2 实体类
         *  3.2.3 service接口
     *  3.3 provider
     *   *  3.3.1 pom依赖
         *  3.3.2 配置文件
         *  3.3.3 mapper
         *  3.3.4 service实现类
         *  3.3.5 启动类
     *  3.4 consumer
     *   *  3.4.1 pom依赖
         *  3.4.2 配置文件
         *  3.4.3 控制层
         *  3.4.4 启动类
 *  四、测试

## 一、Zookeeper ##

我选择的是3.6.3版本的zookeeper

### 1.1 下载 ###

官网：[https://zookeeper.apache.org/releases.html][https_zookeeper.apache.org_releases.html]

![在这里插入图片描述][5a38847a378f4ccd9ebd24468c595d2a.png]  
下载  
![在这里插入图片描述][a1332767365c41c8b5ed88b0b37ca793.png]

### 1.2 安装 ###

将下载的压缩包进行解压  
![在这里插入图片描述][c01d7712a59d45adaec360330470f259.png]  
将zookeeper配置至环境变量

<table> 
 <thead> 
  <tr> 
   <th>变量名</th> 
   <th>变量值</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>ZOOKEEPER_HOME</td> 
   <td>D:\Program Files\apache-zookeeper-3.6.3-bin</td> 
  </tr> 
 </tbody> 
</table>

![在这里插入图片描述][72c860ca71f24af29cd357fc5007bd9c.png]  
path中引入zookeeper

%ZOOKEEPER_HOME%\bin
    %ZOOKEEPER_HOME%\conf

![在这里插入图片描述][9c813123de974c418b15aedef1476e01.png]

### 1.3 修改配置文件 ###

将conf下的**zoo\_sample.cfg**复制并命名为**zoo.cfg**  
并添加配置内容：

dataDir=D:\\azookerpersstudy\\data
    dataLogDir=D:\\azookerpersstudy\\log

### 1.4 启动 ###

在zookeeper下的bin目录下  
点击**zkservice.cmd**  
![在这里插入图片描述][654c2ee292714eccae65b19b019ddc1e.png]  
![在这里插入图片描述][dc9f7fc3690741ba91cb166742439086.png]

## 二、Dubbo插件搭建 ##

idea已经有dubbo插件**IntellijDubboPlugin**，可快速构建一个 dubbo 项目  
Configure→Plugins  
输入Dubbo，点击installed  
![在这里插入图片描述][7acd4c30eadc425f8963bde934a12638.png]  
安装后，在创建项目界面就会多一个Dubbo的选项，点击Next  
![在这里插入图片描述][af7753b4d1b747fba2d00459e710aee8.png]  
点击Next  
![在这里插入图片描述][4a7839c7ba424654bdd65aa75ce0334b.png]  
设置项目路径和名称  
![在这里插入图片描述][de72767c7fbb402b9ab11e13690e80ee.png]  
点击finish  
创建成功后，结构如下：  
![在这里插入图片描述][6bddca4cad044b1db5169a378836c6b6.png]

## 三、手动创建 ##

以下示例为Dubbo+Zookeeper+SpringBoot+Mybatis集成项目

### 3.1 创建项目 ###

选择maven，创建父项目dubbo\_demo  
![在这里插入图片描述][a5e180119e4d4373b08e2c2e07bc23bc.png]

#### 3.1.1 pom依赖 ####

<groupId>com.tung</groupId>
        <artifactId>dubbo_demo</artifactId>
        <packaging>pom</packaging>
        <version>1.0-SNAPSHOT</version>
    
    	
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.7.3</version>
            <relativePath/> 
        </parent>
    
        
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
            <java.version>1.8</java.version>
            <zk.version>3.6.2</zk.version>
            <dubbo.version>2.7.7</dubbo.version>
            <curator.framework.version>5.1.0</curator.framework.version>
            <curator.recipes.version>5.1.0</curator.recipes.version>
        </properties>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.apache.dubbo</groupId>
                    <artifactId>dubbo-spring-boot-starter</artifactId>
                    <version>${dubbo.version}</version>
                </dependency>
    
                <dependency>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                    <version>${zk.version}</version>
                </dependency>
    
                <dependency>
                    <groupId>org.apache.curator</groupId>
                    <artifactId>curator-framework</artifactId>
                    <version>${curator.framework.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.apache.curator</groupId>
                    <artifactId>curator-recipes</artifactId>
                    <version>${curator.recipes.version}</version>
                </dependency>
            </dependencies>
        </dependencyManagement>

### 3.2 api模块 ###

创建dubbo\_api模块  
![在这里插入图片描述][1c984304c4a64628af6d0d50fe7656f8.png]  
api模块提供接口和实体类  
![在这里插入图片描述][6fffad624fa04b62bff90432b89e6954.png]

#### 3.2.1 pom依赖 ####

#### 3.2.2 实体类 ####

package com.tung.entity;
    
    import java.io.Serializable;
    
    /**
     * @author tung
     * @ClassName User
     * @Description 类的说明
     * @date 2022/12/29
     */
    public class User implements Serializable {
        
    
        private  String id;
        private String name;
        private String password;
    
    
        public User(String id, String name, String password) {
        
            this.id = id;
            this.name = name;
            this.password = password;
        }
    
        public User() {
        
        }
    
        public String getId() {
        
            return id;
        }
    
        public void setId(String id) {
        
            this.id = id;
        }
    
        public String getName() {
        
            return name;
        }
    
        public void setName(String name) {
        
            this.name = name;
        }
    
        public String getPassword() {
        
            return password;
        }
    
        public void setPassword(String password) {
        
            this.password = password;
        }
    }

#### 3.2.3 service接口 ####

package com.tung.service;
    
    import com.tung.entity.User;
    
    import java.util.List;
    
    /**
     * @author tung
     * @ClassName UserService
     * @Description 类的说明
     * @date 2022/12/29
     */
    public interface UserService {
        
    
        List<User> findAll();
    }

### 3.3 provider ###

创建dubbo\_provider，操作跟dubbo\_api一样。

#### 3.3.1 pom依赖 ####

<parent>
            <artifactId>dubbo_demo</artifactId>
            <groupId>com.tung</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>dubbo_provider</artifactId>
    
        <name>dubbo_provider</name>
        
        <url>http://www.example.com</url>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <maven.compiler.source>1.7</maven.compiler.source>
            <maven.compiler.target>1.7</maven.compiler.target>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
            </dependency>
    
            
            
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-recipes</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>com.tung</groupId>
                <artifactId>dubbo_api</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
            
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>1.3.2</version>
            </dependency>
            
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </dependency>
        </dependencies>

#### 3.3.2 配置文件 ####

application.yml

server:
      port: 8082
    
    # 注册中心 zookeeper的地址
    dubbo:
      registry:
        address: zookeeper://127.0.0.1:2181
        timeout: 20000
    
      application:
        name: dubbo-provider
    
      scan:
        base-packages: com.tung
    
      protocol:
        name: dubbo
        port: 20880
    
    mybatis:
      config-location: classpath:mybatis-config.xml
    
    spring:
      datasource:
        name : test
        url : jdbc:mysql://127.0.0.1:3306/demo?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true
        username : root
        password: root
        driver-class-name: com.mysql.cj.jdbc.Driver

mybatis-config.xml

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE configuration
            PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
            "http://mybatis.org/dtd/mybatis-3-config.dtd">
    <configuration>
        <settings>
            
            <setting name="cacheEnabled" value="true"/>
            
            <setting name="defaultStatementTimeout" value="3000"/>
            
            <setting name="mapUnderscoreToCamelCase" value="true"/>
            
            <setting name="useGeneratedKeys" value="true"/>
        </settings>
        
    </configuration>

#### 3.3.3 mapper ####

package com.tung.mapper;
    
    import com.tung.entity.User;
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Select;
    
    import java.util.List;
    
    /**
     * @author tung
     * @ClassName UserMapper
     * @Description 类的说明
     * @date 2022/12/29
     */
    @Mapper
    public interface UserMapper {
        
    
        @Select("select id,name,password from t_user")
        List<User> findAll();
    }

#### 3.3.4 service实现类 ####

package com.tung.service.impl;
    
    import com.tung.entity.User;
    import com.tung.mapper.UserMapper;
    import com.tung.service.UserService;
    import org.apache.dubbo.config.annotation.DubboService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * @author tung
     * @ClassName UserServiceImpl
     * @Description 类的说明
     * @date 2022/12/29
     */
    @Component
    @DubboService(loadbalance = "roundrobin")
    public class UserServiceImpl implements UserService {
        
    
        @Autowired
        private UserMapper userMapper;
    
        @Override
        public List<User> findAll() {
        
            return userMapper.findAll();
        }
    }

#### 3.3.5 启动类 ####

package com.tung.service;
    
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    /**
     * @author tung
     * @ClassName ProviderApplication
     * @Description 类的说明
     * @date 2022/12/29
     */
    @SpringBootApplication
    @MapperScan("com.tung.mapper")
    public class ProviderApplication {
        
    
        public static void main(String[] args){
        
            SpringApplication.run(ProviderApplication.class,args);
        }
    }

### 3.4 consumer ###

创建dubbo\_consumer  
![在这里插入图片描述][3b09c5dfb8c84ef686894d7062b2293a.png]

#### 3.4.1 pom依赖 ####

<parent>
            <artifactId>dubbo_demo</artifactId>
            <groupId>com.tung</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>dubbo_consumer</artifactId>
        <packaging>war</packaging>
    
        <name>dubbo_consumer Maven Webapp</name>
        
        <url>http://www.example.com</url>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <maven.compiler.source>1.7</maven.compiler.source>
            <maven.compiler.target>1.7</maven.compiler.target>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>com.tung</groupId>
                <artifactId>dubbo_api</artifactId>
                <version>1.0-SNAPSHOT</version>
            </dependency>
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-recipes</artifactId>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
    
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
    
        </dependencies>

#### 3.4.2 配置文件 ####

application.yml

server:
      port: 8083
    
    # 注册中心 zookeeper的地址
    dubbo:
      registry:
        address: zookeeper://127.0.0.1:2181
        timeout: 20000
    
      application:
        name: dubbo-consumer
    
      scan:
        base-packages: com.tung.controller
    
      protocol:
        name: dubbo-consumer
        port: 20881

#### 3.4.3 控制层 ####

package com.tung.controller;
    
    import com.tung.entity.User;
    import com.tung.service.UserService;
    import org.apache.dubbo.config.annotation.DubboReference;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.List;
    
    /**
     * @author tung
     * @ClassName UserController
     * @Description 类的说明
     * @date 2022/12/29
     */
    @RestController
    @RequestMapping("/user")
    public class UserController {
        
    
        @DubboReference
        private UserService userService;
    
        @GetMapping("/findAll")
        public List<User> findAll(){
        
            return userService.findAll();
        }
    }

#### 3.4.4 启动类 ####

package com.tung;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    /**
     * @author tung
     * @ClassName ConsumerApplication
     * @Description 类的说明
     * @date 2022/12/28
     */
    @SpringBootApplication
    public class ConsumerApplication {
        
    
        public static void main(String[] args){
        
            SpringApplication.run(ConsumerApplication.class,args);
        }
    }

## 四、测试 ##

依次启动provider、consumer  
访问consumer暴露的接口  
![在这里插入图片描述][dab84dbd07f04da6b012fbf980359414.png]  
成功

[https_zookeeper.apache.org_releases.html]: https://zookeeper.apache.org/releases.html
[5a38847a378f4ccd9ebd24468c595d2a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/4d1e08224c2543cd8364a21e6e351f80.png
[a1332767365c41c8b5ed88b0b37ca793.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/085c251b174045b6a60fa049b8b4b3b6.png
[c01d7712a59d45adaec360330470f259.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/ffd75ef709a84ab1be5f58600a9e7d01.png
[72c860ca71f24af29cd357fc5007bd9c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/b01e8612473040d3a699c12ee470c146.png
[9c813123de974c418b15aedef1476e01.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/623246efd60343c4ac5d260d7e365116.png
[654c2ee292714eccae65b19b019ddc1e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/cc7d7d5fe69e4d47ba479bc3879ec751.png
[dc9f7fc3690741ba91cb166742439086.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/bf13718550a34c74a986615d09ceadcf.png
[7acd4c30eadc425f8963bde934a12638.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/04211156ae7448358117bc45f49559d5.png
[af7753b4d1b747fba2d00459e710aee8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/755636d35ed14f079a0400281c2fe999.png
[4a7839c7ba424654bdd65aa75ce0334b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/0758e6a933324eaca157741414b8d5f8.png
[de72767c7fbb402b9ab11e13690e80ee.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/fad16f5d93f14a54aa5b90c1c3f668d0.png
[6bddca4cad044b1db5169a378836c6b6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/68b9a94342534ac3bd2126273412897f.png
[a5e180119e4d4373b08e2c2e07bc23bc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/8cfdb2c6d2104c83adb1b2001a49141a.png
[1c984304c4a64628af6d0d50fe7656f8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/dcd0a1a7364b4fbc97607aaf399a3f27.png
[6fffad624fa04b62bff90432b89e6954.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/12221f7dff48412d9a766d3f312ece4a.png
[3b09c5dfb8c84ef686894d7062b2293a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/d027fce6790d428391ca8cccd61f9f5f.png
[dab84dbd07f04da6b012fbf980359414.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/9111d4ee5bf6447b9eb8b67fd04afdfe.png