技術文章 » 搭建SpringCloud-Alibaba框架

搭建SpringCloud-Alibaba框架

2020-10-15 14:00:41

簡介

搭建基於SpringcloudAlibaba的分散式框架，註冊中心以及服務消費訂閱採用的是中介軟體 Nacos作為實現，服務與服務之間的呼叫採用的是dubbo的rpc協定，各模組通過 Nacos進行統一的設定管理(通過Nacos做設定中心)，當並行進行http介面呼叫時，則是採用中介軟體Sentinel進行服務限流以及服務降級，http請求響應資料則是從資料庫 mysql 中獲取，最後通過springcloud的外掛gateway進行路由轉發。本篇將略微有點長，請耐心看完。

專案地址：https://gitee.com/wangwenlongGitHub/SpringCloudAlibaba-practice.git

Nacos、Sentinel安裝與簡介：https://blog.csdn.net/qq_42227281/article/details/109074957

工程搭建：

1：父工程及子工程

1、建立一個Maven專案作為父工程

src等沒用的檔案直接刪除，只留關鍵的pom即可

2、建立子工程(maven工程)alibaba-module、alibaba-server、alibaba-common

src等沒用的檔案直接刪除，只留關鍵的pom即可

3、alibaba-module--Pom檔案

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>SpringCloudAlibaba-practice</artifactId>
        <groupId>com.jingshang</groupId>
        <version>1.0</version>
    </parent>

    <artifactId>alibaba-module</artifactId>
    <packaging>pom</packaging>
    <description>module模組</description>

    <modules>
        <module>admin-user-biz</module>
        <module>admin-user-api</module>
        <module>admin-role-api</module>
        <module>admin-role-biz</module>
    </modules>
</project>

alibaba-module子工程：我用它來管理api介面、http介面

4、alibaba-server--Pom檔案

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.jingshang</groupId>
    <artifactId>alibaba-server</artifactId>
    <packaging>pom</packaging>
    <version>1.0</version>

    <modules>
        <module>alibaba-gateway-server</module>
    </modules>
</project>

alibaba-server子工程：我用它來管理路由轉發、服務降級、限流等功能模組

 

5、alibaba-common--Pom檔案

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>SpringCloudAlibaba-practice</artifactId>
        <groupId>com.jingshang</groupId>
        <version>1.0</version>
    </parent>

    <artifactId>alibaba-common</artifactId>
    <packaging>pom</packaging>
    <description>common模組</description>

    <modules>
        <module>common-core</module>
        <module>common-code-generation</module>
    </modules>


</project>

alibaba-common子工程：我通常用來整合安全框架、程式碼生成等公共功能模組

2：整合Nacos註冊中心、服務提供者、設定中心。整合sentinel

服務提供者

在alibaba-module工程中中建立 admin-user-api、admin-user-biz等子工程

說明：api為對外開放的介面、biz為http介面，通俗的講就是postman可呼叫的介面。遠端呼叫我是用的dubbo的rpc協定來替代feign和ribbon

1、建立 admin-user-api 模組：右鍵alibaba-module->new->module->建立maven專案

構建Pom：pom

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>alibaba-module</artifactId>
        <groupId>com.jingshang</groupId>
        <version>1.0</version>
    </parent>


    <artifactId>admin-user-api</artifactId>
    <packaging>jar</packaging>
    <description>user模組</description>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>


</project>

2、建立 admin-user-biz 模組：右鍵alibaba-module->new->module->建立springboot專案

構建Pom：pom

<?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.jingshang</groupId>
    <artifactId>admin-user-biz</artifactId>
    <version>1.0</version>
    <packaging>jar</packaging>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <!-- 引入Api -->
        <dependency>
            <groupId>com.jingshang</groupId>
            <artifactId>admin-user-api</artifactId>
            <version>1.0</version>
        </dependency>
        <!-- 公共Api-->
        <dependency>
            <groupId>com.jingshang</groupId>
            <artifactId>common-core</artifactId>
            <version>1.0</version>
        </dependency>
        <!-- mysql -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <!-- mybatis -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.3</version>
        </dependency>
        <!-- 必須包含spring-boot-starter-actuator包，不然啟動會報錯。 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!-- web 應用 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- 設定中心所需jar包 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <!-- 整合的dubbo -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
        <!-- 整合的nacos -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- sentinel -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <!-- lombok -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.2</version>
            <optional>true</optional>
        </dependency>
        <!--  junit 測試所需的jar包 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>0.2.2.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.properties設定

