Springboot整合Dubbo+Nacos實現(xiàn)RPC調(diào)用的示例代碼

更新時間：2024年02月19日 09:45:38 作者：牽著貓散步的鼠鼠

隨著互聯(lián)網(wǎng)技術(shù)的飛速發(fā)展,越來越多的企業(yè)和開發(fā)者開始關(guān)注微服務架構(gòu),Nacos是阿里巴巴開源的一個動態(tài)服務發(fā)現(xiàn)、配置管理和服務管理平臺,本文講解如何將Spring Boot與Dubbo和Nacos整合,實現(xiàn)RPC調(diào)用,需要的朋友可以參考下

前言

隨著互聯(lián)網(wǎng)技術(shù)的飛速發(fā)展，越來越多的企業(yè)和開發(fā)者開始關(guān)注微服務架構(gòu)。微服務架構(gòu)可以將一個大型的應用拆分成多個獨立、可擴展、可維護的小型服務，每個服務負責實現(xiàn)應用的一部分功能。這種架構(gòu)方式可以提高開發(fā)效率，降低系統(tǒng)復雜度，方便團隊協(xié)作，同時也有利于資源的合理利用和彈性伸縮。

在微服務架構(gòu)中，服務之間的通信是一個關(guān)鍵問題。傳統(tǒng)的HTTP通信方式在高并發(fā)、高性能的場景下存在性能瓶頸，因此，越來越多的開發(fā)者開始采用RPC（遠程過程調(diào)用）技術(shù)來實現(xiàn)服務之間的通信。Dubbo是一款高性能、輕量級的開源Java RPC框架，它提供了豐富的服務治理功能，如服務注冊、服務發(fā)現(xiàn)、負載均衡、容錯等，被廣泛應用于微服務架構(gòu)中。

Nacos是阿里巴巴開源的一個動態(tài)服務發(fā)現(xiàn)、配置管理和服務管理平臺，它支持基于DNS和基于RPC的服務發(fā)現(xiàn)，具有跨語言、跨平臺、靈活擴展的特點。網(wǎng)上很多都是Springcloud整合Dubbo，本文講解如何將Spring Boot與Dubbo和Nacos整合，實現(xiàn)RPC調(diào)用。

快速上手

在實現(xiàn)DubboRPC服務調(diào)用時，我們首先需要一個服務注冊中心，常用的服務注冊中心有Zookeeper，Nacos等，我們這里采用Nacos，沒有部署Nacos的請先自行教程部署，這里不細講

創(chuàng)建示例項目

我們這里創(chuàng)建兩個名為ProviderDemo和ConsumerDemo的項目

導入依賴

整合nacos和dubbo主要需要nacos-client和dubbo這兩項依賴

        <!--這里對應的Springboot版本為2.7.6-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>3.0.9</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>2.1.0</version>
        </dependency>

ProviderDemo的maven配置信息如下

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.luckysj</groupId>
    <artifactId>ProviderDemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>ProviderDemo</name>
    <description>ProviderDemo</description>
    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-boot.version>2.7.6</spring-boot.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>3.0.9</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>2.1.0</version>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
 
 
</project>

ConsumerDemo的配置信息如下

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.luckysj</groupId>
    <artifactId>ConsumerDemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>ConsumerDemo</name>
    <description>ConsumerDemo</description>
    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <spring-boot.version>2.7.6</spring-boot.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>3.0.9</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>2.1.0</version>
        </dependency>
 
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
 
</project>

編寫配置

consumerDemo項目的配置如下，注意把nacos信息更改為自己的

server:
  port: 7777
 
dubbo:
  application:
    #設置應用的名稱
    name: dubbo-springboot-consumer
    #qos監(jiān)控服務是否啟動
    qos-enable: true
    #qos監(jiān)控服務端口
    qos-port: 23456
    qos-accept-foreign-ip: false
 
  #指定使用Dubbo協(xié)議，且端口設置為-1，表示隨機分配可用端口
  protocol:
    name: dubbo
    port: -1
  registry:
    #配置注冊中心為Nacos
    id: nacos-registry
    address: nacos://nacos服務的ip:nacos服務的端口
    username: nacos賬戶
    password: nacos密碼
    parameters:
      namespace: f74484c1-02d8-4322-a50c-630bc814fe54   #nacos命名空間
    group: dubbo-demo    #nacos分組
  config-center:
    timeout: 40000 #設置服務超時時間

providerDemo項目的配置如下

server:
  port: 6666
dubbo:
  application:
    #設置應用的名稱
    name: dubbo-springboot-provider
    qos-enable: true
    qos-port: 23444
    qos-accept-foreign-ip: false
  #指定使用Dubbo協(xié)議，且端口設置為-1，表示隨機分配可用端口
  protocol:
    name: dubbo
    port: -1
  registry:
    #配置注冊中心為Nacos
    id: nacos-registry
    address: nacos://ip:端口
    username: 賬戶
    password: 密碼
    parameters:
      namespace: f74484c1-02d8-4322-a50c-630bc814fe54   #nacos命名空間
    group: dubbo-demo    #nacos分組
  config-center:
    timeout: 40000 #設置服務超時時間

添加啟動類注解

我們要使用Dubbo服務的話需要在服務啟動類上編寫@EnableDubbo注解（提供者項目和消費者項目都需要）

編寫服務接口與服務實現(xiàn)類

我們在Provider項目中provider包下新建服務接口與實現(xiàn)類

PrintService接口內(nèi)容如下

public interface PrintService {
    public void print(String str);
}

PrintServiceImpl接口內(nèi)容如下，我們通過@DubboService注解暴露該服務，

@DubboService
public class PrintServiceImpl implements PrintService {
 
    @Override
    public void print(String str) {
        System.out.println("dubbo調(diào)用打印信息為" + str);
    }
}

在服務消費方項目中也定義相同的接口

public interface PrintService {
    public void print(String str);
}

特別注意這里調(diào)用者與提供者的服務接口需要有相同的包路徑，否則無法找到對應服務，我們后續(xù)通過引入一個common項目來解決這個問題

在服務消費方項目編寫一個測試接口，使用@DubboReference注解聲明引用的服務

@RestController
@RequestMapping("/demo")
public class DemoController {
    @DubboReference //聲明服務引用
    private PrintService printService;
 
    @GetMapping("/test")
    public void testDubbo(String str){
        System.out.println("consumer開始RPC調(diào)用provider服務");
        printService.print(str);
    }
}

訪問接口，測試兩項目之間的服務調(diào)用，可以看到我們ConsumerDemo項目通過Dubbo成功的調(diào)用了ProviderDemo項目

http://localhost:7777/demo/test?str=111

引入common項目

我們上面可以發(fā)現(xiàn)提供者和消費者的服務接口必須在相同的包路徑下，十分的不優(yōu)雅，故我們可以新建一個common項目，在這個項目中定義雙方服務調(diào)用的接口，相當于定義了一種規(guī)范，兩邊都采用common中的服務接口，這樣就不會因為包路徑不同導致dubbo找不到對應服務