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

小鱼儿 2024-03-30 12:32 122阅读 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

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

1.2 安装

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














变量名 变量值
ZOOKEEPER_HOME D:\Program Files\apache-zookeeper-3.6.3-bin

在这里插入图片描述
path中引入zookeeper

  1. %ZOOKEEPER_HOME%\bin
  2. %ZOOKEEPER_HOME%\conf

在这里插入图片描述

1.3 修改配置文件

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

  1. dataDir=D:\\azookerpersstudy\\data
  2. dataLogDir=D:\\azookerpersstudy\\log

1.4 启动

在zookeeper下的bin目录下
点击zkservice.cmd
在这里插入图片描述
在这里插入图片描述

二、Dubbo插件搭建

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

三、手动创建

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

3.1 创建项目

选择maven，创建父项目dubbo_demo
在这里插入图片描述

3.1.1 pom依赖

  1. <groupId>com.tung</groupId>
  2.     <artifactId>dubbo_demo</artifactId>
  3.     <packaging>pom</packaging>
  4.     <version>1.0-SNAPSHOT</version>
  6.     <!-- 此处是springboot的父工程，用于指定springboot 版本 -->
  7.     <parent>
  8.         <groupId>org.springframework.boot</groupId>
  9.         <artifactId>spring-boot-starter-parent</artifactId>
  10.         <version>2.7.3</version>
  11.         <relativePath/> <!-- lookup parent from repository -->
  12.     </parent>
  14.     <!-- 统一版本管理 -->
  15.     <properties>
  16.         <maven.compiler.source>8</maven.compiler.source>
  17.         <maven.compiler.target>8</maven.compiler.target>
  18.         <java.version>1.8</java.version>
  19.         <zk.version>3.6.2</zk.version>
  20.         <dubbo.version>2.7.7</dubbo.version>
  21.         <curator.framework.version>5.1.0</curator.framework.version>
  22.         <curator.recipes.version>5.1.0</curator.recipes.version>
  23.     </properties>
  25.     <dependencyManagement>
  26.         <dependencies>
  27.             <dependency>
  28.                 <groupId>org.apache.dubbo</groupId>
  29.                 <artifactId>dubbo-spring-boot-starter</artifactId>
  30.                 <version>${dubbo.version}</version>
  31.             </dependency>
  33.             <dependency>
  34.                 <groupId>org.apache.zookeeper</groupId>
  35.                 <artifactId>zookeeper</artifactId>
  36.                 <version>${zk.version}</version>
  37.             </dependency>
  39.             <dependency>
  40.                 <groupId>org.apache.curator</groupId>
  41.                 <artifactId>curator-framework</artifactId>
  42.                 <version>${curator.framework.version}</version>
  43.             </dependency>
  44.             <dependency>
  45.                 <groupId>org.apache.curator</groupId>
  46.                 <artifactId>curator-recipes</artifactId>
  47.                 <version>${curator.recipes.version}</version>
  48.             </dependency>
  49.         </dependencies>
  50.     </dependencyManagement>

3.2 api模块

创建dubbo_api模块
在这里插入图片描述
api模块提供接口和实体类
在这里插入图片描述

3.2.1 pom依赖

  1. <parent>
  2.         <artifactId>dubbo_demo</artifactId>
  3.         <groupId>com.tung</groupId>
  4.         <version>1.0-SNAPSHOT</version>
  5.     </parent>
  6.     <modelVersion>4.0.0</modelVersion>
  8.     <artifactId>dubbo_api</artifactId>
  10.     <name>dubbo_api</name>
  11.     <!-- FIXME change it to the project's website -->
  12.     <url>http://www.example.com</url>
  14.     <properties>
  15.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  16.         <maven.compiler.source>1.7</maven.compiler.source>
  17.         <maven.compiler.target>1.7</maven.compiler.target>
  18.     </properties>

