前言

從本章節開始，我們學習 Spring Cloud Alibaba 相關微服務組件。

Spring Cloud Alibaba 介紹

Spring Cloud Alibaba 致力於提供微服務開發的一站式解決方案。此項目包含開發分散式應用微服務的必需組件，方便開發者通過 Spring Cloud 編程模型輕鬆使用這些組件來開發分散式應用服務。

依託 Spring Cloud Alibaba，只需要添加一些註解和少量配置，就可以將 Spring Cloud 應用接入阿里微服務解決方案，通過阿里中間件來迅速搭建分散式應用系統。

Spring Cloud Alibaba 功能

1. 「服務限流降級 Sentinel」：支援 WebServlet，WebFlux，OpenFeign，RestTemplate，Dubbo，Gateway，Zuul 限流降級功能的接入。可以在運行時通過控制台實時修改限流降級規則，並且還支援限流降級度量指標監控。
2. 「服務註冊與發現 Nacos」：適配 Spring Cloud 服務註冊與發現標準，默認集成了 Ribbon 的支援。
3. 「分散式配置管理 Nacos」：支援分散式系統中的外部化配置，配置更改時自動刷新。
4. 「RPC 服務 Dubbo」：擴展 Spring Cloud 客戶端 RestTemplate 和 OpenFeign 以支援調用 Dubbo RPC 服務。
5. 「消息驅動 RocketMQ」：基於 Spring Cloud Stream 為微服務應用構建消息驅動能力。
6. 「分散式事務 Seata」：支援高性能且易於使用的分散式事務解決方案。
7. 「阿里雲對象存儲 OSS」：大規模，安全，低成本，高度可靠的雲存儲服務。支援隨時隨地在任何應用程式中存儲和訪問任何類型的數據。
8. 「分散式任務調度 SchedulerX」：提供秒級、精準、高可靠、高可用的定時（基於 Cron 表達式）任務調度服務。同時提供分散式的任務執行模型，如網格任務。網格任務支援海量子任務均勻分配到所有 Worker（schedulerx-client）上執行。
9. 「阿里雲簡訊服務 SMS」：覆蓋全球的簡訊服務，友好、高效、智慧的通訊能力，幫助企業迅速搭建客戶觸達通道。

Spring Cloud Alibaba 組件

• Nacos：阿里巴巴開源產品，一個更易於構建雲原生應用的動態服務發現、配置管理和服務管理平台。
• Sentinel：面向分散式服務架構的輕量級流量控制產品，把流量作為切入點，從流量控制、熔斷降級、系統負載保護等多個維度保護服務的穩定性。
• RocketMQ：一款開源的分散式消息系統，基於高可用分散式集群技術，提供低延時的、高可靠的消息發布與訂閱服務。
• Dubbo：Apache Dubbo™ 是一款高性能 Java RPC 框架。
• Seata：阿里巴巴開源產品，一個易於使用的高性能微服務分散式事務解決方案。
• Alibaba Cloud ACM：一款在分散式架構環境中對應用配置進行集中管理和推送的應用配置中心產品。
• Alibaba Cloud OSS：阿里雲對象存儲服務（Object Storage Service，簡稱 OSS），是阿里雲提供的海量、安全、低成本、高可靠的雲存儲服務。您可以在任何應用、任何時間、任何地點存儲和訪問任意類型的數據。
• Alibaba Cloud SchedulerX：阿里中間件團隊開發的一款分散式任務調度產品，提供秒級、精準、高可靠、高可用的定時（基於 Cron 表達式）任務調度服務。
• Alibaba Cloud SMS：覆蓋全球的簡訊服務，友好、高效、智慧的互聯化通訊能力，幫助企業迅速搭建客戶觸達通道。

什麼是註冊中心

服務註冊中心是服務實現服務化管理的核心組件，類似於目錄服務的作用，主要用來存儲服務資訊，譬如提供者 url 串、路由資訊等。服務註冊中心是微服務架構中最基礎的設施之一。

