Netflix Eureka 2.X https://github.com/Netflix/eureka/wiki 官方宣告停止開(kāi)發(fā)邻遏，但其實(shí)對(duì)國(guó)內(nèi)的用戶影響甚小，一方面國(guó)內(nèi)大都使用的是 Eureka 1.X 系列眉孩，并且官方也在積極維護(hù) 1.X https://github.com/Netflix/eureka/releases。

The existing open source work on eureka 2.0 is discontinued. The code base and artifacts that were released as part of the existing repository of work on the 2.x branch is considered use at your own risk.

Eureka 1.x is a core part of Netflix's service discovery system and is still an active project.

翻譯：

有關(guān) eureka 2.0 的現(xiàn)有開(kāi)源工作已停止淋纲。在 2.x 分支上作為現(xiàn)有工作資料庫(kù)的一部分發(fā)布的代碼庫(kù)和工件被視為使用后果自負(fù)啄巧。

Eureka 1.x 是 Netflix 服務(wù)發(fā)現(xiàn)系統(tǒng)的核心部分，仍然是一個(gè)活躍的項(xiàng)目胸囱。

雖然 Eureka祷舀，Hystrix 等不再繼續(xù)開(kāi)發(fā)或維護(hù)，但是目前來(lái)說(shuō)不影響使用烹笔，不管怎么說(shuō)感謝開(kāi)源裳扯，向 Netflix 公司的開(kāi)源致敬。

另一方面 Spring Cloud 支持很多服務(wù)發(fā)現(xiàn)的軟件谤职，Eureka 只是其中之一饰豺，比如我們今天要講的主角 Consul。下面是 Spring Cloud 支持的服務(wù)發(fā)現(xiàn)軟件以及特性對(duì)比允蜈。

常見(jiàn)的注冊(cè)中心

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

Consul 介紹

Consul 是 HashiCorp 公司推出的開(kāi)源工具冤吨，用于實(shí)現(xiàn)分布式系統(tǒng)的服務(wù)發(fā)現(xiàn)與配置。與其它分布式服務(wù)注冊(cè)與發(fā)現(xiàn)的方案漩蟆，Consul 的方案更“一站式”，內(nèi)置了服務(wù)注冊(cè)與發(fā)現(xiàn)框架蛤克、分布一致性協(xié)議實(shí)現(xiàn)扔仓、健康檢查、Key/Value 存儲(chǔ)（配置中心）咖耘、多數(shù)據(jù)中心方案儿倒，不再需要依賴其它工具（比如 ZooKeeper 等）版保，使用起來(lái)也較為簡(jiǎn)單。

Consul 使用 Go 語(yǔ)言編寫(xiě)凰慈，因此具有天然可移植性（支持Linux汞幢、Windows 和 Mac OS）；安裝包僅包含一個(gè)可執(zhí)行文件微谓，方便部署森篷，與 Docker 等輕量級(jí)容器可無(wú)縫配合输钩。

Consul 特性

• Raft 算法

• 服務(wù)發(fā)現(xiàn)

• 健康檢查

• Key/Value 存儲(chǔ)（配置中心）

• 多數(shù)據(jù)中心

• 支持 http 和 dns 協(xié)議接口

• 官方提供 web 管理界面

Consul 角色

點(diǎn)擊鏈接觀看：Consul 角色視頻（獲取更多請(qǐng)關(guān)注公眾號(hào)「哈嘍沃德先生」）

• client：客戶端，無(wú)狀態(tài)仲智，將 HTTP 和 DNS 接口請(qǐng)求轉(zhuǎn)發(fā)給局域網(wǎng)內(nèi)的服務(wù)端集群买乃。
• server：服務(wù)端，保存配置信息钓辆，高可用集群剪验，每個(gè)數(shù)據(jù)中心的 server 數(shù)量推薦為 3 個(gè)或者 5 個(gè)。

