• SpringBoot+Dubbo+Nacos 开发实战教程

    本文来写个详细的例子来说下dubbo+nacos+springboot开发实战。本文不会讲述太多的理论的知识，会写一个最简单的例子来说明dubbo如何与nacos整合，快速搭建开发环境。

    文章目录

    • 环境准备

      • dubbo简介

      • Nacos环境准备

      • Nacos与dubbo整合

    • 项目管理规范

    • dubbo整合nacos案例

      • 创建公共接口模块

      • 创建服务提供者模块

      • 创建服务消费者模块

      • 服务调用测试

    • 本文小结

    环境准备

    dubbo简介

    dubbo核心节点之间的调用关系

    节点说明

    调用关系说明

    • 服务容器负责启动，加载，运行服务提供者。

    • 服务提供者在启动时，向注册中心注册自己提供的服务。

    • 服务消费者在启动时，向注册中心订阅自己所需的服务。

    • 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

    • 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

    • 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

    Nacos环境准备

    启动nacos，本文使用的是nacos1.4.3版本

    打开nacos的控制面板

    Nacos与dubbo整合

    为了方便大家理解，这里写出对应的生产方、消费方 Demo 代码，以及使用的注册中心。

    项目管理规范

    springboot，netflix和cloud alibaba之间有版本之间的对应关系，本文选择的版本如下

    dubbo和cloud alibaba之间有版本之间的对应关系，本文选择的版本如下

    为了后续方便使用SpringCloud Alibaba进行开发，首先创建一个pom类型的父项目，主要用于项目技术栈版本管理，创建一个maven项目，名称为spring-cloud-alibaba-example，去除src文件，修改pom文件

    1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0</modelVersion>
    6.  
    7.     <groupId>ah.wideth</groupId>
    8.     <artifactId>spring-cloud-alibaba-example</artifactId>
    9.     <version>1.0-SNAPSHOT</version>
    10.  
    11.     <parent>
    12.         <groupId>org.springframework.boot</groupId>
    13.         <artifactId>spring-boot-starter-parent</artifactId>
    14.         <version>2.3.12.RELEASE</version>
    15.         <relativePath/> <!-- lookup parent from repository -->
    16.     </parent>
    17.  
    18.     <packaging>pom</packaging>
    19.  
    20.     <properties>
    21.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    22.         <java.version>1.8</java.version>
    23.         <spring-cloud.version>Hoxton.SR12</spring-cloud.version>
    24.         <com-alibaba-cloud.version>2.2.7.RELEASE</com-alibaba-cloud.version>
    25.     </properties>
    26.  
    27.     <!--对项目版本进行管理-->
    28.     <dependencyManagement>
    29.         <dependencies>
    30.             <dependency>
    31.                 <groupId>org.springframework.cloud</groupId>
    32.                 <artifactId>spring-cloud-dependencies</artifactId>
    33.                 <version>${spring-cloud.version}</version>
    34.                 <type>pom</type>
    35.                 <scope>import</scope>
    36.             </dependency>
    37.  
    38.             <dependency>
    39.                 <groupId>com.alibaba.cloud</groupId>
    40.                 <artifactId>spring-cloud-alibaba-dependencies</artifactId>
    41.                 <version>${com-alibaba-cloud.version}</version>
    42.                 <type>pom</type>
    43.                 <scope>import</scope>
    44.             </dependency>
    45.         </dependencies>
    46.     </dependencyManagement>
    47. </project>

    后续创建的项目都放到此目录下，只需要声明groupId和artifactId，会自动引用父项目spring-cloud-alibaba-example的版本。与其说是父项目，不如说是根项目: 因为下面每学习一个新的技术，就会新建一个真正的父项目，而在对应的父项目下面又会创建许多的子项目

    dubbo整合nacos案例

    本文的案例是在上文nacos开发实例的基础之上继续编写的。下面开始创建我们的项目，贴上我的目录结构。

    模块说明

    • public-api公共接口模块（接口），供服务消费者和服务提供者调用。

    • dubbo-provider服务提供者模块（接口实现类），引入了public-api模块

    • dubbo-consumer服务消费者模块（controller），引入了public-api模块

    • 消费者和提供者通过公共接口模块进行rpc远程调用

    父工程pom文件

    1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.     <modelVersion>4.0.0</modelVersion>
    5.  
    6.     <parent>
    7.         <artifactId>spring-cloud-alibaba-example</artifactId>
    8.         <groupId>ah.wideth</groupId>
    9.         <version>1.0-SNAPSHOT</version>
    10.     </parent>
    11.  
    12.     <modules>
    13.         <module>public-api</module>
    14.         <module>dubbo-provider</module>
    15.         <module>dubbo-consumer</module>
    16.     </modules>
    17.  
    18.     <artifactId>dubbo-nacos-example</artifactId>
    19.     <name>dubbo-nacos-example</name>
    20.     <description>duboo与nacos整合的父工程</description>
    21.     <packaging>pom</packaging>
    22.  
    23.     <properties>
    24.         <java.version>1.8</java.version>
    25.         <project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
    26.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    27.         <dubbo.version>2.7.13</dubbo.version>
    28.         <nacos.version>1.4.1</nacos.version>
    29.     </properties>
    30.  
    31.  
    32.     <dependencies>
    33.  
    34.         <dependency>
    35.             <groupId>com.alibaba.cloud</groupId>
    36.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    37.             <!--解决nacos-client2.0报错的问题-->
    38.             <exclusions>
    39.                 <exclusion>
    40.                     <artifactId>nacos-client</artifactId>
    41.                     <groupId>com.alibaba.nacos</groupId>
    42.                 </exclusion>
    43.             </exclusions>
    44.         </dependency>
    45.  
    46.  
    47.         <!--dubbo相关-->
    48.         <dependency>
    49.             <groupId>org.apache.dubbo</groupId>
    50.             <artifactId>dubbo-spring-boot-starter</artifactId>
    51.             <version>${dubbo.version}</version>
    52.         </dependency>
    53.  
    54.         <dependency>
    55.             <groupId>org.apache.dubbo</groupId>
    56.             <artifactId>dubbo-registry-nacos</artifactId>
    57.             <version>${dubbo.version}</version>
    58.         </dependency>
    59.  
    60.         <dependency>
    61.             <groupId>com.alibaba.nacos</groupId>
    62.             <artifactId>nacos-client</artifactId>
    63.             <version>${nacos.version}</version>
    64.         </dependency>
    65.  
    66.         <!-- 解决dubbo2.7.13jar包冲突问题-->
    67.         <dependency>
    68.             <groupId>com.alibaba.spring</groupId>
    69.             <artifactId>spring-context-support</artifactId>
    70.             <version>1.0.11</version>
    71.         </dependency>
    72.  
    73.         <dependency>
    74.             <groupId>org.apache.dubbo</groupId>
    75.             <artifactId>dubbo</artifactId>
    76.             <version>${dubbo.version}</version>
    77.             <exclusions>
    78.                 <exclusion>
    79.                     <groupId>org.springframework</groupId>
    80.                     <artifactId>spring</artifactId>
    81.                 </exclusion>
    82.                 <exclusion>
    83.                     <groupId>javax.servlet</groupId>
    84.                     <artifactId>servlet-api</artifactId>
    85.                 </exclusion>
    86.                 <exclusion>
    87.                     <groupId>log4j</groupId>
    88.                     <artifactId>log4j</artifactId>
    89.                 </exclusion>
    90.             </exclusions>
    91.         </dependency>
    92.         
    93.     </dependencies>
    94.  
    95. </project>

    创建公共接口模块

    pom文件

    1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.     <modelVersion>4.0.0</modelVersion>
    5.  
    6.     <parent>
    7.         <artifactId>dubbo-nacos-example</artifactId>
    8.         <groupId>ah.wideth</groupId>
    9.         <version>1.0-SNAPSHOT</version>
    10.     </parent>
    11.  
    12.     <artifactId>public-api</artifactId>
    13.     <name>public-api</name>
    14.     <description>api公用接口</description>
    15.     <packaging>jar</packaging>
    16.  
    17.     <properties>
    18.         <java.version>1.8</java.version>
    19.         <project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
    20.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    21.     </properties>
    22.  
    23.     <dependencies>
    24.         <dependency>
    25.             <groupId>org.springframework.boot</groupId>
    26.             <artifactId>spring-boot-starter-web</artifactId>
    27.         </dependency>
    28.     </dependencies>
    29.  
    30.     <build>
    31.         <plugins>
    32.             <plugin>
    33.                 <groupId>org.springframework.boot</groupId>
    34.                 <artifactId>spring-boot-maven-plugin</artifactId>
    35.             </plugin>
    36.         </plugins>
    37.     </build>
    38.  
    39. </project>

    公共接口模块里面只有一个接口，没有配置文件，打jar包

    1. package ah.wideth.api;
    2.  
    3. /**
    4.  * 让生产者和服务消
    5.  * 费者来使用这个接口
    6.  */
    7. public interface InfoService {
    8.  
    9.     String getInfo();
    10. }

    创建服务提供者模块

    pom文件

    1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.     <modelVersion>4.0.0</modelVersion>
    5.  
    6.     <parent>
    7.         <artifactId>dubbo-nacos-example</artifactId>
    8.         <groupId>ah.wideth</groupId>
    9.         <version>1.0-SNAPSHOT</version>
    10.     </parent>
    11.  
    12.     <artifactId>dubbo-provider</artifactId>
    13.     <name>dubbo-provider</name>
    14.     <description>dubbo的服务提供者模块</description>
    15.  
    16.     <properties>
    17.         <java.version>1.8</java.version>
    18.         <project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
    19.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    20.     </properties>
    21.  
    22.     <dependencies>
    23.  
    24.         <dependency>
    25.             <groupId>org.springframework.boot</groupId>
    26.             <artifactId>spring-boot-starter-web</artifactId>
    27.         </dependency>
    28.  
    29.         <!--引入公共接口模块-->
    30.         <dependency>
    31.             <groupId>${project.groupId}</groupId>
    32.             <artifactId>public-api</artifactId>
    33.             <version>${project.version}</version>
    34.         </dependency>
    35.  
    36.     </dependencies>
    37.  
    38.     <build>
    39.         <plugins>
    40.             <plugin>
    41.                 <groupId>org.springframework.boot</groupId>
    42.                 <artifactId>spring-boot-maven-plugin</artifactId>
    43.             </plugin>
    44.         </plugins>
    45.     </build>
    46.  
    47. </project>

    application.yml配置文件

    1. server:
    2.   port: 8180
    3.  
    4. spring:
    5.   application:
    6.     name: dubbo-provider
    7.  
    8. dubbo:
    9.   registry:
    10.     address: nacos://127.0.0.1:8848 #注册地址
    11.   application:
    12.     name: dubbo-provider #应用名
    13.   protocol:
    14.     name: dubbo #dubbo协议
    15.     port: 20880 #协议端口
    16.   scan:
    17.     base-packages: ah.wideth.impl #扫包范围
    18.   provider:
    19.     timeout: 30000 #超时时间

    接口实现类，该类实现了上面我们在公共接口模块创建的接口

    1. package ah.wideth.impl;
    2.  
    3. import ah.wideth.api.InfoService;
    4. import org.apache.dubbo.config.annotation.DubboService;
    5. import org.springframework.stereotype.Component;
    6.  
    7.  
    8. // dubbo提供的Service注解，用于声明对外暴露服务
    9. // Service引入的是org.apache.dubbo.config.annotation.Service包
    10. @Component
    11. @DubboService
    12. public class InfoServiceImpl implements InfoService {
    13.  
    14.     @Override
    15.     public String getInfo() {
    16.  
    17.         return "hello，这里是dubbo-provider模块！";
    18.     }
    19. }

    服务提供者启动类

    1. package ah.wideth;
    2.  
    3. import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
    4. import org.springframework.boot.SpringApplication;
    5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    7.  
    8.  
    9. @EnableDubbo
    10. @EnableDiscoveryClient
    11. @SpringBootApplication
    12. public class DubboProviderApplication {
    13.  
    14.     public static void main(String[] args) {
    15.  
    16.         SpringApplication.run(DubboProviderApplication.class, args);
    17.         System.out.println("dubbo服务提供者8180启动了");
    18.     }
    19.  
    20. }

    创建服务消费者模块

    pom文件

    1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.     <modelVersion>4.0.0</modelVersion>
    5.  
    6.     <parent>
    7.         <artifactId>dubbo-nacos-example</artifactId>
    8.         <groupId>ah.wideth</groupId>
    9.         <version>1.0-SNAPSHOT</version>
    10.     </parent>
    11.  
    12.     <artifactId>dubbo-consumer</artifactId>
    13.     <name>dubbo-consumer</name>
    14.     <description>dubbo的服务消费者模块</description>
    15.  
    16.     <properties>
    17.         <java.version>1.8</java.version>
    18.         <project.build.sourceEncoding>utf-8</project.build.sourceEncoding>
    19.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    20.     </properties>
    21.  
    22.     <dependencies>
    23.  
    24.         <dependency>
    25.             <groupId>org.springframework.boot</groupId>
    26.             <artifactId>spring-boot-starter-web</artifactId>
    27.         </dependency>
    28.  
    29.         <!--引入公共接口模块-->
    30.         <dependency>
    31.             <groupId>${project.groupId}</groupId>
    32.             <artifactId>public-api</artifactId>
    33.             <version>${project.version}</version>
    34.         </dependency>
    35.  
    36.     </dependencies>
    37.  
    38.     <build>
    39.         <plugins>
    40.             <plugin>
    41.                 <groupId>org.springframework.boot</groupId>
    42.                 <artifactId>spring-boot-maven-plugin</artifactId>
    43.             </plugin>
    44.         </plugins>
    45.  
    46.     </build>
    47. </project>

    application.yml配置文件

    1. server:
    2.   port: 8181
    3.  
    4. spring:
    5.   application:
    6.     name: dubbo-consumer
    7.  
    8. dubbo:
    9.   registry:
    10.     address: nacos://127.0.0.1:8848 #注册地址
    11.   application:
    12.     name: dubbo-consumer #应用名
    13.   consumer:
    14.     timeout: 30000 #超时时间

    controller，调用公共接口模块创建的接口

    1. package ah.wideth.controller;
    2.  
    3. import ah.wideth.api.InfoService;
    4. import org.apache.dubbo.config.annotation.DubboReference;
    5. import org.springframework.web.bind.annotation.GetMapping;
    6. import org.springframework.web.bind.annotation.RestController;
    7.  
    8. @RestController
    9. public class InfoController {
    10.  
    11.     //dumbo提供的Reference注解，用于调用远程服务
    12.     @DubboReference(check = false)
    13.     private InfoService infoService;
    14.  
    15.     @GetMapping("/getInfo")
    16.     public String getInfo(){
    17.  
    18.         return infoService.getInfo();
    19.     }
    20. }

    服务消费者启动类

    1. package ah.wideth;
    2.  
    3. import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
    4. import org.springframework.boot.SpringApplication;
    5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    7.  
    8.  
    9. @EnableDubbo
    10. @EnableDiscoveryClient
    11. @SpringBootApplication
    12. public class DubboConsumerApplication {
    13.  
    14.     public static void main(String[] args) {
    15.  
    16.         SpringApplication.run(DubboConsumerApplication.class, args);
    17.         System.out.println("dubbo服务消费者8181启动了");
    18.     }
    19.  
    20. }

    服务调用测试

    打开Nacos控制面板查看注册中心中的服务

    启动nacos，启动服务提供者和服务消费者，调用服务消费者的getInfo方法，服务提供者会返回结果

  • 相关阅读:
    设计模式——装饰者模式、桥接模式、外观模式（结构型模式）
    深入探索JVM高效并发 — Java内存模型(三) 原子性、可见性与有序性
    软件工程——期末复习知识点汇总
    【教程】uni-app iOS打包解决profile文件与私钥证书不匹配问题
    图像处理之颜色特征描述
    项目人力资源管理
    学习css过渡动画-transition
    Django配置静态文件
    TensorFlow2从磁盘读取图片数据集的示例(tf.keras.utils.image_dataset_from_directory)
    电子标签模块：让传感器智能化，工程安全监测更便捷
  • 原文地址：https://blog.csdn.net/jianpengxuexikaifa/article/details/127378383