註冊中心可以說是微服務架構中的「通訊錄」，它記錄了服務和服務地址的映射關係。在分散式架構中，服務會註冊到這裡，當服務需要調用其它服務時，就到這裡找到服務的地址，進行調用。

簡單理解就是：在沒有註冊中心時候，服務間調用需要知道被當服務調方的具體地址（寫死的 ip:port）。更換部署地址，就不得不修改調用當中指定的地址。而有了註冊中心之後，每個服務在調用別人的時候只需要知道服務名稱（軟編碼）就好，地址都會通過註冊中心根據服務名稱獲取到具體的服務地址進行調用。

舉個現實生活中的例子，比如說，我們手機中的通訊錄的兩個使用場景：

❝

當我想給張三打電話時，那我需要在通訊錄中按照名字找到張三，然後就可以找到他的手機號撥打電話。—— 服務發現

李四辦了手機號並把手機號告訴了我，我把李四的號碼存進通訊錄，後續，我就可以從通訊錄找到他。—— 服務註冊

通訊錄 —— ？什麼角色（服務註冊中心）

❞

總結：服務註冊中心的作用就是「服務的註冊」和「服務的發現」。

常見的註冊中心

• Netflix Eureka
• Alibaba Nacos
• HashiCorp Consul
• Apache ZooKeeper
• CoreOS Etcd
• CNCF CoreDNS

CAP 原則與 BASE 理論

CAP 原則

CAP 原則又稱 CAP 定理，指的是在一個分散式系統中， Consistency（一致性）、 Availability（可用性）、Partition tolerance（分區容錯性），三者不可得兼。

CAP 由 Eric Brewer 在 2000 年 PODC 會議上提出。該猜想在提出兩年後被證明成立，成為我們熟知的 CAP 定理。CAP 三者不可兼得。

取捨策略

CAP 三個特性只能滿足其中兩個，那麼取捨的策略就共有三種：

• 「CA without P」：如果不要求P（不允許分區），則C（強一致性）和A（可用性）是可以保證的。但放棄 P 的同時也就意味著放棄了系統的擴展性，也就是分散式節點受限，沒辦法部署子節點，這是違背分散式系統設計的初衷的。
• 「CP without A」：如果不要求A（可用），相當於每個請求都需要在伺服器之間保持強一致，而P（分區）會導致同步時間無限延長（也就是等待數據同步完才能正常訪問服務），一旦發生網路故障或者消息丟失等情況，就要犧牲用戶的體驗，等待所有數據全部一致了之後再讓用戶訪問系統。設計成 CP 的系統其實不少，最典型的就是分散式資料庫，如 Redis、HBase 等。對於這些分散式資料庫來說，數據的一致性是最基本的要求，因為如果連這個標準都達不到，那麼直接採用關係型資料庫就好，沒必要再浪費資源來部署分散式資料庫。
• 「AP without C」：要高可用並允許分區，則需放棄一致性。一旦分區發生，節點之間可能會失去聯繫，為了高可用，每個節點只能用本地數據提供服務，而這樣會導致全局數據的不一致性。典型的應用就如某米的搶購手機場景，可能前幾秒你瀏覽商品的時候頁面提示是有庫存的，當你選擇完商品準備下單的時候，系統提示你下單失敗，商品已售完。這其實就是先在 A（可用性）方面保證系統可以正常的服務，然後在數據的一致性方面做了些犧牲，雖然多少會影響一些用戶體驗，但也不至於造成用戶購物流程的嚴重阻塞。

總結

現如今，對於多數大型互聯網應用的場景，主機眾多、部署分散，而且現在的集群規模越來越大，節點只會越來越多，所以節點故障、網路故障是常態，因此分區容錯性也就成為了一個分散式系統必然要面對的問題。那麼就只能在 C 和 A 之間進行取捨。但對於傳統的項目就可能有所不同，拿銀行的轉賬系統來說，涉及到金錢的對於數據一致性不能做出一絲的讓步，C 必須保證，出現網路故障的話，寧可停止服務，可以在 A 和 P 之間做取捨。

總而言之，沒有最好的策略，好的系統應該是根據業務場景來進行架構設計的，只有適合的才是最好的。