首先前联，圖中有兩個(gè)數(shù)據(jù)中心功戚，分別為 Datacenter1 和 Datacenter2 。Consul 非常好的支持多個(gè)數(shù)據(jù)中心似嗤，每個(gè)數(shù)據(jù)中心內(nèi)疫铜，有客戶端和服務(wù)器端，服務(wù)器一般為 3~5 個(gè)双谆，這樣可以在穩(wěn)定和性能上達(dá)到平衡壳咕，因?yàn)楦嗟臋C(jī)器會(huì)使數(shù)據(jù)同步很慢。不過(guò)客戶端是沒(méi)有限制的顽馋，可以有成千上萬(wàn)個(gè)谓厘。

數(shù)據(jù)中心內(nèi)的所有節(jié)點(diǎn)都會(huì)加入到 Gossip (流言)協(xié)議。這就意味著有一個(gè) Gossip 池寸谜，其中包含這個(gè)數(shù)據(jù)中心所有的節(jié)點(diǎn)竟稳。客戶端不需要去配置服務(wù)器地址信息熊痴，發(fā)現(xiàn)服務(wù)工作會(huì)自動(dòng)完成他爸。檢測(cè)故障節(jié)點(diǎn)的工作不是放在服務(wù)器端棍厌，而是分布式的瓜饥；這使得失敗檢測(cè)相對(duì)于本地化的心跳機(jī)制而言，更具可拓展性产舞。在選擇 leader 這種重要的事情發(fā)生的時(shí)候巾陕，數(shù)據(jù)中心被用作消息層來(lái)做消息廣播讨跟。

每個(gè)數(shù)據(jù)中心內(nèi)的服務(wù)器都是單個(gè) Raft 中節(jié)點(diǎn)集的一部分。這意味著他們一起工作鄙煤，選擇一個(gè)單一的領(lǐng)導(dǎo)者——一個(gè)具有額外職責(zé)的選定的服務(wù)器晾匠。leader 負(fù)責(zé)處理所有查詢和事物。事物也必須作為同步協(xié)議的一部分復(fù)制到節(jié)點(diǎn)集中的所有節(jié)點(diǎn)梯刚。由于這個(gè)要求凉馆，當(dāng)非 leader 服務(wù)器接收到 RPC 請(qǐng)求時(shí)，就會(huì)將請(qǐng)求其轉(zhuǎn)發(fā)給集群 leader。

服務(wù)器端節(jié)點(diǎn)同時(shí)也作為 WAN Gossip 池的一部分澜共，WAN 池和 LAN 池不同的是向叉，它針對(duì)網(wǎng)絡(luò)高延遲做了優(yōu)化，而且只包含其他Consul 服務(wù)器的節(jié)點(diǎn)咳胃。這個(gè)池的目的是允許數(shù)據(jù)中心以最少的消耗方式發(fā)現(xiàn)對(duì)方植康。啟動(dòng)新的數(shù)據(jù)中心與加入現(xiàn)有的 WAN Gossip 一樣簡(jiǎn)單旷太。因?yàn)檫@些服務(wù)器都在這個(gè)池中運(yùn)行展懈，它還支持跨數(shù)據(jù)中心請(qǐng)求。當(dāng)服務(wù)器收到對(duì)不同數(shù)據(jù)中心的請(qǐng)求時(shí)供璧，它會(huì)將其轉(zhuǎn)發(fā)到正確數(shù)據(jù)中心中的隨機(jī)服務(wù)器存崖。那個(gè)服務(wù)器可能會(huì)轉(zhuǎn)發(fā)給本地的 leader。

這樣會(huì)使數(shù)據(jù)中心的耦合非常低睡毒。但是由于故障檢測(cè)来惧，連接緩存和復(fù)用，跨數(shù)據(jù)中心請(qǐng)求相對(duì)快速可靠演顾。

