Spring Cloud Gateway實戰之一：初探-有解無憂

歡迎訪問我的GitHub

這里分類和匯總了欣宸的全部原創(含配套原始碼)：https://github.com/zq2599/blog_demos

關于《Spring Cloud Gateway實戰》系列

《Spring Cloud Gateway實戰》是欣宸在Java領域的系列原創，旨在通過專案實戰與大家一起學習和掌握Spring Cloud Gateway，更好的為實際專案服務

本篇概覽

作為《Spring Cloud Gateway實戰》的開篇，本文的主要內容如下：

基礎知識簡介
確認環境涉及到的工具和服務的版本
啟動nacos，作為后續實戰的注冊中心和配置中心
創建maven父工程，為后續實戰的代碼和依賴庫版本做好管理
創建名為common的子工程，存放共用的常量和資料結構
創建名為provider-hello的web應用，用于gateway路由的目標
運行一個簡單的demo，完成spring-cloud-gateway的初體驗

關于Spring Cloud Gateway

這是一個基于Spring技術堆疊構建的API網關，涉及到：Spring5、Spring Boot 2、Reactor等，目標是為專案提供簡單高效的API路由，以及強大的擴展能力：安全、監控、彈性計算等
官方架構圖如下，可見請求到來后，由Handler Mapping決定請求對應的真實目標，然后交給Web Handler，由一系列過濾器(filter)執行鏈式處理，從紅色箭頭和注釋可以發現，請求前后都有過濾器在運行：

在這里插入圖片描述

版本資訊

《Spring Cloud Gateway實戰》系列涉及的軟體和庫版本資訊如下：
本篇實戰涉及到的主要版本情況如下：

JDK：1.8.0_291
IDEA：2021.1.3 (Ultimate Edition)
maven：3.8.1
作業系統：win10 64位
springboot：2.4.2
spring-cloud：2020.0.1
spring-cloud-alibaba：2021.1

更詳細的版本匹配關系請參考：https://github.com/alibaba/spring-cloud-alibaba/wiki/版本說明

經典配置中的核心概念

先通過一個典型的簡化版配置來了解幾個核心概念，假設Spring Cloud Gateway應用正在運行，監聽8080埠，一旦有遠程請求來到8080埠，下面的配置就會生效了，三個核心概念，以及每個配置的作用，請參考中文注釋：

spring:
  cloud:
    gateway:
      # 核心概念1：路由，一個路由代表一個處理邏輯，
      # 該邏輯里面包含三個元素：匹配條件(是否該此路由處理)、真實處理地址、過濾器
      routes:
        # id要確保唯一性
      - id: add_request_header_route
      	# 真實處理地址，請求一旦確定是當前路由處理，就會轉發到這個地址去
        uri: https://example.org
        # 核心概念2：謂語或者斷言，作用是判斷請求是否由當前路由處理
        predicates:
          # 這是斷言的一種，檢查請求的Cookie中mycookie的值是否等于mycookievalue
        - Cookie=mycookie,mycookievalue
        # 核心概念3：過濾器，請求前和請求后都可以有過濾器處理請求回應資料
        filters:
          # 這個過濾器的作用是在請求header中添加一個鍵值對，值等于"aaabbbccc"
        - AddRequestHeader=X-Request-Red, aaabbbccc

上述配置資訊中的predicates是簡化版配置，和完整配置對比效果如下，簡單的說就是把一行拆成了三項：name、args.name、args.regexp

在這里插入圖片描述

理論知識點到為止，咱們還是盡快動手吧

啟動nacos-2.0.3

整個《pring Cloud Gateway實戰》系列，我們會涉及到多個服務，這就不可避免的會用到注冊中心和配置中心，這里我選擇了nacos，它可以很好地承擔注冊中心和配置中心的角色，接下來介紹如何部署和啟動nacos
下載nacos，地址是：https://github.com/alibaba/nacos/releases/download/2.0.3/nacos-server-2.0.3.zip
解壓后進入nacos\bin目錄，執行以下命令啟動nacos：

startup.cmd -m standalone

如果您的電腦是mac或者linux，請執行以下命令啟動nacos：

sh startup.sh -m standalone

瀏覽器登錄nacos，地址是http://localhost:8848/nacos，賬號和密碼都是nacos
登錄成功后顯示如下：

在這里插入圖片描述

原始碼下載