BASE 理論

CAP 理論已經提出好多年了，難道真的沒有辦法解決這個問題嗎？也許可以做些改變。比如 C 不必使用那麼強的一致性，可以先將數據存起來，稍後再更新，實現所謂的 「最終一致性」。

這個思路又是一個龐大的問題，同時也引出了第二個理論 BASE 理論。

❝

BASE：全稱 Basically Available（基本可用），Soft state（軟狀態），和 Eventually consistent（最終一致性）三個短語的縮寫，來自 ebay 的架構師提出。

❞

BASE 理論是對 CAP 中一致性和可用性權衡的結果，其來源於對大型互聯網分散式實踐的總結，是基於 CAP 定理逐步演化而來的。其核心思想是：

❝

既然無法做到強一致性（Strong consistency），但每個應用都可以根據自身的業務特點，採用適當的方式來使系統達到最終一致性（Eventual consistency）。

❞

Basically Available（基本可用）

基本可用是指分散式系統在出現故障的時候，允許損失部分可用性（例如響應時間、功能上的可用性）。需要注意的是，基本可用絕不等價於系統不可用。

• 響應時間上的損失：正常情況下搜索引擎需要在 0.5 秒之內返回給用戶相應的查詢結果，但由於出現故障（比如系統部分機房發生斷電或斷網故障），查詢結果的響應時間增加到了 1~2 秒。
• 功能上的損失：購物網站在購物高峰（如雙十一）時，為了保護系統的穩定性，部分消費者可能會被引導到一個降級頁面。

Soft state（軟狀態）

什麼是軟狀態呢？相對於原子性而言，要求多個節點的數據副本都是一致的，這是一種 「硬狀態」。

軟狀態是指允許系統存在中間狀態，而該中間狀態不會影響系統整體可用性。分散式存儲中一般一份數據會有多個副本，允許不同副本數據同步的延時就是軟狀態的體現。

Eventually consistent（最終一致性）

系統不可能一直是軟狀態，必須有個時間期限。在期限過後，應當保證所有副本保持數據一致性。從而達到數據的最終一致性。這個時間期限取決於網路延時，系統負載，數據複製方案設計等等因素。

實際上，不只是分散式系統使用最終一致性，關係型資料庫在某個功能上，也是使用最終一致性的，比如備份，資料庫的複製都是需要時間的，這個複製過程中，業務讀取到的值就是舊值。當然，最終還是達成了數據一致性。這也算是一個最終一致性的經典案例。

總結

總的來說，BASE 理論面向的是大型高可用可擴展的分散式系統，和傳統事務的 ACID 是相反的，它完全不同於 ACID 的強一致性模型，而是通過犧牲強一致性來獲得可用性，並允許數據在一段時間是不一致的。

為什麼需要註冊中心

了解了什麼是註冊中心，那麼我們繼續談談，為什麼需要註冊中心。在分散式系統中，我們不僅僅是需要在註冊中心找到服務和服務地址的映射關係這麼簡單，我們還需要考慮更多更複雜的問題：

• 服務註冊後，如何被及時發現
• 服務宕機後，如何及時下線
• 服務如何有效的水平擴展
• 服務發現時，如何進行路由
• 服務異常時，如何進行降級
• 註冊中心如何實現自身的高可用

這些問題的解決都依賴於註冊中心。簡單看，註冊中心的功能有點類似於 DNS 伺服器或者負載均衡器，而實際上，註冊中心作為微服務的基礎組件，可能要更加複雜，也需要更多的靈活性和時效性。所以我們還需要學習更多 Spring Cloud 微服務組件協同完成應用開發。

註冊中心解決了以下問題：

• 服務管理
• 服務之間的自動發現
• 服務的依賴關係管理

Nacos 介紹

Nacos 是 Alibaba 公司推出的開源工具，用於實現分散式系統的服務發現與配置管理。英文全稱 Dynamic Naming and Configuration Service，Na 為 Naming/NameServer 即註冊中心，co 為 Configuration 即配置中心，Service 是指該註冊/配置中心都是以服務為核心。服務（Service）是 Nacos 世界的一等公民。