總的來(lái)說(shuō)供搀，數(shù)據(jù)不會(huì)在不同的數(shù)據(jù)中心之間做復(fù)制備份。當(dāng)收到一個(gè)請(qǐng)求處于別的數(shù)據(jù)中心的資源時(shí)钠至，本地的 Consul 服務(wù)器會(huì)發(fā)一個(gè) RPC 請(qǐng)求到遠(yuǎn)端的 Consul 服務(wù)器葛虐，然后返回結(jié)果。如果遠(yuǎn)端數(shù)據(jù)中心處于不可用狀態(tài)棉钧，那么這么資源也會(huì)不可用屿脐，但這不影響本地的數(shù)據(jù)中心。在一些特殊的情況下宪卿，有限的數(shù)據(jù)集會(huì)被跨數(shù)據(jù)中心復(fù)制備份的诵，比如說(shuō) Consul 內(nèi)置的 ACL 復(fù)制能力，或者像 consul-replicate 這樣的外部工具佑钾。

Consul 工作原理

服務(wù)發(fā)現(xiàn)以及注冊(cè)

當(dāng)服務(wù) Producer 啟動(dòng)時(shí)西疤，會(huì)將自己的 Ip/host 等信息通過(guò)發(fā)送請(qǐng)求告知 Consul，Consul 接收到 Producer 的注冊(cè)信息后休溶，每隔 10s（默認(rèn)）會(huì)向 Producer 發(fā)送一個(gè)健康檢查的請(qǐng)求瘪阁，檢驗(yàn) Producer 是否健康。

服務(wù)調(diào)用

當(dāng) Consumer 請(qǐng)求 Product 時(shí)邮偎，會(huì)先從 Consul 中拿到存儲(chǔ) Product 服務(wù)的 IP 和 Port 的臨時(shí)表(temp table)管跺，從temp table 表中任選一個(gè)· Producer 的 IP 和 Port， 然后根據(jù)這個(gè) IP 和 Port禾进，發(fā)送訪問(wèn)請(qǐng)求豁跑；temp table 表只包含通過(guò)了健康檢查的 Producer 信息，并且每隔 10s（默認(rèn)）更新。

Consul 安裝

Eureka 其實(shí)就是個(gè) Servlet 程序艇拍，跑在 Servlet 容器中狐蜕；Consul 則是用 go 語(yǔ)言編寫(xiě)的第三方工具需要單獨(dú)安裝使用。

下載

訪問(wèn) Consul 官網(wǎng)：https://www.consul.io 下載 Consul 的最新版本卸夕。

支持多種環(huán)境安裝层释，截圖中只顯示了部分環(huán)境。

安裝

為了讓大家學(xué)習(xí)到不同環(huán)境的安裝快集，單節(jié)點(diǎn)我們?cè)?Windows 安裝贡羔，集群環(huán)境在 Linux 安裝。

單節(jié)點(diǎn)

壓縮包中就只有一個(gè) consul.exe 的執(zhí)行文件个初。

cd 到對(duì)應(yīng)的目錄下乖寒，使用 cmd 啟動(dòng) Consul

# -dev表示開(kāi)發(fā)模式運(yùn)行，另外還有 -server 表示服務(wù)模式運(yùn)行
consul agent -dev -client=0.0.0.0

為了方便啟動(dòng)院溺，也可以在 consul.exe 同級(jí)目錄下創(chuàng)建一個(gè)腳本來(lái)啟動(dòng)楣嘁，腳本內(nèi)容如下：

consul agent -dev -client=0.0.0.0
pause

訪問(wèn)管理后臺(tái)：http://localhost:8500/ 看到下圖意味著我們的 Consul 服務(wù)啟動(dòng)成功了。

Consul 入門(mén)案例

點(diǎn)擊鏈接觀看：Consul 入門(mén)案例視頻（獲取更多請(qǐng)關(guān)注公眾號(hào)「哈嘍沃德先生」）

consul-demo 聚合工程珍逸。SpringBoot 2.2.4.RELEASE逐虚、Spring Cloud Hoxton.SR1。

創(chuàng)建項(xiàng)目

我們創(chuàng)建聚合項(xiàng)目來(lái)講解 Consul谆膳，首先創(chuàng)建一個(gè) pom 父工程叭爱。

添加依賴

pom.xml