本篇實戰中的完整原始碼可在GitHub下載到，地址和鏈接資訊如下表所示(https://github.com/zq2599/blog_demos)：

名稱	鏈接	備注
專案主頁	https://github.com/zq2599/blog_demos	該專案在GitHub上的主頁
git倉庫地址(https)	https://github.com/zq2599/blog_demos.git	該專案原始碼的倉庫地址，https協議
git倉庫地址(ssh)	[email protected]:zq2599/blog_demos.git	該專案原始碼的倉庫地址，ssh協議

這個git專案中有多個檔案夾，本篇的原始碼在spring-cloud-tutorials檔案夾下，如下圖紅框所示：

在這里插入圖片描述

《Spring Cloud Gateway實戰》系列的父工程

新建名為spring-cloud-tutorials的maven工程，這就是《Spring Cloud Gateway實戰》系列所有原始碼的父工程就，pom.xml內容如下，可見這里將springboot、spring-cloud、spring-cloud-alibaba庫的版本號都已經確定，今后子工程就無需關注依賴庫的版本號了：

<?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>
    <modules>
        <module>hello-gateway</module>
        <module>provider-hello</module>
        <module>common</module>
    </modules>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.4.2</version>
        <relativePath/>
    </parent>

    <groupId>com.bolingcavalry</groupId>
    <artifactId>spring-cloud-tutorials</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <java.version>1.8</java.version>
        <spring-cloud.version>2020.0.1</spring-cloud.version>
        <spring-cloud-alibaba.version>2021.1</spring-cloud-alibaba.version>
    </properties>

    <packaging>pom</packaging>
    <description>Demo project for Spring Cloud </description>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <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>
            <dependency>
                <groupId>com.squareup.okhttp3</groupId>
                <artifactId>okhttp</artifactId>
                <version>3.14.9</version>
                <scope>compile</scope>
            </dependency>
            <dependency>
                <groupId>ch.qos.logback</groupId>
                <artifactId>logback-classic</artifactId>
                <version>1.1.7</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>1.16.16</version>
            </dependency>
        </dependencies>
    </dependencyManagement>
</project>

創建名為common的子工程，存放共用的常量和資料結構

現在創建名為common的子工程，整個《Spring Cloud Gateway實戰》系列涉及的常量和資料結構都放在這個子工程中，方便其他工程使用
新增常量Constants.java：

package com.bolingcavalry.common;

public interface Constants {
    String HELLO_PREFIX = "Hello World";
}

創建web應用，作為服務提供方

現在創建名為provider-hello的web應用，這是個極其普通的web應用，提供幾個http介面服務，咱們在嘗試Spring Cloud Gateway的基本功能時，都會將請求路由到provider-hello上來
provider-hello是個普通的springboot應用，會在nacos進行注冊，其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">
    <parent>
        <artifactId>spring-cloud-tutorials</artifactId>
        <groupId>com.bolingcavalry</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>provider-hello</artifactId>
    <packaging>jar</packaging>

    <dependencies>

        <dependency>
            <groupId>com.bolingcavalry</groupId>
            <artifactId>common</artifactId>
            <version>${project.version}</version>
        </dependency>

        <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-config</artifactId>
        </dependency>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <!-- 如果父工程不是springboot，就要用以下方式使用插件，才能生成正常的jar -->
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <mainClass>com.bolingcavalry.provider.ProviderApplication</mainClass>
                </configuration>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
</project>

工程的組態檔application.yml如下，web埠是8082，還有一處要注意的是nacos服務地址：

server:
  #服務埠
  port: 8082

spring:
  application:
    name: provider-hello
  cloud:
    nacos:
      discovery:
        # nacos服務地址
        server-addr: 127.0.0.1:8848

啟動類ProviderApplication.java

package com.bolingcavalry.provider;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

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

普通的Controller類Hello.java，對外提供一個http服務：

package com.bolingcavalry.provider.controller;

import com.bolingcavalry.common.Constants;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.text.SimpleDateFormat;
import java.util.Date;

@RestController
@RequestMapping("/hello")
public class Hello {

    private String dateStr(){
        return new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date());
    }

    /**
     * 回傳字串型別
     * @return
     */
    @GetMapping("/str")
    public String helloStr() {
        return Constants.HELLO_PREFIX + ", " + dateStr();
    }
}

新增測驗類HelloTest.java，用于檢查應用的服務是否正常：

package com.bolingcavalry.provider.controller;

import com.bolingcavalry.common.Constants;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.http.MediaType;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;

import static org.hamcrest.Matchers.containsString;
import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.content;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;

@SpringBootTest
@AutoConfigureMockMvc
@Slf4j
class HelloTest {

    @Autowired
    private MockMvc mvc;

    @Test
    void hello() throws Exception {
        String responseString = mvc.perform(MockMvcRequestBuilders.get("/hello/str").accept(MediaType.APPLICATION_JSON))
                .andExpect(status().isOk())
                .andExpect(content().string(containsString(Constants.HELLO_PREFIX)))
                .andDo(print())
                .andReturn()
                .getResponse()
                .getContentAsString();

        log.info("response in junit test :\n" + responseString);
    }
}