❝

官網是這樣說的：一個更易於構建雲原生應用的動態服務發現、配置管理和服務管理平台。

❞

Nacos 致力於發現、配置和管理微服務。Nacos 提供了一組簡單易用的特性集，可以快速實現動態服務發現、服務配置、服務元數據及流量管理。

Nacos 可以更敏捷和容易地構建、交付和管理微服務平台。 Nacos 是構建以「服務」為中心的現代應用架構的服務基礎設施。

使用 Nacos 簡化服務發現、配置管理、服務治理及管理的解決方案，讓微服務的發現、管理、共享、組合更加容易。

Nacos 安裝

環境準備

Nacos 依賴 Java 環境來運行。如果您是從程式碼開始構建並運行 Nacos，還需要為此配置 Maven 環境，請確保是在以下版本環境中安裝使用:

• JDK 1.8+；
• Maven 3.2.x+。

下載源碼或者安裝包

可以通過源碼和發行包兩種方式來獲取 Nacos。

源碼方式

從 Github 上下載源碼方式。

git clone //github.com/alibaba/nacos.git
cd nacos/
mvn -Prelease-nacos -Dmaven.test.skip=true clean install -U  
ls -al distribution/target/

// change the $version to your actual path
cd distribution/target/nacos-server-$version/nacos/bin

發行包方式

您可以從 //github.com/alibaba/nacos/releases 下載最新穩定版本的 nacos-server 包。

啟動伺服器

Linux/Unix/Mac

在 Nacos 的解壓目錄 nacos/bin 目錄下啟動。

啟動命令（standalone 代表著單機模式運行，非集群模式）:

sh startup.sh -m standalone

如果您使用的是 ubuntu 系統，或者運行腳本報錯提示符號找不到，可嘗試如下運行：

bash startup.sh -m standalone

Windows

啟動命令：

cmd startup.cmd

或者雙擊 startup.cmd 運行文件。

訪問

訪問：//localhost:8848/nacos/ ，默認用戶名/密碼是 nacos/nacos。

關閉伺服器

Linux/Unix/Mac

sh shutdown.sh

Windows

cmd shutdown.cmd

或者雙擊 shutdown.cmd 運行文件。

Nacos 入門案例

創建項目

我們創建聚合項目來講解 Nacos，首先創建一個 pom 父工程。