<?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>

    <!-- 項(xiàng)目坐標(biāo)地址 -->
    <groupId>com.example</groupId>
    <!-- 項(xiàng)目模塊名稱(chēng) -->
    <artifactId>consul-demo</artifactId>
    <!-- 項(xiàng)目版本名稱(chēng) 快照版本SNAPSHOT、正式版本RELEASE -->
    <version>1.0-SNAPSHOT</version>

    <!-- 繼承 spring-boot-starter-parent 依賴 -->
    <!-- 使用繼承方式摹量，實(shí)現(xiàn)復(fù)用涤伐，符合繼承的都可以被使用 -->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.4.RELEASE</version>
    </parent>

    <!--
        集中定義依賴組件版本號(hào)，但不引入缨称，
        在子工程中用到聲明的依賴時(shí)凝果，可以不加依賴的版本號(hào)，
        這樣可以統(tǒng)一管理工程中用到的依賴版本
     -->
    <properties>
        <!-- Spring Cloud Hoxton.SR1 依賴 -->
        <spring-cloud.version>Hoxton.SR1</spring-cloud.version>
    </properties>

    <!-- 項(xiàng)目依賴管理 父項(xiàng)目只是聲明依賴睦尽，子項(xiàng)目需要寫(xiě)明需要的依賴(可以省略版本信息) -->
    <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>
        </dependencies>
    </dependencyManagement>

</project>

服務(wù)提供者 service-provider

創(chuàng)建項(xiàng)目

在剛才的父工程下創(chuàng)建一個(gè) service-provider 服務(wù)提供者的項(xiàng)目器净。

添加依賴

pom.xml

<?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.example</groupId>
    <artifactId>service-provider</artifactId>
    <version>1.0-SNAPSHOT</version>

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

    <!-- 項(xiàng)目依賴 -->
    <dependencies>
        <!-- spring cloud consul 依賴 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- spring boot actuator 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</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: service-provider # 應(yīng)用名稱(chēng)
  # 配置 Consul 注冊(cè)中心
  cloud:
    consul:
      # 注冊(cè)中心的訪問(wèn)地址
      host: localhost
      port: 8500
      # 服務(wù)提供者信息
      discovery:
        register: true                                # 是否需要注冊(cè)
        instance-id: ${spring.application.name}-01    # 注冊(cè)實(shí)例 id（必須唯一）
        service-name: ${spring.application.name}      # 服務(wù)名稱(chēng)
        port: ${server.port}                          # 服務(wù)端口
        prefer-ip-address: true                       # 是否使用 ip 地址注冊(cè)
        ip-address: ${spring.cloud.client.ip-address} # 服務(wù)請(qǐng)求 ip

實(shí)體類(lèi)

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;

}

編寫(xiě)服務(wù)

ProductService.java

package com.example.service;

import com.example.pojo.Product;

import java.util.List;

/**
 * 商品服務(wù)
 */
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 org.springframework.stereotype.Service;

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

/**
 * 商品服務(wù)
 */
@Service
public class ProductServiceImpl implements ProductService {

