devbox
AllinToyou
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

SpringBoot+Dubbo+Nacos 开发实战教程_springboot+nacos+double

作者：AllinToyou | 2024-02-29 12:43:07

赞

踩

springboot+nacos+double

本文来写个详细的例子来说下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方法，服务提供者会返回结果

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/AllinToyou/article/detail/165640
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号