添加依賴

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="//maven.apache.org/POM/4.0.0"
         xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="//maven.apache.org/POM/4.0.0 //maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <!-- 項目坐標地址 -->
    <groupId>com.example</groupId>
    <!-- 項目模組名稱 -->
    <artifactId>nacos-demo</artifactId>
    <!-- 項目版本名稱 快照版本SNAPSHOT、正式版本RELEASE -->
    <version>1.0-SNAPSHOT</version>

    <!-- 繼承 spring-boot-starter-parent 依賴 -->
    <!-- 使用繼承方式，實現復用，符合繼承的都可以被使用 -->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.RELEASE</version>
    </parent>

    <!--
        集中定義依賴組件版本號，但不引入，
        在子工程中用到聲明的依賴時，可以不加依賴的版本號，
        這樣可以統一管理工程中用到的依賴版本
     -->
    <properties>
        <!-- Spring Cloud Hoxton.SR4 依賴 -->
        <spring-cloud.version>Hoxton.SR4</spring-cloud.version>
        <!-- spring cloud alibaba 依賴 -->
        <spring-cloud-alibaba.version>2.1.0.RELEASE</spring-cloud-alibaba.version>
    </properties>

    <!-- 項目依賴管理 父項目只是聲明依賴，子項目需要寫明需要的依賴(可以省略版本資訊) -->
    <dependencyManagement>
        <dependencies>
            <!-- spring cloud 依賴 -->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <!-- spring cloud alibaba 依賴 -->
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>${spring-cloud-alibaba.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

</project>

商品服務 product-service

創建項目

在剛才的父工程下創建一個 product-service 項目。

添加依賴

主要添加 spring-cloud-starter-alibaba-nacos-discovery 依賴。

<!-- spring cloud alibaba nacos discovery 依賴 -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

完整依賴如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="//maven.apache.org/POM/4.0.0"
         xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="//maven.apache.org/POM/4.0.0 //maven.apache.org/xsd/maven-4.0.0.xsd">
    
    <!-- 繼承父依賴 -->
    <parent>
        <artifactId>nacos-demo</artifactId>
        <groupId>com.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>product-service</artifactId>

    <!-- 項目依賴 -->
    <dependencies>
        <!-- spring cloud alibaba nacos discovery 依賴 -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- spring boot web 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- lombok 依賴 -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <scope>provided</scope>
        </dependency>

        <!-- spring boot test 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

</project>

配置文件

application.yml

server:
  port: 7070 # 埠

spring:
  application:
    name: product-service # 應用名稱
  # 配置 Nacos 註冊中心
  cloud:
    nacos:
      discovery:
        enabled: true # 如果不想使用 Nacos 進行服務註冊和發現，設置為 false 即可
        server-addr: 127.0.0.1:8848 # Nacos 伺服器地址

實體類

Product.java

package com.example.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Product implements Serializable {

    private Integer id;
    private String productName;
    private Integer productNum;
    private Double productPrice;

}

編寫服務

ProductService.java

package com.example.service;

import com.example.pojo.Product;

import java.util.List;

/**
 * 商品服務
 */
public interface ProductService {

    /**
     * 查詢商品列表
     *
     * @return
     */
    List<Product> selectProductList();

}

ProductServiceImpl.java

package com.example.service.impl;

import com.example.pojo.Product;
import com.example.service.ProductService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.util.Arrays;
import java.util.List;

/**
 * 商品服務
 */
@Slf4j
@Service
public class ProductServiceImpl implements ProductService {

    /**
     * 查詢商品列表
     *
     * @return
     */
    @Override
    public List<Product> selectProductList() {
        log.info("商品服務查詢商品資訊...");
        return Arrays.asList(
                new Product(1, "華為手機", 1, 5800D),
                new Product(2, "聯想筆記型電腦", 1, 6888D),
                new Product(3, "小米平板", 5, 2020D)
        );
    }

}

控制層

ProductController.java

package com.example.controller;

import com.example.pojo.Product;
import com.example.service.ProductService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("/product")
public class ProductController {

    @Autowired
    private ProductService productService;

    /**
     * 查詢商品列表
     *
     * @return
     */
    @GetMapping("/list")
    public List<Product> selectProductList() {
        return productService.selectProductList();
    }

}

❝

該項目我們可以通過單元測試進行測試，也可以直接通過 url 使用 postman 或者瀏覽器來進行測試。

❞

啟動類

通過 Spring Cloud 原生註解 @EnableDiscoveryClient 開啟服務註冊發現功能。

package com.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

// 開啟 @EnableDiscoveryClient 註解，當前版本默認會開啟該註解
//@EnableDiscoveryClient
@SpringBootApplication
public class ProductServiceApplication {

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

}

註冊中心

刷新 Nacos 伺服器，可以看到服務已註冊至 Nacos。

訂單服務 order-service

創建項目

在剛才的父工程下創建一個 order-service 項目。

添加依賴

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="//maven.apache.org/POM/4.0.0"
         xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="//maven.apache.org/POM/4.0.0 //maven.apache.org/xsd/maven-4.0.0.xsd">

    <!-- 繼承父依賴 -->
    <parent>
        <artifactId>nacos-demo</artifactId>
        <groupId>com.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>order-service</artifactId>

    <!-- 項目依賴 -->
    <dependencies>
        <!-- spring cloud alibaba nacos discovery 依賴 -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <!-- spring boot web 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- lombok 依賴 -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <scope>provided</scope>
        </dependency>

        <!-- spring boot test 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>
    
</project>

配置文件

application.yml

server:
  port: 9090 # 埠

spring:
  application:
    name: order-service # 應用名稱
  # 配置 Nacos 註冊中心
  cloud:
    nacos:
      discovery:
        enabled: true # 如果不想使用 Nacos 進行服務註冊和發現，設置為 false 即可
        server-addr: 127.0.0.1:8848 # Nacos 伺服器地址

實體類

Product.java

package com.example.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Product implements Serializable {

    private Integer id;
    private String productName;
    private Integer productNum;
    private Double productPrice;

}

Order.java

package com.example.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.List;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Order implements Serializable {

    private Integer id;
    private String orderNo;
    private String orderAddress;
    private Double totalPrice;
    private List<Product> productList;

}

消費服務

OrderService.java

package com.example.service;

import com.example.pojo.Order;

public interface OrderService {

    /**
     * 根據主鍵查詢訂單
     *
     * @param id
     * @return
     */
    Order selectOrderById(Integer id);

}

對於服務的消費我們這裡講三種實現方式：

• DiscoveryClient：通過元數據獲取服務資訊
• LoadBalancerClient：Ribbon 的負載均衡器
• @LoadBalanced：通過註解開啟 Ribbon 的負載均衡器

DiscoveryClient

Spring Boot 不提供任何自動配置的RestTemplate bean，所以需要在啟動類中注入 RestTemplate。

package com.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

// 開啟 @EnableDiscoveryClient 註解，當前版本默認會開啟該註解
//@EnableDiscoveryClient
@SpringBootApplication
public class OrderServiceApplication {

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

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

}

OrderServiceImpl.java

package com.example.service.impl;

import com.alibaba.fastjson.JSON;
import com.example.pojo.Order;
import com.example.pojo.Product;
import com.example.service.OrderService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import org.springframework.web.client.RestTemplate;

import java.util.List;

@Slf4j
@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private DiscoveryClient discoveryClient;

    /**
     * 根據主鍵查詢訂單
     *
     * @param id
     * @return
     */
    @Override
    public Order selectOrderById(Integer id) {
        log.info("訂單服務查詢訂單資訊...");
        return new Order(id, "order-001", "中國", 22788D,
                selectProductListByDiscoveryClient());
    }

    private List<Product> selectProductListByDiscoveryClient() {
        StringBuffer sb = null;

        // 獲取服務列表
        List<String> serviceIds = discoveryClient.getServices();
        if (CollectionUtils.isEmpty(serviceIds))
            return null;

        // 根據服務名稱獲取服務
        List<ServiceInstance> serviceInstances = discoveryClient.getInstances("product-service");
        if (CollectionUtils.isEmpty(serviceInstances))
            return null;

        // 構建遠程服務調用地址
        ServiceInstance si = serviceInstances.get(0);
        sb = new StringBuffer();
        sb.append("//" + si.getHost() + ":" + si.getPort() + "/product/list");
        log.info("訂單服務調用商品服務...");
        log.info("從註冊中心獲取到的商品服務地址為：{}", sb.toString());

        // 遠程調用服務
        // ResponseEntity: 封裝了返回數據
        ResponseEntity<List<Product>> response = restTemplate.exchange(
                sb.toString(),
                HttpMethod.GET,
                null,
                new ParameterizedTypeReference<List<Product>>() {});
        log.info("商品資訊查詢結果為：{}", JSON.toJSONString(response.getBody()));
        return response.getBody();
    }

}