spring.application.name=admin-user-biz
server.port=8001
# sentinel dashboard
spring.cloud.sentinel.transport.dashboard=10.10.10.244:8888
#nacos 註冊中心
spring.cloud.nacos.discovery.server-addr=localhost:8848
spring.cloud.nacos.discovery.namespace=dddf9ef6-638a-42fa-9b82-9c61a944f6cc
#spring.cloud.nacos.discovery.cluster‐name=DEFAULT_GROUP
# dubbo 服務
dubbo.scan.base-packages=com.jingshang.adminuserbiz.service
dubbo.protocol.name=dubbo
dubbo.protocol.port=20881
dubbo.registry.address=spring-cloud://localhost
#訂閱 (意思是呼叫哪個web服務的介面)
#dubbo.cloud.subscribed-services=admin-user-biz
#mysql紀錄檔
logging.level.com.jingshang.adminuserbiz.dao=debug

注：mysql設定到了nacos中，application.properties中就不再重複寫mysql的連線了，如何將mysql設定到nacos中請繼續往下看

 

說明：application.properties中設定了nacos註冊中心、sentinel流量防衛兵等基本設定、rpc遠端呼叫協定【dubbo】

重點：當你設定了dubbo之後，Service層的註解要使用 dubbo的@Service註解，當你非要使用 @org.springframework.stereotype.Service的 @Service註解時，請一定保證當前服務沒有被其他服務遠端呼叫。否則呼叫此服務的服務消費者啟動時將會丟擲【No provider available for the service 】 翻譯過來就是：沒有提供該服務的提供商

2.1、構建nacos設定中心

①登入：預設賬號密碼都是 nacos。地址：http://localhost:8848/nacos

②進去後選擇：【服務管理】-->【名稱空間】-->【點選右上角：新建名稱空間】

效果圖：

④新增設定資訊：選擇列表頁的 【設定管理】-->【選擇上方剛建立的dev名稱空間】-->【點選右上方的 + 號】Id、group、設定內容為必填資訊。 配合格式我springboot專案中用的是properties，所以這裡選properties就可以了，主要是和程式碼的組態檔字尾保持一致即可

我這裡只配了 資料庫，各位小夥伴根據自己實際情況做設定​​​​​​​

⑤bootstrap.properties拉取設定中心資訊的設定

#設定中心
spring.cloud.nacos.config.server-addr=localhost:8848
spring.cloud.nacos.config.prefix=alibaba-admin-database
spring.cloud.nacos.config.group=DEFAULT_DATABASE
spring.cloud.nacos.config.file-extension=properties
spring.cloud.nacos.config.namespace=dddf9ef6-638a-42fa-9b82-9c61a944f6cc
# 修改nacos紀錄檔列印級別，不修改的話，設定資訊一直重新整理
logging.level.com.alibaba.nacos:warn

yaml格式

logging:
  level:
    com:
      alibaba:
        nacos: warn
spring:
  cloud:
    nacos:
      config:
        file-extension: properties
        group: DEFAULT_DATABASE
        namespace: dddf9ef6-638a-42fa-9b82-9c61a944f6cc
        prefix: alibaba-admin-database
        server-addr: localhost:8848

bootstrap.properties的屬性與nacos的對應關係

說明：為什麼這裡要建立兩個組態檔，為什麼不直接在application.properties中設定所有所需資訊呢。這是因為nacos做設定中心的時候，預設支援的是bootstrap，而不是application，不這麼做的話， 你的設定就算寫的再好，也不會將其放到nacos中做設定中心的，而且會導致啟動找不到設定而報錯

重點：bootstrap.properties通過namespace【namespace的指向是名稱空間，如果不寫的話，預設去找public名稱空間，但是這樣的話，設定就找不到了(我們在設定中心設定的資料庫資訊)】和prefix【prefix它指定的設定的Id】，通過這兩個屬性，使得組態檔 能精準的找到屬於我們自己的設定資訊

⑥nacos多配製

前提：需要有一個預設設定，該預設設定需要指定【名稱空間：namespace、nacos地址：server-addr】

多配製：當你需要從nacos設定中心拉取多個設定時，應該在bootstrap.properties組態檔中設定【data-id、group】如下圖圈紅的位置

⑦ 如需多配製請在bootstrap.properties中這麼寫：

spring.cloud.nacos.config.ext-config[0].data-id=alibaba-admin-database.properties

spring.cloud.nacos.config.ext-config[0].group=DEFAULT_DATABASE

yaml格式

spring:
  cloud:
    nacos:
      config:
        ext-config:
        - data-id: alibaba-admin-database.properties
          group: DEFAULT_DATABASE

重點：值得注意的是data-id 一定要加擴充套件名，當你不加它的時候，系統還是會提醒你，讓你選擇一個合適的擴充套件名，至於為什麼系統會這麼貼心的告訴你呢？ 那是因為它報錯給我們了 【 報錯資訊：must contains file extension with properties|yaml|yml 】