3.2.2 实体类

  1. package com.tung.entity;
  3. import java.io.Serializable;
  5. /**
  6.  * @author tung
  7.  * @ClassName User
  8.  * @Description 类的说明
  9.  * @date 2022/12/29
  10.  */
  11. public class User implements Serializable {
  14.     private  String id;
  15.     private String name;
  16.     private String password;
  19.     public User(String id, String name, String password) {
  21.         this.id = id;
  22.         this.name = name;
  23.         this.password = password;
  24.     }
  26.     public User() {
  28.     }
  30.     public String getId() {
  32.         return id;
  33.     }
  35.     public void setId(String id) {
  37.         this.id = id;
  38.     }
  40.     public String getName() {
  42.         return name;
  43.     }
  45.     public void setName(String name) {
  47.         this.name = name;
  48.     }
  50.     public String getPassword() {
  52.         return password;
  53.     }
  55.     public void setPassword(String password) {
  57.         this.password = password;
  58.     }
  59. }

3.2.3 service接口

  1. package com.tung.service;
  3. import com.tung.entity.User;
  5. import java.util.List;
  7. /**
  8.  * @author tung
  9.  * @ClassName UserService
  10.  * @Description 类的说明
  11.  * @date 2022/12/29
  12.  */
  13. public interface UserService {
  16.     List<User> findAll();
  17. }

3.3 provider

创建dubbo_provider，操作跟dubbo_api一样。

3.3.1 pom依赖

  1. <parent>
  2.         <artifactId>dubbo_demo</artifactId>
  3.         <groupId>com.tung</groupId>
  4.         <version>1.0-SNAPSHOT</version>
  5.     </parent>
  6.     <modelVersion>4.0.0</modelVersion>
  8.     <artifactId>dubbo_provider</artifactId>
  10.     <name>dubbo_provider</name>
  11.     <!-- FIXME change it to the project's website -->
  12.     <url>http://www.example.com</url>
  14.     <properties>
  15.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  16.         <maven.compiler.source>1.7</maven.compiler.source>
  17.         <maven.compiler.target>1.7</maven.compiler.target>
  18.     </properties>
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter-web</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter</artifactId>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.apache.zookeeper</groupId>
  31.             <artifactId>zookeeper</artifactId>
  32.         </dependency>
  34.         <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework -->
  35.         <!-- zookeeper和dubbo的集成包 -->
  36.         <dependency>
  37.             <groupId>org.apache.curator</groupId>
  38.             <artifactId>curator-framework</artifactId>
  39.         </dependency>
  40.         <!-- zookeeper和dubbo的集成包 -->
  41.         <dependency>
  42.             <groupId>org.apache.curator</groupId>
  43.             <artifactId>curator-recipes</artifactId>
  44.         </dependency>
  46.         <!-- 刚刚创建的api接口模块 -->
  47.         <dependency>
  48.             <groupId>com.tung</groupId>
  49.             <artifactId>dubbo_api</artifactId>
  50.             <version>1.0-SNAPSHOT</version>
  51.         </dependency>
  52.         <!--dubbo启动-->
  53.         <dependency>
  54.             <groupId>org.apache.dubbo</groupId>
  55.             <artifactId>dubbo-spring-boot-starter</artifactId>
  56.         </dependency>
  57.         <!--mybatis-->
  58.         <dependency>
  59.             <groupId>org.mybatis.spring.boot</groupId>
  60.             <artifactId>mybatis-spring-boot-starter</artifactId>
  61.             <version>1.3.2</version>
  62.         </dependency>
  63.         <!--mysql-connector-java-->
  64.         <dependency>
  65.             <groupId>mysql</groupId>
  66.             <artifactId>mysql-connector-java</artifactId>
  67.             <scope>runtime</scope>
  68.         </dependency>
  69.     </dependencies>

3.3.2 配置文件