LoadBalancerClient

OrderServiceImpl.java

package com.example.service.impl;

import com.alibaba.fastjson.JSON;
import com.example.pojo.Order;
import com.example.pojo.Product;
import com.example.service.OrderService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.List;

@Slf4j
@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private LoadBalancerClient loadBalancerClient; // Ribbon 負載均衡器

    /**
     * 根據主鍵查詢訂單
     *
     * @param id
     * @return
     */
    @Override
    public Order selectOrderById(Integer id) {
        log.info("訂單服務查詢訂單資訊...");
        return new Order(id, "order-001", "中國", 22788D,
                selectProductListByLoadBalancerClient());
    }

    private List<Product> selectProductListByLoadBalancerClient() {
        StringBuffer sb = null;

        // 根據服務名稱獲取服務
        ServiceInstance si = loadBalancerClient.choose("product-service");
        if (null == si)
            return null;

        sb = new StringBuffer();
        sb.append("//" + si.getHost() + ":" + si.getPort() + "/product/list");
        log.info("訂單服務調用商品服務...");
        log.info("從註冊中心獲取到的商品服務地址為：{}", sb.toString());

        // ResponseEntity: 封裝了返回數據
        ResponseEntity<List<Product>> response = restTemplate.exchange(
                sb.toString(),
                HttpMethod.GET,
                null,
                new ParameterizedTypeReference<List<Product>>() {});
        log.info("商品資訊查詢結果為：{}", JSON.toJSONString(response.getBody()));
        return response.getBody();
    }

}