誤區：ext-config[0]我當時在想為什麼是【0】,如果沒有【0】的情況下，我可不可以直接寫【1】百思不得其解，但是當我看到原始碼的時候我才突然恍然大悟

/**
 * 一組擴充套件設定
 */
private List<Config> extConfig;

這個設定的容器是List，而List索引必須從0開始，所以當你需要多配製的時候，要從0開始，然後才是1、2、3

設定好後啟動檢視控制檯紀錄檔輸出，如下圖：載入了兩個設定

⑧啟動類新增註解

@MapperScan(basePackages = {"com.jingshang.adminuserbiz.dao"})
@EnableDiscoveryClient//將服務註冊到註冊中心
@SpringBootApplication
public class AdminUserBizApplication {

    public static void main(String[] args) {
        SpringApplication.run(AdminUserBizApplication.class, args);
    }

}

2.1：編寫http介面、並進行流控及降級

①Mapper層省略、寫sql語句的時候，啟動類記得掃描喲或者在Mapper層加註解

②Service層：介面寫在 admin-user-api 裡面，如下圖

介面方法：String findByName(Integer id); id查詢返回名稱，這方法名起的不咋地，能懂意思就行哈，不要太在意我起的名字​​​​​​​

③Service實現類：該實現類放在 admin-user-biz 裡面。如下圖。如果不明白api、zip的區別，請往上看，上面有說明。​​​​​​​

④介面方法：

@Slf4j
@Service
public class UserServiceImpl implements UserDubboService {


    @Resource
    private UserDao sysUserDao;

    @SentinelResource(value = "user/findByName", blockHandler = "exceptionHandler")
    @Override
    public String findByName(Integer id) {
        return sysUserDao.findByName(id);
    }
}

重點：

 

1、@Service註解使用 dubbo的註解，且一定要實現介面

2、@SentinelResource它是sentinel的註解(用於服務限流、降級、服務熔斷)

用於定義資源，並提供可選的例外處理和 fallback 設定項。

@SentinelResource 註解包含以下屬性：

value：資源名稱，必需項（不能為空）

entryType：entry 型別，可選項（預設為EntryType.OUT）

blockHandler(命名塊的異常功能) 、 blockHandlerClass (指定自定義限流及降級的類)

3、Sentinel限流、降級的使用

一：流控

①先請求介面，因為只有請求完介面後，sentinel的簇點鏈路才有該路徑，才可以進行限流​​​​​​​

②開啟sentinel 簇點鏈路->列表檢視->找到剛呼叫的介面地址->點選流控​​​​​​​

QPS:點選數

單機閾值：單位時間內QPS和執行緒數的數量

執行緒數：跟QPS很像，理解直觀意思即可

關聯：比如A介面地址為資源名、B介面地址為關聯的資源名，當A介面限流後，B介面也會被限流

Warm Up：預熱模式，該載入因子預設是3，意思是當QPS(點選數)設定每秒10次，warm up設定5秒，那就是在5秒內處於預熱模式。每秒的並行是 QPS/載入因子、10/3 ，也就是說在預熱模式內(warm up = 5秒)並行最多是3，當大於3的時候就會進行流量控制

排隊等候：這種方式主要用於處理間隔性突發的流量，例如訊息佇列。想象一下這樣的場景，在某一秒有大量的請求到來，而接下來的幾秒則處於空閒狀態， 我們希望系統能夠在接下來的空閒期間逐漸處理這些請求，而不是在第一秒直接拒絕多餘的請求。

注意：勻速排隊模式暫時不支援 QPS > 1000 的場景。

注意 ：自定義的流量控制異常請參考上面介面實現類裡的方法

二：降級

①先請求介面，因為只有請求完介面後，sentinel的簇點鏈路才有該路徑，才可以進行降級

②開啟sentinel 簇點鏈路->列表檢視->找到剛呼叫的介面地址->點選降級

注意：降級規則1.8之後更新了策略

RT：平均響應時間，當rt設定為200毫秒時則表示，單位時間內的的請求平均響應時間必須在200毫秒以內完成，若超出則會觸發降級

時間視窗：被降級後的資源將在時間視窗後恢復正常

異常比例：單位時間內的請求，當報錯達到一定比例後服務將會自動降級(例：每秒請求10次，異常比例設定為20%，那麼10次請求中報錯超過3次，報錯就會 超過20%，一旦超過，sentinel就會進行服務熔斷)

異常數：這個相對於前兩個就比較好理解一些了，直接設定好報錯的次數，當報錯次數超過設定的異常數時，就會自動降級

