微服务 | Springboot整合Dubbo+Nacos实现RPC调用

官网：Apache Dubbo

随着互联网技术的飞速发展，越来越多的企业和开发者开始关注微服务架构。微服务架构可以将一个大型的应用拆分成多个独立、可扩展、可维护的小型服务，每个服务负责实现应用的一部分功能。这种架构方式可以提高开发效率，降低系统复杂度，方便团队协作，同时也有利于资源的合理利用和弹性伸缩。

在微服务架构中，服务之间的通信是一个关键问题。传统的HTTP通信方式在高并发、高性能的场景下存在性能瓶颈，因此，越来越多的开发者开始采用RPC（远程过程调用）技术来实现服务之间的通信。Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了丰富的服务治理功能，如服务注册、服务发现、负载均衡、容错等，被广泛应用于微服务架构中。

Nacos是阿里巴巴开源的一个动态服务发现、配置管理和服务管理平台，它支持基于DNS和基于RPC的服务发现，具有跨语言、跨平台、灵活扩展的特点。网上很多都是Springcloud整合Dubbo，本文讲解如何将Spring Boot与Dubbo和Nacos整合，实现RPC调用。

工作原理图

以上是 Dubbo 的工作原理图，从抽象架构上分为两层：服务治理抽象控制面 和 Dubbo 数据面 。

• 服务治理控制面。服务治理控制面不是特指如注册中心类的单个具体组件，而是对 Dubbo 治理体系的抽象表达。控制面包含协调服务发现的注册中心、流量管控策略、Dubbo Admin 控制台等，如果采用了 Service Mesh 架构则还包含 Istio 等服务网格控制面。
• Dubbo 数据面。 数据面代表集群部署的所有 Dubbo 进程，进程之间通过 RPC 协议实现数据交换，Dubbo 定义了微服务应用开发与调用规范并负责完成数据传输的编解码工作。
  • 服务消费者 (Dubbo Consumer)，发起业务调用或 RPC 通信的 Dubbo 进程
  • 服务提供者 (Dubbo Provider)，接收业务调用或 RPC 通信的 Dubbo 进程

快速上手

在实现DubboRPC服务调用时，我们首先需要一个服务注册中心，常用的服务注册中心有Zookeeper，Nacos等，我们这里采用Nacos，没有部署Nacos的请先自行教程部署，这里不细讲

1、环境搭建

创建基础项目父模块，再分别创建三个子模块（consumer、interface、provider）

2、导入依赖

1、父模块

    <properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><dubbo.version>3.2.0-beta.4</dubbo.version><spring-boot.version>2.6.11</spring-boot.version></properties><dependencyManagement><dependencies><!-- Spring Boot --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>${spring-boot.version}</version><type>pom</type><scope>import</scope></dependency><!--springcloudalibaba--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>2021.0.4.0</version><type>pom</type><scope>import</scope></dependency><!--nacos--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId><version>2021.0.4.0</version><type>pom</type><scope>import</scope></dependency><!-- Dubbo --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-bom</artifactId><version>${dubbo.version}</version><type>pom</type><scope>import</scope></dependency><!-- Dubbo --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>${dubbo.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

2、子模块

分别在consumer、provider导入依赖

    <dependencies><!-- Api接口 --><dependency><groupId>com.ruoyi</groupId><artifactId>interface</artifactId><version>1.0-SNAPSHOT</version></dependency><!-- dubbo --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId></dependency><!-- spring boot starter --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--Nacos--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency></dependencies>

3、配置文件

分别在consumer、provider编写配置文件

1、服务提供者（provider）

dubbo:application:name: Dubbo-provider  #Dubbo服务名称qos-enable: falseprotocol:name: dubbo  #协议名称port: -1  #端口号，-1表示自动分配registry:address: nacos://localhost:8848 #注册中心地址server:port: 9001
spring:application:name:   SpringBoot-Nacos-Dubbo-provider #Nacos注册中心服务名称

2、消费者（consumer）

dubbo:application:name: Dubbo-consumer  #Dubbo服务名称
#    qos-enable: falseprotocol:name: dubbo  #协议名称port: -1  #端口号，-1表示自动分配registry:address: nacos://localhost:8848 #注册中心地址server:port: 8082
spring:application:name:   SpringBoot-Nacos-Dubbo-consumer #Nacos注册中心服务名称

4、接口API

1、在interface模块中编写接口

/*** 在 DemoService 中，定义了 sayHello 这个方法。后续服务端发布的服务，消费端订阅的服务都是围绕着 DemoService 接口展开的*/
public interface DubboDemoService {String sayHello(String name);
}

2、在provider模块中编写实现类

/*** 定义了服务接口之后，可以在服务端这一侧定义对应的实现，这部分的实现相对于消费端来说是远端的实现，本地没有相关的信息。*/
@DubboService // 暴露服务  通过这个配置可以基于 Spring Boot 去发布 Dubbo 服务。
public class DubboDemoServiceImpl implements DubboDemoService {@Overridepublic String sayHello(String name) {System.err.println("服务提供者，我被Dobbo调用了");return "Hello" + name ;}
}

5、消费者(consumer)Controller

@RestController
@RequestMapping("/consumer")
public class ConsumerController {@DubboReferenceprivate DubboDemoService dubboDemoService;@GetMapping("/test")public String test(){return dubboDemoService.sayHello("微服务 SpringBoot整合Nacos+Dubbo");}
}

6、启动类

分别在consumer、provider编写配置启动类，并且启动项目

1、consumer

@SpringBootApplication
@EnableDubbo
public class ConsumerApplication_8082 {public static void main(String[] args) {SpringApplication.run(ConsumerApplication_8082.class,args);}
}

2、provider

@SpringBootApplication
@EnableDubbo
public class ProviderApplication_9001 {public static void main(String[] args) {SpringApplication.run(ProviderApplication_9001.class,args);}
}

启动服务提供者和消费者

浏览器访问消费者中的Controller localhost:8082/consumer/test