@LoadBalanced

啟動類注入 RestTemplate 時添加 @LoadBalanced 負載均衡註解，表示這個 RestTemplate 在請求時擁有客戶端負載均衡的能力。

package com.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@EnableDiscoveryClient
@SpringBootApplication
public class OrderServiceApplication {

    @Bean
    @LoadBalanced // 負載均衡註解
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

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

}

OrderServiceImpl.java

package com.example.service.impl;

import com.alibaba.fastjson.JSON;
import com.example.pojo.Order;
import com.example.pojo.Product;
import com.example.service.OrderService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.List;

@Slf4j
@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 根據主鍵查詢訂單
     *
     * @param id
     * @return
     */
    @Override
    public Order selectOrderById(Integer id) {
        log.info("訂單服務查詢訂單資訊...");
        return new Order(id, "order-001", "中國", 22788D,
                selectProductListByLoadBalancerAnnotation());
    }

    private List<Product> selectProductListByLoadBalancerAnnotation() {
        String url = "//product-service/product/list";
        log.info("訂單服務調用商品服務...");
        log.info("從註冊中心獲取到的商品服務地址為：{}", url);
        // ResponseEntity: 封裝了返回數據
        ResponseEntity<List<Product>> response = restTemplate.exchange(
                url,
                HttpMethod.GET,
                null,
                new ParameterizedTypeReference<List<Product>>() {});
        log.info("商品資訊查詢結果為：{}", JSON.toJSONString(response.getBody()));
        return response.getBody();
    }

}

控制層

OrderController.java

package com.example.controller;

import com.example.pojo.Order;
import com.example.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private OrderService orderService;

    /**
     * 根據主鍵查詢訂單
     *
     * @param id
     * @return
     */
    @GetMapping("/{id}")
    public Order selectOrderById(@PathVariable("id") Integer id) {
        return orderService.selectOrderById(id);
    }

}

訪問

刷新 Nacos 伺服器，可以看到服務已註冊至 Nacos。

訪問：//localhost:9090/order/1 結果如下：

配置 MySQL 資料庫

Nacos 在 0.7 版本之前，默認使用的是嵌入式資料庫 Apache Derby 來存儲數據（內嵌的資料庫會隨著 Nacos 一起啟動，無需額外安裝）；0.7 版本及以後，增加了對 MySQL 數據源的支援。

MySQL數據源

環境要求：MySQL 5.6.5+（生產使用建議至少主備模式，或者採用高可用資料庫）；

初始化 MySQL 資料庫

創建資料庫 nacos_config。

SQL源文件地址：//github.com/alibaba/nacos/blob/master/distribution/conf/nacos-mysql.sql ，或者在 nacos-server 解壓目錄 conf 下，找到 nacos-mysql.sql 文件，運行該文件，結果如下：

application.properties 配置

修改 nacos/conf/application.properties 文件的以下內容。

最終修改結果如下：

#*************** Config Module Related Configurations ***************#
### If user MySQL as datasource:
# 指定數據源為 MySQL
spring.datasource.platform=mysql
Count of DB:
資料庫實例數量
db.num=1
資料庫連接資訊，如果是 MySQL 8.0+ 版本需要添加 serverTimezone=Asia/Shanghai
Connect URL of DB:
db.url.0=jdbc:mysql://127.0.0.1:3306/nacos_config?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&serverTimezone=Asia/Shanghai

db.user=root

db.password=1234