執行單元測驗（此時nacos是否啟動無所謂，只是不啟動的話控制臺會有一些錯誤資訊，但是沒有影響），如下，測驗通過表示服務是正常的：

在這里插入圖片描述

開發一個簡單的demo，完成spring-cloud-gateway的初體驗

前面做了那么多準備，接下來咱們會投入到Spring Cloud Gateway的開發中，先寫個簡單的demo快速體驗一下
新增名為hello-gateway的子工程，pom.xml如下，重點是依賴了spring-cloud-starter-gateway庫，還有一處要重點小心的：測驗庫用的是reactor-test和spring-boot-starter-test，這和之前的單元測驗很不一樣，用的是webflux：

<?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">
    <parent>
        <artifactId>spring-cloud-tutorials</artifactId>
        <groupId>com.bolingcavalry</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>hello-gateway</artifactId>

    <dependencies>
        <dependency>
            <groupId>com.bolingcavalry</groupId>
            <artifactId>common</artifactId>
            <version>${project.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
        </dependency>

        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-test</artifactId>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

下面是重點，Spring Cloud Gateway的組態檔application.yml：

server:
  #服務埠
  port: 8081
spring:
  application:
    name: hello-gateway
  cloud:
    gateway:
      routes:
        - id: path_route
          # 匹配成功后，會被轉發到8082埠，至于埠后面的path，會直接使用原始請求的
          # 例如http://127.0.0.1:8081/hello/str，會被轉發到http://127.0.0.1:8082/hello/str
          uri: http://127.0.0.1:8082
          predicates:
            # 根據請求路徑中帶有"/hello/"，就算匹配成功
          - Path=/hello/**

如果要轉發到其他域名下，需要創建配置類解決跨域問題：

package com.bolingcavalry.hellogateway.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.cors.CorsConfiguration;
import org.springframework.web.cors.reactive.CorsWebFilter;
import org.springframework.web.cors.reactive.UrlBasedCorsConfigurationSource;
import org.springframework.web.util.pattern.PathPatternParser;

@Configuration
public class CorsConfig {

    @Bean
    public CorsWebFilter corsFilter() {
        CorsConfiguration config = new CorsConfiguration();
        config.addAllowedMethod("*");
        config.addAllowedOrigin("*");
        config.addAllowedHeader("*");

        UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource(new PathPatternParser());
        source.registerCorsConfiguration("/**", config);

        return new CorsWebFilter(source);
    }
}

啟動類：

package com.bolingcavalry.hellogateway;

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

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

最后是單元測驗類，請注意，由于Spring Cloud Gateway使用了webflux技術堆疊，因此不能用常見的MockMvc來模擬請求，幾個注解也值得注意，另外也要注意WebTestClient的expectStatus、expectBody等API的用法：

package com.bolingcavalry.hellogateway;

import com.bolingcavalry.common.Constants;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.reactive.AutoConfigureWebTestClient;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.http.MediaType;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import org.springframework.test.web.reactive.server.WebTestClient;
import static org.junit.jupiter.api.Assertions.assertTrue;

@SpringBootTest
@ExtendWith(SpringExtension.class)
@AutoConfigureWebTestClient
public class HelloTest {

    @Autowired
    private WebTestClient webClient;

    @Test
    void testHelloPredicates() {
        webClient.get()
                .uri("/hello/str")
                .accept(MediaType.APPLICATION_JSON)
                .exchange()
                // 驗證狀態
                .expectStatus().isOk()
                // 驗證結果，注意結果是字串格式
                .expectBody(String.class).consumeWith(result  -> assertTrue(result.getResponseBody().contains(Constants.HELLO_PREFIX)));
    }
}

請確保provider-hello應用已經啟動，再運行上面創建的HelloTest.java，得到結果如下，測驗通過，證明hello-gateway的功能符合預期，成功的將請求轉發到provider-hello應用，并且成功收到回應：

在這里插入圖片描述

至此，《Spring Cloud Gateway實戰》系列的準備作業已經完成，而且開發了一個簡單的應用體驗最基本的Spring Cloud Gateway功能，接下來的文章，咱們一起實戰更多基本功能，

你不孤單，欣宸原創一路相伴

Java系列
Spring系列
Docker系列
kubernetes系列
資料庫+中間件系列
DevOps系列

歡迎關注公眾號：程式員欣宸

微信搜索「程式員欣宸」，我是欣宸，期待與您一同暢游Java世界...
https://github.com/zq2599/blog_demos

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/349473.html

標籤：Java

上一篇：貪心法（二）：貪心法的應用例題

下一篇：Fastjson 的 3 種漏洞利用鏈，一起來看看！