application.yml

  1. server:
  2.   port: 8082
  4. # 注册中心 zookeeper的地址
  5. dubbo:
  6.   registry:
  7.     address: zookeeper://127.0.0.1:2181
  8.     timeout: 20000
  10.   application:
  11.     name: dubbo-provider
  13.   scan:
  14.     base-packages: com.tung
  16.   protocol:
  17.     name: dubbo
  18.     port: 20880
  20. mybatis:
  21.   config-location: classpath:mybatis-config.xml
  23. spring:
  24.   datasource:
  25.     name : test
  26.     url : jdbc:mysql://127.0.0.1:3306/demo?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true
  27.     username : root
  28.     password: root
  29.     driver-class-name: com.mysql.cj.jdbc.Driver

mybatis-config.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE configuration
  3.         PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  4.         "http://mybatis.org/dtd/mybatis-3-config.dtd">
  5. <configuration>
  6.     <settings>
  7.         <!-- Globally enables or disables any caches configured in any mapper under this configuration -->
  8.         <setting name="cacheEnabled" value="true"/>
  9.         <!-- Sets the number of seconds the driver will wait for a response from the database -->
  10.         <setting name="defaultStatementTimeout" value="3000"/>
  11.         <!-- Enables automatic mapping from classic database column names A_COLUMN to camel case classic Java property names aColumn -->
  12.         <setting name="mapUnderscoreToCamelCase" value="true"/>
  13.         <!-- Allows JDBC support for generated keys. A compatible driver is required.
  14.         This setting forces generated keys to be used if set to true,
  15.          as some drivers deny compatibility but still work -->
  16.         <setting name="useGeneratedKeys" value="true"/>
  17.     </settings>
  18.     <!-- Continue going here -->
  19. </configuration>

3.3.3 mapper

  1. package com.tung.mapper;
  3. import com.tung.entity.User;
  4. import org.apache.ibatis.annotations.Mapper;
  5. import org.apache.ibatis.annotations.Select;
  7. import java.util.List;
  9. /**
  10.  * @author tung
  11.  * @ClassName UserMapper
  12.  * @Description 类的说明
  13.  * @date 2022/12/29
  14.  */
  15. @Mapper
  16. public interface UserMapper {
  19.     @Select("select id,name,password from t_user")
  20.     List<User> findAll();
  21. }

3.3.4 service实现类

  1. package com.tung.service.impl;
  3. import com.tung.entity.User;
  4. import com.tung.mapper.UserMapper;
  5. import com.tung.service.UserService;
  6. import org.apache.dubbo.config.annotation.DubboService;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.stereotype.Component;
  10. import java.util.ArrayList;
  11. import java.util.List;
  13. /**
  14.  * @author tung
  15.  * @ClassName UserServiceImpl
  16.  * @Description 类的说明
  17.  * @date 2022/12/29
  18.  */
  19. @Component
  20. @DubboService(loadbalance = "roundrobin")
  21. public class UserServiceImpl implements UserService {
  24.     @Autowired
  25.     private UserMapper userMapper;
  27.     @Override
  28.     public List<User> findAll() {
  30.         return userMapper.findAll();
  31.     }
  32. }

3.3.5 启动类

  1. package com.tung.service;
  3. import org.mybatis.spring.annotation.MapperScan;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  7. /**
  8.  * @author tung
  9.  * @ClassName ProviderApplication
  10.  * @Description 类的说明
  11.  * @date 2022/12/29
  12.  */
  13. @SpringBootApplication
  14. @MapperScan("com.tung.mapper")
  15. public class ProviderApplication {
  18.     public static void main(String[] args){
  20.         SpringApplication.run(ProviderApplication.class,args);
  21.     }
  22. }

3.4 consumer

创建dubbo_consumer
在这里插入图片描述