    /**
     * 查詢商品列表
     *
     * @return
     */
    @Override
    public List<Product> selectProductList() {
        return Arrays.asList(
                new Product(1, "華為手機(jī)", 1, 5800D),
                new Product(2, "聯(lián)想筆記本", 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();
    }

}

該項(xiàng)目我們可以通過(guò)單元測(cè)試進(jìn)行測(cè)試，也可以直接通過(guò) url 使用 postman 或者瀏覽器來(lái)進(jìn)行測(cè)試当凡。

啟動(dòng)類(lèi)

ServiceProviderApplication.java

package com.example;

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

@SpringBootApplication
public class ServiceProviderApplication {

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

}

訪問(wèn)

訪問(wèn)管理后臺(tái)：http://localhost:8500/ 看到下圖意味著我們的服務(wù)注冊(cè)至注冊(cè)中心了山害。

將 service-provider 項(xiàng)目復(fù)制一份修改端口為 7071 ，注冊(cè)實(shí)例 id 為 02沿量。

spring:
  application:
    name: service-provider # 應(yīng)用名稱(chēng)
  # 配置 Consul 注冊(cè)中心
  cloud:
    consul:
      # 注冊(cè)中心的訪問(wèn)地址
      host: localhost
      port: 8500
      # 服務(wù)提供者信息
      discovery:
        register: true                                # 是否需要注冊(cè)
        instance-id: ${spring.application.name}-02    # 注冊(cè)實(shí)例 id（必須唯一）
        service-name: ${spring.application.name}      # 服務(wù)名稱(chēng)
        port: ${server.port}                          # 服務(wù)端口
        prefer-ip-address: true                       # 是否使用 ip 地址注冊(cè)
        ip-address: ${spring.cloud.client.ip-address} # 服務(wù)請(qǐng)求 ip

# 端口
server:
  port: 8602

啟動(dòng) service-provider02 結(jié)果如下：

服務(wù)消費(fèi)者 service-consumer

創(chuàng)建項(xiàng)目

在剛才的父工程下創(chuàng)建一個(gè) service-consumer 服務(wù)消費(fèi)者的項(xiàng)目浪慌。

添加依賴

pom.xml

<?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.example</groupId>
    <artifactId>service-consumer</artifactId>
    <version>1.0-SNAPSHOT</version>

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

    <!-- 項(xiàng)目依賴 -->
    <dependencies>
        <!-- spring cloud consul 依賴 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-consul-discovery</artifactId>
        </dependency>
        <!-- spring boot actuator 依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</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: service-consumer # 應(yīng)用名稱(chēng)
  # 配置 Consul 注冊(cè)中心
  cloud:
    consul:
      # 注冊(cè)中心的訪問(wèn)地址
      host: localhost
      port: 8500
      # 服務(wù)提供者信息
      discovery:
        register: false                               # 是否需要注冊(cè)
        instance-id: ${spring.application.name}-01    # 注冊(cè)實(shí)例 id（必須唯一）
        service-name: ${spring.application.name}      # 服務(wù)名稱(chēng)
        port: ${server.port}                          # 服務(wù)端口
        prefer-ip-address: true                       # 是否使用 ip 地址注冊(cè)
        ip-address: ${spring.cloud.client.ip-address} # 服務(wù)請(qǐng)求 ip

實(shí)體類(lèi)

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;

}

消費(fèi)服務(wù)

OrderService.java

package com.example.service;

import com.example.pojo.Order;

public interface OrderService {

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

}

OrderServiceImpl.java

package com.example.service.impl;

import com.example.pojo.Order;
import com.example.pojo.Product;
import com.example.service.OrderService;
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;

@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 根據(jù)主鍵查詢訂單
     *
     * @param id
     * @return
     */
    @Override
    public Order selectOrderById(Integer id) {
        return new Order(id, "order-001", "中國(guó)", 22788D,
                selectProductListByLoadBalancerAnnotation());
    }

    private List<Product> selectProductListByLoadBalancerAnnotation() {
        // ResponseEntity: 封裝了返回?cái)?shù)據(jù)
        ResponseEntity<List<Product>> response = restTemplate.exchange(
                "http://service-provider/product/list",
                HttpMethod.GET,
                null,
                new ParameterizedTypeReference<List<Product>>() {
                });
        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;

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

}

啟動(dòng)類(lèi)

ServiceConsumerApplication.java

package com.example;

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

@SpringBootApplication
public class ServiceConsumerApplication {

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

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

}

訪問(wèn)

訪問(wèn)：http://localhost:9090/order/1 結(jié)果如下：

下一篇我們講解 Consul 集群環(huán)境的搭建。記得關(guān)注噢～

本文采用 知識(shí)共享「署名-非商業(yè)性使用-禁止演繹 4.0 國(guó)際」許可協(xié)議朴则。

大家可以通過(guò) 分類(lèi) 查看更多關(guān)于 Spring Cloud 的文章权纤。

?? 您的點(diǎn)贊和轉(zhuǎn)發(fā)是對(duì)我最大的支持。

?? 關(guān)注公眾號(hào) 哈嘍沃德先生「文檔 + 視頻」每篇文章都配有專(zhuān)門(mén)視頻講解，學(xué)習(xí)更輕松噢 ~