注意 ：自定義的服務降級異常請參考上面介面實現類裡的方法，與流控的自定義異常寫法可以保持一致，關鍵點在sentinel Dashbord對於該資源是設定了限流還是降級

2.2 服務消費者

服務消費者

1、建立 admin-role-api 模組：右鍵alibaba-module->new->module->建立maven專案

構建Pom:

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <artifactId>alibaba-module</artifactId>
        <groupId>com.jingshang</groupId>
        <version>1.0</version>
    </parent>


    <artifactId>admin-role-api</artifactId>
    <packaging>jar</packaging>
    <description>role模組</description>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

</project>

2、建立 admin-role-biz 模組：右鍵alibaba-module->new->module->建立springboot專案

構建Pom：

<?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.jingshang</groupId>
    <artifactId>admin-role-biz</artifactId>
    <version>1.0</version>
    <packaging>jar</packaging>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.5.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <!-- 引入Api -->
        <dependency>
            <groupId>com.jingshang</groupId>
            <artifactId>admin-role-api</artifactId>
            <version>1.0</version>
        </dependency>
        <dependency>
            <groupId>com.jingshang</groupId>
            <artifactId>admin-user-api</artifactId>
            <version>1.0</version>
        </dependency>
        <!-- mysql -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <!-- mybatis -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.3</version>
        </dependency>
        <!-- 必須包含spring-boot-starter-actuator包，不然啟動會報錯。 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!-- web 應用 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- 整合的dubbo -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
        <!-- 整合的nacos -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- 設定中心所需jar包 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <!-- sentinel -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.2</version>
            <optional>true</optional>
        </dependency>
        <!--  junit 測試所需的jar包 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>0.2.2.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.properties基本設定

spring.application.name=admin-role-biz
server.port=8002
# sentinel dashboard (限流、熔斷降級)
spring.cloud.sentinel.transport.dashboard=10.10.10.244:8888
#nacos 註冊中心
spring.cloud.nacos.discovery.server-addr=localhost:8848
spring.cloud.nacos.discovery.namespace=dddf9ef6-638a-42fa-9b82-9c61a944f6cc
# dubbo 服務
#dubbo.scan.base-packages=com.jingshang.adminrolebiz.service
dubbo.protocol.name=dubbo
dubbo.protocol.port=20882
dubbo.registry.address=spring-cloud://localhost
#訂閱 (意思是呼叫哪個web服務的介面)
dubbo.cloud.subscribed-services=admin-user-biz
#mysql紀錄檔
logging.level.com.jingshang.adminrolebiz.dao=debug

bootstrap.properties拉取設定中心的設定，這裡跟服務提供者保持一致，都是拉取的同一個資料庫的設定，這裡就不重新貼上程式碼了，小夥伴可直接複製服務提供者的bootstrap.properties中的設定，我這裡只在nacos中設定了資料庫，其他設定根據小夥伴們的個人需求進行編寫

啟動類新增@EnableDiscoveryClient註解

注：搭建消費者的方法與提供者步驟相同，這裡不再贅述​​​​​​​

3、消費提供者提供的方法​​​​​​​

serviceImpl

package com.jingshang.adminrolebiz.service;

import com.jingshang.adminuserapi.dubbo.UserDubboService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Component;


/**
 * @Author: 王文龍
 * @Date: 2020/9/914:21
 * @Version: 1.0
 * @Describe: 描述:
 */
@Component
public class RoleServiceImpl {


    @Reference
    UserDubboService dubboService;//dubbo服務


    public String findByName(Integer id) {
        return dubboService.findByName(id);
    }
}

 

注入服務提供者時，要使用dubbo的@Reference註解，我個人遠端呼叫是用的dubbo的rpc協定，如果遠端呼叫使用的的feign的話就另當別論了

注：因為我這裡沒有實現介面，所以不需要@Service註解，但需要 @Component註解，而且application.properties也不可以讓dubbo去掃描service包，在你妹使用dubbo的@Service註解的時候，設定裡去掃描service包是會報錯的，所以這裡注意一下

controller

package com.jingshang.adminrolebiz.controller;

import com.jingshang.adminrolebiz.service.RoleServiceImpl;
import com.jingshang.adminuserapi.dubbo.UserDubboService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @Author: 王文龍
 * @Date: 2020/9/914:25
 * @Version: 1.0
 * @Describe: 描述:
 */
@RestController
@RequestMapping("/role")
public class RoleController {


    @Resource
    private RoleServiceImpl roleService;

    @RequestMapping("/findByName")
    public String findByName(Integer id) {
        return roleService.findByName(id);
    }
}

 

5、PostMan呼叫介面

!!!! 關於服務註冊、訂閱、設定、限流、降級就到此結束了​​​​​​​