3.4.1 pom依赖

  1. <parent>
  2.         <artifactId>dubbo_demo</artifactId>
  3.         <groupId>com.tung</groupId>
  4.         <version>1.0-SNAPSHOT</version>
  5.     </parent>
  6.     <modelVersion>4.0.0</modelVersion>
  8.     <artifactId>dubbo_consumer</artifactId>
  9.     <packaging>war</packaging>
  11.     <name>dubbo_consumer Maven Webapp</name>
  12.     <!-- FIXME change it to the project's website -->
  13.     <url>http://www.example.com</url>
  15.     <properties>
  16.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  17.         <maven.compiler.source>1.7</maven.compiler.source>
  18.         <maven.compiler.target>1.7</maven.compiler.target>
  19.     </properties>
  21.     <dependencies>
  22.         <dependency>
  23.             <groupId>com.tung</groupId>
  24.             <artifactId>dubbo_api</artifactId>
  25.             <version>1.0-SNAPSHOT</version>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.apache.dubbo</groupId>
  29.             <artifactId>dubbo-spring-boot-starter</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter</artifactId>
  34.         </dependency>
  35.         <dependency>
  36.             <groupId>org.apache.curator</groupId>
  37.             <artifactId>curator-framework</artifactId>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.apache.curator</groupId>
  41.             <artifactId>curator-recipes</artifactId>
  42.         </dependency>
  43.         <dependency>
  44.             <groupId>org.apache.zookeeper</groupId>
  45.             <artifactId>zookeeper</artifactId>
  47.         </dependency>
  48.         <dependency>
  49.             <groupId>org.springframework.boot</groupId>
  50.             <artifactId>spring-boot-starter-web</artifactId>
  51.         </dependency>
  54.     </dependencies>

3.4.2 配置文件

application.yml

  1. server:
  2.   port: 8083
  4. # 注册中心 zookeeper的地址
  5. dubbo:
  6.   registry:
  7.     address: zookeeper://127.0.0.1:2181
  8.     timeout: 20000
  10.   application:
  11.     name: dubbo-consumer
  13.   scan:
  14.     base-packages: com.tung.controller
  16.   protocol:
  17.     name: dubbo-consumer
  18.     port: 20881

3.4.3 控制层

  1. package com.tung.controller;
  3. import com.tung.entity.User;
  4. import com.tung.service.UserService;
  5. import org.apache.dubbo.config.annotation.DubboReference;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  10. import java.util.List;
  12. /**
  13.  * @author tung
  14.  * @ClassName UserController
  15.  * @Description 类的说明
  16.  * @date 2022/12/29
  17.  */
  18. @RestController
  19. @RequestMapping("/user")
  20. public class UserController {
  23.     @DubboReference
  24.     private UserService userService;
  26.     @GetMapping("/findAll")
  27.     public List<User> findAll(){
  29.         return userService.findAll();
  30.     }
  31. }

3.4.4 启动类

  1. package com.tung;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. /**
  7.  * @author tung
  8.  * @ClassName ConsumerApplication
  9.  * @Description 类的说明
  10.  * @date 2022/12/28
  11.  */
  12. @SpringBootApplication
  13. public class ConsumerApplication {
  16.     public static void main(String[] args){
  18.         SpringApplication.run(ConsumerApplication.class,args);
  19.     }
  20. }

四、测试

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

发表评论

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

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

相关阅读

    相关 Dubbo 入门搭建

    一、背景与架构(摘自官网) 随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不

    青旅半醒青旅半醒/ 0 赞/ 120 阅读

    相关 Dubbo - Dubbo框架搭建

    简单说明 Dubbo是一个基于RPC协议的分布式框架，RPC的全称为Remote Procedure Call，其目的为实现远程调用。而分布式的目的是为了能够更好的针对不

    灰太狼灰太狼/ 0 赞/ 428 阅读

    相关 dubbo入门教程-从零搭建dubbo服务

    【原创 转载请注明出处】 本文是学习了dubbo之后自己手动写的，比较通俗，很多都是自己学习之后的理解，写的过程中没有参考任何文章。 另外dubbo也有官方文档，但是比较官

    蔚落蔚落/ 0 赞/ 451 阅读