spring cloud - 路由gateway搭建及官方文檔詳情解析

gateway組件搭建

環(huán)境版本

spring cloud  Greenwich.SR5
spring boot   2.1.6.RELEASE
jdk           11

pom文件

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-configuration-processor</artifactId>
    <optional>true</optional>
</dependency>

項目配置文件

spring:
  application:
    name: gateway-service
  # 開啟 Gateway 服務(wù)注冊中心服務(wù)發(fā)現(xiàn)
  cloud:
    gateway:
      discovery:
        locator:
          # 自動根據(jù)服務(wù)名 提供 路由轉(zhuǎn)發(fā)
          enabled: true
          # 服務(wù)名小寫開啟
          lower-case-service-id: true
eureka:
  client:
    serviceUrl:
      defaultZone: http://eureka0:8010/eureka/, http://eureka1:8010/eureka/, http://eureka2:8010/eureka/ # eureka server的地址

logging:
  level:
    org.springframework.cloud.gateway: trace
    org.springframework.http.server.reactive: debug
    org.springframework.web.reactive: debug
    reactor.ipc.netty: debug

server:
  port: 8020

啟動類 配置 注解

@EnableEurekaClient
@SpringBootApplication
public class GatewayApplication {

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

}

gateway配置詳解

Spring Cloud Gateway 2.1.0 中文官網(wǎng)文檔

目錄

1. How to Include Spring Cloud Gateway
2. Glossary
3. How It Works
4. Route Predicate Factories
5. GatewayFilter Factories
6. Global Filters
7. TLS / SSL
8. Configuration
9. Reactor Netty Access Logs
10. CORS Configuration
11. Actuator API
12. Developer Guide

該項目提供了一個建立在Spring Ecosystem之上的API網(wǎng)關(guān)盏道,包括:Spring 5稍浆,Spring Boot 2和Project Reactor。Spring Cloud Gateway旨在提供一種簡單而有效的方式來對API進行路由,并為他們提供切面衅枫,例如:安全性嫁艇,監(jiān)控/指標 和彈性等。

1. 如何在工程中引用Spring Cloud Gateway

要在項目中引入Spring Cloud Gateway弦撩,需要引用 group org.springframework.cloud 和 artifact id為spring-cloud-starter-gateway starter步咪。最新的Spring Cloud Release 構(gòu)建信息,請參閱Spring Cloud Project page益楼。

如果應(yīng)用了該starter猾漫,但由于某種原因不希望啟用網(wǎng)關(guān)蹋绽,請進行設(shè)置spring.cloud.gateway.enabled=false哮内。

重要 Spring Cloud Gateway依賴Spring Boot和Spring Webflux提供的Netty runtime凹联。它不能在傳統(tǒng)的Servlet容器中工作或構(gòu)建為WAR

2. 詞匯表
  • Route 路由:gateway的基本構(gòu)建模塊援制。它由ID钝域、目標URI迄汛、斷言集合和過濾器集合組成妥箕。如果聚合斷言結(jié)果為真连躏,則匹配到該路由萨惑。
  • Predicate 斷言:這是一個Java 8 Function Predicate捐康。輸入類型是 Spring Framework ServerWebExchange。這允許開發(fā)人員可以匹配來自HTTP請求的任何內(nèi)容庸蔼,例如Header或參數(shù)解总。
  • Filter 過濾器:這些是使用特定工廠構(gòu)建的 Spring FrameworkGatewayFilter實例。所以可以在返回請求之前或之后修改請求和響應(yīng)的內(nèi)容姐仅。
3. 如何工作的
image.png

Spring Cloud Gateway Diagram

客戶端向Spring Cloud Gateway發(fā)出請求花枫。如果Gateway Handler Mapping確定請求與路由匹配,則將其發(fā)送到Gateway Web Handler掏膏。此handler通過特定于該請求的過濾器鏈處理請求劳翰。圖中filters被虛線劃分的原因是filters可以在發(fā)送代理請求之前或之后執(zhí)行邏輯。先執(zhí)行所有“pre filter”邏輯馒疹,然后進行請求代理佳簸。在請求代理執(zhí)行完后,執(zhí)行“post filter”邏輯颖变。

注意 HTTP和HTTPS URI默認端口設(shè)置是80和443生均。

4. 路由斷言Factories

Spring Cloud Gateway將路由作為Spring WebFlux HandlerMapping基礎(chǔ)結(jié)構(gòu)的一部分進行匹配。Spring Cloud Gateway包含許多內(nèi)置的路由斷言Factories腥刹。這些斷言都匹配HTTP請求的不同屬性马胧。多個路由斷言Factories可以通過 and 組合使用。

4.1 After 路由斷言 Factory

After Route Predicate Factory采用一個參數(shù)——日期時間衔峰。在該日期時間之后發(fā)生的請求都將被匹配佩脊。

application.yml

spring:
  cloud:
    gateway:
      routes:
      - id: after_route
        uri: http://example.org
        predicates:
        - After=2017-01-20T17:42:47.789-07:00[America/Denver]
4.2 Before 路由斷言 Factory

Before Route Predicate Factory采用一個參數(shù)——日期時間蛙粘。在該日期時間之前發(fā)生的請求都將被匹配。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: before_route
        uri: http://example.org
        predicates:
        - Before=2017-01-20T17:42:47.789-07:00[America/Denver]
4.3 Between 路由斷言 Factory

Between 路由斷言 Factory有兩個參數(shù)威彰,datetime1和datetime2出牧。在datetime1和datetime2之間的請求將被匹配。datetime2參數(shù)的實際時間必須在datetime1之后抱冷。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: between_route
        uri: http://example.org
        predicates:
        - Between=2017-01-20T17:42:47.789-07:00[America/Denver], 2017-01-21T17:42:47.789-07:00[America/Denver]
4.4 Cookie 路由斷言 Factory

Cookie 路由斷言 Factory有兩個參數(shù)崔列,cookie名稱和正則表達式梢褐。請求包含次cookie名稱且正則表達式為真的將會被匹配旺遮。

application.yml

spring:
  cloud:
    gateway:
      routes:
      - id: cookie_route
        uri: http://example.org
        predicates:
        - Cookie=chocolate, ch.p
4.5 Header 路由斷言 Factory

Header 路由斷言 Factory有兩個參數(shù),header名稱和正則表達式盈咳。請求包含次header名稱且正則表達式為真的將會被匹配耿眉。

application.yml.

spring:
 cloud:
   gateway:
     routes:
     - id: header_route
       uri: http://example.org
       predicates:
       - Header=X-Request-Id, \d+
4.6 Host 路由斷言 Factory

Host 路由斷言 Factory包括一個參數(shù):host name列表。使用Ant路徑匹配規(guī)則鱼响,.作為分隔符鸣剪。 application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: host_route
        uri: http://example.org
        predicates:
        - Host=**.somehost.org,**.anotherhost.org
4.7 Method 路由斷言 Factory

Method 路由斷言 Factory只包含一個參數(shù): 需要匹配的HTTP請求方式

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: method_route
        uri: http://example.org
        predicates:
        - Method=GET

所有GET請求都將被路由

4.8 Path 路由斷言 Factory

Path 路由斷言 Factory 有2個參數(shù): 一個Spring PathMatcher表達式列表和可選matchOptionalTrailingSeparator標識 .

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: host_route
        uri: http://example.org
        predicates:
        - Path=/foo/{segment},/bar/{segment}

例如: /foo/1 or /foo/bar or /bar/baz的請求都將被匹配

URI 模板變量 (如上例中的 segment ) 將以Map的方式保存于ServerWebExchange.getAttributes() key為ServerWebExchangeUtils.URI_TEMPLATE_VARIABLES_ATTRIBUTE. 這些值將在GatewayFilter Factories使用

可以使用以下方法來更方便地訪問這些變量。

Map<String, String> uriVariables = ServerWebExchangeUtils.getPathPredicateVariables(exchange);

String segment = uriVariables.get("segment");
4.9 Query 路由斷言 Factory

Query 路由斷言 Factory 有2個參數(shù): 必選項 param 和可選項 regexp.

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: query_route
        uri: http://example.org
        predicates:
        - Query=baz

則包含了請求參數(shù) baz的都將被匹配丈积。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: query_route
        uri: http://example.org
        predicates:
        - Query=foo, ba.

如果請求參數(shù)里包含foo參數(shù)筐骇,并且值匹配為ba. 表達式,則將會被路由江滨,如:bar and baz

4.10 RemoteAddr 路由斷言 Factory

RemoteAddr 路由斷言 Factory的參數(shù)為 一個CIDR符號(IPv4或IPv6)字符串的列表铛纬,最小值為1,例如192.168.0.1/16(其中192.168.0.1是IP地址并且16是子網(wǎng)掩碼)唬滑。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: remoteaddr_route
        uri: http://example.org
        predicates:
        - RemoteAddr=192.168.1.1/24

如果請求的remote address 為 192.168.1.10則將被路由

4.10.1 修改遠程地址的解析方式

默認情況下告唆,RemoteAddr 路由斷言 Factory使用傳入請求中的remote address。如果Spring Cloud Gateway位于代理層后面晶密,則可能與實際客戶端IP地址不匹配擒悬。

可以通過設(shè)置自定義RemoteAddressResolver來自定義解析遠程地址的方式。Spring Cloud Gateway網(wǎng)關(guān)附帶一個非默認遠程地址解析程序稻艰,它基于X-Forwarded-For header, XForwardedRemoteAddressResolver.

XForwardedRemoteAddressResolver 有兩個靜態(tài)構(gòu)造函數(shù)方法懂牧,采用不同的安全方法:

  1. XForwardedRemoteAddressResolver::TrustAll返回一個RemoteAddressResolver,它始終采用X-Forwarded-for頭中找到的第一個IP地址尊勿。這種方法容易受到欺騙归苍,因為惡意客戶端可能會為解析程序接受的“x-forwarded-for”設(shè)置初始值。
  2. XForwardedRemoteAddressResolver::MaxTrustedIndex獲取一個索引运怖,該索引與在Spring Cloud網(wǎng)關(guān)前運行的受信任基礎(chǔ)設(shè)施數(shù)量相關(guān)拼弃。例如,如果SpringCloudGateway只能通過haproxy訪問摇展,則應(yīng)使用值1吻氧。如果在訪問Spring Cloud Gateway之前需要兩個受信任的基礎(chǔ)架構(gòu)躍點,那么應(yīng)該使用2。

給定以下的header值:

X-Forwarded-For: 0.0.0.1, 0.0.0.2, 0.0.0.3

下面的` maxTrustedIndex值將生成以下遠程地址:

image.png

image.png

Java 配置方式:

GatewayConfig.java

RemoteAddressResolver resolver = XForwardedRemoteAddressResolver
    .maxTrustedIndex(1);

...

.route("direct-route",
    r -> r.remoteAddr("10.1.1.1", "10.10.1.1/24")
        .uri("https://downstream1")
.route("proxied-route",
    r -> r.remoteAddr(resolver,  "10.10.1.1", "10.10.1.1/24")
        .uri("https://downstream2")
)
5. GatewayFilter Factories

過濾器允許以某種方式修改傳入的HTTP請求或返回的HTTP響應(yīng)盯孙。過濾器的作用域是某些特定路由鲁森。Spring Cloud Gateway包括許多內(nèi)置的 Filter工廠。

注意:有關(guān)如何使用以下任何過濾器的更詳細示例振惰,請查看unit tests.歌溉。

5.1 AddRequestHeader GatewayFilter Factory

采用一對名稱和值作為參數(shù) application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: add_request_header_route
        uri: http://example.org
        filters:
        - AddRequestHeader=X-Request-Foo, Bar

對于所有匹配的請求,這將向下游請求的頭中添加 x-request-foo:bar header

5.2 AddRequestParameter GatewayFilter Factory

采用一對名稱和值作為參數(shù) application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: add_request_parameter_route
        uri: http://example.org
        filters:
        - AddRequestParameter=foo, bar

對于所有匹配的請求骑晶,這將向下游請求添加foo=bar查詢字符串

5.3 AddResponseHeader GatewayFilter Factory

采用一對名稱和值作為參數(shù)

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: add_request_header_route
        uri: http://example.org
        filters:
        - AddResponseHeader=X-Response-Foo, Bar

對于所有匹配的請求痛垛,這會將x-response-foo:bar頭添加到下游響應(yīng)的header中

5.4 Hystrix GatewayFilter Factory

Hystrix 是Netflix開源的斷路器組件。Hystrix GatewayFilter允許你向網(wǎng)關(guān)路由引入斷路器桶蛔,保護你的服務(wù)不受級聯(lián)故障的影響匙头,并允許你在下游故障時提供fallback響應(yīng)。

要在項目中啟用Hystrix網(wǎng)關(guān)過濾器仔雷,需要添加對 spring-cloud-starter-netflix-hystrix的依賴 Spring Cloud Netflix.

Hystrix GatewayFilter Factory 需要一個name參數(shù)蹂析,即HystrixCommand的名稱。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: hystrix_route
        uri: http://example.org
        filters:
        - Hystrix=myCommandName

這將剩余的過濾器包裝在命令名為“myCommandName”的HystrixCommand中碟婆。

hystrix過濾器還可以接受可選的fallbackUri 參數(shù)电抚。目前,僅支持forward: 預(yù)設(shè)的URI竖共,如果調(diào)用fallback蝙叛,則請求將轉(zhuǎn)發(fā)到與URI匹配的控制器。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: hystrix_route
        uri: lb://backing-service:8088
        predicates:
        - Path=/consumingserviceendpoint
        filters:
        - name: Hystrix
          args:
            name: fallbackcmd
            fallbackUri: forward:/incaseoffailureusethis
        - RewritePath=/consumingserviceendpoint, /backingserviceendpoint

當調(diào)用hystrix fallback時肘迎,這將轉(zhuǎn)發(fā)到/incaseoffailureusethis uri甥温。注意,這個示例還演示了(可選)通過目標URI上的'lb`前綴,使用Spring Cloud Netflix Ribbon 客戶端負載均衡妓布。

主要場景是使用fallbackUri 到網(wǎng)關(guān)應(yīng)用程序中的內(nèi)部控制器或處理程序姻蚓。但是,也可以將請求重新路由到外部應(yīng)用程序中的控制器或處理程序匣沼,如:

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: ingredients
        uri: lb://ingredients
        predicates:
        - Path=//ingredients/**
        filters:
        - name: Hystrix
          args:
            name: fetchIngredients
            fallbackUri: forward:/fallback
      - id: ingredients-fallback
        uri: http://localhost:9994
        predicates:
        - Path=/fallback

在本例中狰挡,gateway應(yīng)用程序中沒有 fallback 實現(xiàn),但是另一個應(yīng)用程序中有一個接口實現(xiàn)释涛,注冊為“http://localhost:9994”加叁。

在將請求轉(zhuǎn)發(fā)到fallback的情況下,Hystrix Gateway過濾還支持直接拋出Throwable 唇撬。它被作為ServerWebExchangeUtils.HYSTRIX_EXECUTION_EXCEPTION_ATTR屬性添加到ServerWebExchange中它匕,可以在處理網(wǎng)關(guān)應(yīng)用程序中的fallback時使用。

對于外部控制器/處理程序方案窖认,可以添加帶有異常詳細信息的header豫柬「嫦#可以在 FallbackHeaders GatewayFilter Factory section.中找到有關(guān)它的更多信息。

hystrix配置參數(shù)(如 timeouts)可以使用全局默認值配置烧给,也可以使用Hystrix wiki中所述屬性進行配置燕偶。

要為上面的示例路由設(shè)置5秒超時,將使用以下配置:

application.yml.

hystrix.command.fallbackcmd.execution.isolation.thread.timeoutInMilliseconds: 5000
5.5 FallbackHeaders GatewayFilter Factory

FallbackHeaders允許在轉(zhuǎn)發(fā)到外部應(yīng)用程序中的FallbackUri的請求的header中添加Hystrix異常詳細信息础嫡,如下所示:

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: ingredients
        uri: lb://ingredients
        predicates:
        - Path=//ingredients/**
        filters:
        - name: Hystrix
          args:
            name: fetchIngredients
            fallbackUri: forward:/fallback
      - id: ingredients-fallback
        uri: http://localhost:9994
        predicates:
        - Path=/fallback
        filters:
        - name: FallbackHeaders
          args:
            executionExceptionTypeHeaderName: Test-Header

在本例中指么,在運行HystrixCommand發(fā)生執(zhí)行異常后,請求將被轉(zhuǎn)發(fā)到 localhost:9994應(yīng)用程序中的 fallback終端或程序榴鼎。異常類型伯诬、消息(如果可用)cause exception類型和消息的頭,將由FallbackHeaders filter添加到該請求中檬贰。

通過設(shè)置下面列出的參數(shù)值及其默認值姑廉,可以在配置中覆蓋headers的名稱:

  • executionExceptionTypeHeaderName ("Execution-Exception-Type")
  • executionExceptionMessageHeaderName ("Execution-Exception-Message")
  • rootCauseExceptionTypeHeaderName ("Root-Cause-Exception-Type")
  • rootCauseExceptionMessageHeaderName ("Root-Cause-Exception-Message")

Hystrix 如何實現(xiàn)的更多細節(jié)可以參考 Hystrix GatewayFilter Factory section.

5.6 PrefixPath GatewayFilter Factory

PrefixPath GatewayFilter 只有一個 prefix 參數(shù).

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: prefixpath_route
        uri: http://example.org
        filters:
        - PrefixPath=/mypath

這將給所有匹配請求的路徑加前綴/mypath缺亮。因此翁涤,向/hello發(fā)送的請求將發(fā)送到/mypath/hello

5.7 PreserveHostHeader GatewayFilter Factory

該filter沒有參數(shù)萌踱。設(shè)置了該Filter后葵礼,GatewayFilter將不使用由HTTP客戶端確定的host header ,而是發(fā)送原始host header 并鸵。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: preserve_host_route
        uri: http://example.org
        filters:
        - PreserveHostHeader
5.8 RequestRateLimiter GatewayFilter Factory

RequestRateLimiter使用RateLimiter實現(xiàn)是否允許繼續(xù)執(zhí)行當前請求鸳粉。如果不允許繼續(xù)執(zhí)行,則返回HTTP 429 - Too Many Requests (默認情況下)园担。

這個過濾器可以配置一個可選的keyResolver 參數(shù)和rate limiter參數(shù)(見下文)届谈。

keyResolverKeyResolver 接口的實現(xiàn)類.在配置中,按名稱使用SpEL引用bean弯汰。#{@myKeyResolver} 是引用名為'myKeyResolver'的bean的SpEL表達式艰山。

KeyResolver.java.

public interface KeyResolver {
    Mono<String> resolve(ServerWebExchange exchange);
}

KeyResolver接口允許使用可插拔策略來派生限制請求的key。在未來的里程碑版本中咏闪,將有一些KeyResolver實現(xiàn)曙搬。

KeyResolver的默認實現(xiàn)是PrincipalNameKeyResolver,它從ServerWebExchange檢索Principal并調(diào)用Principal.getName()鸽嫂。

默認情況下纵装,如果KeyResolver 沒有獲取到key,請求將被拒絕据某。此行為可以使用 spring.cloud.gateway.filter.request-rate-limiter.deny-empty-key (true or false) 和 spring.cloud.gateway.filter.request-rate-limiter.empty-key-status-code屬性進行調(diào)整橡娄。

說明 無法通過"shortcut" 配置RequestRateLimiter。以下示例無效

application.properties.

# INVALID SHORTCUT CONFIGURATION
spring.cloud.gateway.routes[0].filters[0]=RequestRateLimiter=2, 2, #{@userkeyresolver}
5.8.1 Redis RateLimiter

Redis的實現(xiàn)基于 Stripe實現(xiàn)癣籽。它需要使用 spring-boot-starter-data-redis-reactive Spring Boot starter挽唉。

使用的算法是Token Bucket Algorithm.扳还。

redis-rate-limiter.replenishRate是你允許用戶每秒執(zhí)行多少請求,而丟棄任何請求橱夭。這是令牌桶的填充速率氨距。

``redis-rate-limiter.burstCapacity`是允許用戶在一秒鐘內(nèi)執(zhí)行的最大請求數(shù)。這是令牌桶可以保存的令牌數(shù)棘劣。將此值設(shè)置為零將阻止所有請求俏让。

穩(wěn)定速率是通過在replenishRateburstCapacity中設(shè)置相同的值來實現(xiàn)的〔缦荆可通過設(shè)置burstCapacity高于replenishRate來允許臨時突發(fā)流浪首昔。在這種情況下,限流器需要在兩次突發(fā)之間留出一段時間(根據(jù)replenishRate)糙俗,因為連續(xù)兩次突發(fā)將導(dǎo)致請求丟失 (HTTP 429 - Too Many Requests).勒奇。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: requestratelimiter_route
        uri: http://example.org
        filters:
        - name: RequestRateLimiter
          args:
            redis-rate-limiter.replenishRate: 10
            redis-rate-limiter.burstCapacity: 20

Config.java.

@Bean
KeyResolver userKeyResolver() {
    return exchange -> Mono.just(exchange.getRequest().getQueryParams().getFirst("user"));
}

這定義了每個用戶10個請求的限制。允許20個突發(fā)巧骚,但下一秒只有10個請求可用赊颠。KeyResolver是一個簡單的獲取user請求參數(shù)的工具(注意:不建議用于生產(chǎn))。

限流器也可以定義為RateLimiter接口的實現(xiàn) bean劈彪。在配置中竣蹦,按名稱使用SpEL引用bean。#{@myRateLimiter}是引用名為'myRateLimiter'的bean的SpEL表達式沧奴。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: requestratelimiter_route
        uri: http://example.org
        filters:
        - name: RequestRateLimiter
          args:
            rate-limiter: "#{@myRateLimiter}"
            key-resolver: "#{@userKeyResolver}"
5.9 RedirectTo GatewayFilter Factory

該過濾器有一個 status 和一個 url參數(shù)痘括。status是300類重定向HTTP代碼,如301滔吠。該URL應(yīng)為有效的URL纲菌,這將是 Location header的值。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: prefixpath_route
        uri: http://example.org
        filters:
        - RedirectTo=302, http://acme.org

這將發(fā)送一個302狀態(tài)碼和一個Location:http://acme.org header來執(zhí)行重定向疮绷。

5.10 RemoveNonProxyHeaders GatewayFilter Factory

RemoveNonProxyHeaders GatewayFilter Factory 從轉(zhuǎn)發(fā)請求中刪除headers翰舌。刪除的默認頭列表來自 IETF.

The default removed headers are:

  • Connection
  • Keep-Alive
  • Proxy-Authenticate
  • Proxy-Authorization
  • TE
  • Trailer
  • Transfer-Encoding
  • Upgrade 要更改此設(shè)置,請將 spring.cloud.gateway.filter.remove-non-proxy-headers.headers屬性設(shè)置為要刪除的header名稱矗愧。
5.11 RemoveRequestHeader GatewayFilter Factory

有一個name參數(shù). 這是要刪除的header的名稱灶芝。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: removerequestheader_route
        uri: http://example.org
        filters:
        - RemoveRequestHeader=X-Request-Foo

這將在X-Request-Foo header被發(fā)送到下游之前刪除它。

5.12 RemoveResponseHeader GatewayFilter Factory

有一個name參數(shù). 這是要刪除的header的名稱唉韭。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: removeresponseheader_route
        uri: http://example.org
        filters:
        - RemoveResponseHeader=X-Response-Foo

這將在返回到網(wǎng)關(guān)client之前從響應(yīng)中刪除x-response-foo頭夜涕。

5.13 RewritePath GatewayFilter Factory

包含一個 regexp正則表達式參數(shù)和一個 replacement 參數(shù). 通過使用Java正則表達式靈活地重寫請求路徑。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: rewritepath_route
        uri: http://example.org
        predicates:
        - Path=/foo/**
        filters:
        - RewritePath=/foo/(?<segment>.*), /$\{segment}

對于請求路徑/foo/bar属愤,將在發(fā)出下游請求之前將路徑設(shè)置為/bar女器。注意,由于YAML規(guī)范,請使用 $\替換 $住诸。

5.14 RewriteResponseHeader GatewayFilter Factory

包含 name, regexpreplacement 參數(shù).驾胆。通過使用Java正則表達式靈活地重寫響應(yīng)頭的值涣澡。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: rewriteresponseheader_route
        uri: http://example.org
        filters:
        - RewriteResponseHeader=X-Response-Foo, , password=[^&]+, password=***

對于一個/42?user=ford&password=omg!what&flag=true的header值,在做下游請求時將被設(shè)置為/42?user=ford&password=***&flag=true丧诺,由于YAML規(guī)范入桂,請使用 $\替換 $

5.15 SaveSession GatewayFilter Factory

SaveSession GatewayFilter Factory將調(diào)用轉(zhuǎn)發(fā)到下游之強制執(zhí)行WebSession::save 操作驳阎。這在使用 Spring Session 之類時特別有用抗愁,需要確保會話狀態(tài)在進行轉(zhuǎn)發(fā)調(diào)用之前已保存。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: save_session
        uri: http://example.org
        predicates:
        - Path=/foo/**
        filters:
        - SaveSession

如果你希望要將[Spring Security](https://projects.spring.io/Spring Security/)與Spring Session集成,并確保安全詳細信息已轉(zhuǎn)發(fā)到遠程的進程呵晚,這一點至關(guān)重要蜘腌。

5.16 SecureHeaders GatewayFilter Factory

SecureHeaders GatewayFilter Factory 將許多headers添加到reccomedation處的響應(yīng)中,從this blog post.

添加以下標題(使用默認值分配):

  • X-Xss-Protection:1; mode=block
  • Strict-Transport-Security:max-age=631138519
  • X-Frame-Options:DENY
  • X-Content-Type-Options:nosniff
  • Referrer-Policy:no-referrer
  • Content-Security-Policy:default-src 'self' https:; font-src 'self' https: data:; img-src 'self' https: data:; object-src 'none'; script-src https:; style-src 'self' https: 'unsafe-inline'
  • X-Download-Options:noopen
  • X-Permitted-Cross-Domain-Policies:none

要更改默認值饵隙,請在spring.cloud.gateway.filter.secure-headers 命名空間中設(shè)置相應(yīng)的屬性:

Property to change:

  • xss-protection-header
  • strict-transport-security
  • frame-options
  • content-type-options
  • referrer-policy
  • content-security-policy
  • download-options
  • permitted-cross-domain-policies
5.17 SetPath GatewayFilter Factory

SetPath GatewayFilter Factory 采用 template路徑參數(shù)撮珠。它提供了一種通過允許路徑的模板化segments來操作請求路徑的簡單方法。使用Spring Framework中的URI模板金矛,允許多個匹配segments芯急。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: setpath_route
        uri: http://example.org
        predicates:
        - Path=/foo/{segment}
        filters:
        - SetPath=/{segment}

對于一個 /foo/bar請求,在做下游請求前绷柒,路徑將被設(shè)置為/bar

5.18 SetResponseHeader GatewayFilter Factory

SetResponseHeader GatewayFilter Factory 包括 namevalue 參數(shù).

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: setresponseheader_route
        uri: http://example.org
        filters:
        - SetResponseHeader=X-Response-Foo, Bar

此GatewayFilter使用給定的名稱替換所有header志于,而不是添加涮因。因此废睦,如果下游服務(wù)器響應(yīng)為X-Response-Foo:1234,則會將其替換為X-Response-Foo:Bar,這是網(wǎng)關(guān)客戶端將接收的內(nèi)容养泡。

5.19 SetStatus GatewayFilter Factory

SetStatus GatewayFilter Factory 包括唯一的 status參數(shù).必須是一個可用的Spring HttpStatus嗜湃。它可以是整數(shù)值404或字符串枚舉NOT_FOUND

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: setstatusstring_route
        uri: http://example.org
        filters:
        - SetStatus=BAD_REQUEST
      - id: setstatusint_route
        uri: http://example.org
        filters:
        - SetStatus=401

在這個例子中澜掩,HTTP返回碼將設(shè)置為401.

5.20 StripPrefix GatewayFilter Factory

StripPrefix GatewayFilter Factory 包括一個parts參數(shù)购披。 parts參數(shù)指示在將請求發(fā)送到下游之前,要從請求中去除的路徑中的節(jié)數(shù)肩榕。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: nameRoot
        uri: http://nameservice
        predicates:
        - Path=/name/**
        filters:
        - StripPrefix=2

當通過網(wǎng)關(guān)發(fā)出/name/bar/foo請求時刚陡,向nameservice發(fā)出的請求將是http://nameservice/foo

5.21 Retry GatewayFilter Factory

Retry GatewayFilter Factory包括 retries, statuses, methodsseries 參數(shù).

  • retries: 應(yīng)嘗試的重試次數(shù)
  • statuses: 應(yīng)該重試的HTTP狀態(tài)代碼株汉,用org.springframework.http.HttpStatus標識
  • methods: 應(yīng)該重試的HTTP方法筐乳,用 org.springframework.http.HttpMethod標識
  • series: 要重試的一系列狀態(tài)碼,用 org.springframework.http.HttpStatus.Series標識

application.yml.

spring: cloud: gateway: routes: - id: retry_test uri: http://localhost:8080/flakey predicates: - Host=*.retry.com filters: - name: Retry args: retries: 3 statuses: BAD_GATEWAY

注意 retry filter 不支持body請求的重試乔妈,如通過body的POST 或 PUT請求

注意 在使用帶有前綴為 forward:retry filter時蝙云,應(yīng)仔細編寫目標端點,以便在出現(xiàn)錯誤時不會執(zhí)行任何可能導(dǎo)致將響應(yīng)發(fā)送到客戶端并提交的操作路召。例如勃刨,如果目標端點是帶注解的controller波材,則目標controller方法不應(yīng)返回帶有錯誤狀態(tài)代碼的ResponseEntity。相反身隐,它應(yīng)該拋出一個Exception廷区,或者發(fā)出一個錯誤信號,例如通過Mono.error(ex) 返回值贾铝,重試過濾器可以配置為通過重試來處理躲因。

5.22 RequestSize GatewayFilter Factory

當請求大小大于允許的限制時,RequestSize GatewayFilter Factory可以限制請求不到達下游服務(wù)忌傻。過濾器以RequestSize作為參數(shù)大脉,這是定義請求的允許大小限制(以字節(jié)為單位)。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: request_size_route
      uri: http://localhost:8080/upload
      predicates:
      - Path=/upload
      filters:
      - name: RequestSize
        args:
          maxSize: 5000000

當請求因大小而被拒絕時水孩, RequestSize GatewayFilter Factory 將響應(yīng)狀態(tài)設(shè)置為413 Payload Too Large镰矿,并帶有額外的header errorMessage 。下面是一個 errorMessage的例子俘种。

errorMessage` : `Request size is larger than permissible limit. Request size is 6.0 MB where permissible limit is 5.0 MB

注意 如果未在路由定義中作為filter參數(shù)提供秤标,則默認請求大小將設(shè)置為5 MB。

5.23 Modify Request Body GatewayFilter Factory

這個過濾器被定義為beta版本宙刘,將來API可能會改變苍姜。

此過濾器可用于在請求主體被網(wǎng)關(guān)發(fā)送到下游之前對其進行修改。

注意 只能使用Java DSL配置此過濾器

@Bean
public RouteLocator routes(RouteLocatorBuilder builder) {
    return builder.routes()
        .route("rewrite_request_obj", r -> r.host("*.rewriterequestobj.org")
            .filters(f -> f.prefixPath("/httpbin")
                .modifyRequestBody(String.class, Hello.class, MediaType.APPLICATION_JSON_VALUE,
                    (exchange, s) -> return Mono.just(new Hello(s.toUpperCase())))).uri(uri))
        .build();
}

static class Hello {
    String message;

    public Hello() { }

    public Hello(String message) {
        this.message = message;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }
}
5.24 Modify Response Body GatewayFilter Factory

這個過濾器被定義為beta版本悬包,將來API可能會改變衙猪。 此過濾器可用于在將響應(yīng)正文發(fā)送回客戶端之前對其進行修改。

注意 只能使用Java DSL配置此過濾器

@Bean
public RouteLocator routes(RouteLocatorBuilder builder) {
    return builder.routes()
        .route("rewrite_response_upper", r -> r.host("*.rewriteresponseupper.org")
            .filters(f -> f.prefixPath("/httpbin")
                .modifyResponseBody(String.class, String.class,
                    (exchange, s) -> Mono.just(s.toUpperCase()))).uri(uri)
        .build();
}
6. Global Filters

GlobalFilter接口與GatewayFilter具有相同的簽名布近。是有條件地應(yīng)用于所有路由的特殊過濾器垫释。(此接口和用法可能在將來的里程碑版本中發(fā)生更改)。

6.1 全局Filter和GatewayFilter組合排序

當請求進入(并與路由匹配)時撑瞧,篩選Web Handler 會將GlobalFilter的所有實例和所有的GatewayFilter路由特定實例添加到 filter chain棵譬。filter組合的排序由org.springframework.core.Ordered接口決定,可以通過實現(xiàn)getOrde()方法或使用@Order注釋來設(shè)置预伺。

由于Spring Cloud Gateway將用于執(zhí)行過濾器邏輯區(qū)分為“前置”和“后置”階段订咸,具有最高優(yōu)先級的過濾器將是“前置”階段的第一個,而“后置”階段的最后一個酬诀。

ExampleConfiguration.java.

@Bean
@Order(-1)
public GlobalFilter a() {
    return (exchange, chain) -> {
        log.info("first pre filter");
        return chain.filter(exchange).then(Mono.fromRunnable(() -> {
            log.info("third post filter");
        }));
    };
}

@Bean
@Order(0)
public GlobalFilter b() {
    return (exchange, chain) -> {
        log.info("second pre filter");
        return chain.filter(exchange).then(Mono.fromRunnable(() -> {
            log.info("second post filter");
        }));
    };
}

@Bean
@Order(1)
public GlobalFilter c() {
    return (exchange, chain) -> {
        log.info("third pre filter");
        return chain.filter(exchange).then(Mono.fromRunnable(() -> {
            log.info("first post filter");
        }));
    };
}
6.2 Forward Routing Filter

ForwardRoutingFilter在exchange屬性ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR中查找URI脏嚷。如果URL有一個forwardscheme (如 forward:///localendpoint),它將使用Spring DispatcherHandler 來處理請求料滥。請求URL的路徑部分將被轉(zhuǎn)發(fā)URL中的路徑覆蓋然眼。未修改的原始URL將附加到 ServerWebExchangeUtils.GATEWAY_ORIGINAL_REQUEST_URL_ATTR屬性中的列表中。

6.3 LoadBalancerClient Filter

LoadBalancerClientFilter在exchange屬性ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR中查找URI葵腹。如果URL有一個lbscheme (如 lb://myservice)高每,它將使用Spring Cloud LoadBalancerClient 將名稱(在前一個示例中為'myservice)解析為實際主機和端口屿岂,并替換URI。未修改的原始URL將附加到ServerWebExchangeUtils.GATEWAY_ORIGINAL_REQUEST_URL_ATTR屬性中的列表中鲸匿。過濾器還將查看ServerWebExchangeUtils.GATEWAY_SCHEME_PREFIX_ATTR屬性爷怀,查看它是否等于lb`,然后應(yīng)用相同的規(guī)則带欢。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: myRoute
        uri: lb://service
        predicates:
        - Path=/service/**

注意 默認情況下运授,如果一個服務(wù)實例在LoadBalancer 中沒有發(fā)現(xiàn),則返回503乔煞∮蹼可以通過設(shè)置spring.cloud.gateway.loadbalancer.use404=true來讓網(wǎng)管返回404.

注意

LoadBalancer返回的ServiceInstanceisSecure 值將覆蓋在對網(wǎng)關(guān)發(fā)出的請求中指定的scheme。例如渡贾,如果請求通過HTTPS進入網(wǎng)關(guān)逗宜,但ServiceInstance表示它不安全,則下游請求將通過HTTP協(xié)議空骚。相反的情況也適用纺讲。但是,如果在網(wǎng)關(guān)配置中為路由指定了GATEWAY_SCHEME_PREFIX_ATTR囤屹,則前綴將被刪除熬甚,并且路由URL生成的scheme將覆蓋ServiceInstance配置。

6.4 Netty Routing Filter

如果位于 ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR屬性中的URL具有httphttps 模式肋坚,則會運行Netty Routing Filter乡括。它使用Netty HttpClient 發(fā)出下游代理請求袜硫。響應(yīng)放在 ServerWebExchangeUtils.CLIENT_RESPONSE_ATTR exchange屬性中木缝,以便在以后的過濾器中使用。(有一個實驗階段不需要Netty的相同的功能的Filter,WebClientHttpRoutingFilter

6.5 Netty Write Response Filter

如果ServerWebExchangeUtils.CLIENT_RESPONSE_ATTR exchange屬性中存在 Netty HttpClientResponse峦剔,則運行 NettyWriteResponseFilter 。它在其他所有過濾器完成后將代理響應(yīng)寫回網(wǎng)關(guān)客戶端響應(yīng)之后運行角钩。(有一個不需要netty的實驗性的WebClientWriteResponseFilter執(zhí)行相同的功能)

6.6 RouteToRequestUrl Filter

如果ServerWebExchangeUtils.GATEWAY_ROUTE_ATTR exchange屬性中存在Route對象吝沫,RouteToRequestUrlFilter將運行。它基于請求URI創(chuàng)建一個新的URI递礼,使用Route對象的uri屬性進行更新惨险。新的URI被放置在ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR exchange屬性中。

如果該URI有一個前綴scheme脊髓,例如lb:ws://serviceid辫愉,則會從該URI中剝離該 lb scheme,并將其放置在ServerWebExchangeUtils.GATEWAY_SCHEME_PREFIX_ATTR中将硝,以便稍后在過濾器鏈中使用恭朗。

6.7 Websocket Routing Filter

如果ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTRexchange屬性中有 ws 屏镊、 wssscheme,則Websocket Routing Filter將被運行痰腮。它使用Spring Web Socket基礎(chǔ)模塊將Websocket轉(zhuǎn)發(fā)到下游而芥。

URI前綴為lb的Websockets可以被負載均衡,如 lb:ws://serviceid.

注意 如果使用 SockJS 作為普通HTTP的fallback膀值,則應(yīng)配置普通HTTP路由以及WebSocket路由棍丐。

application.yml.

spring:
  cloud:
    gateway:
      routes:
      # SockJS route
      - id: websocket_sockjs_route
        uri: http://localhost:3001
        predicates:
        - Path=/websocket/info/**
      # Normwal Websocket route
      - id: websocket_route
        uri: ws://localhost:3001
        predicates:
        - Path=/websocket/**
6.8 Gateway Metrics Filter

要啟用網(wǎng)關(guān)指標,請將spring-boot-starter-actuator添加為項目依賴項沧踏。然后歌逢,默認情況下,只要屬性spring.cloud.gateway.metrics.enabled未設(shè)置為false翘狱,網(wǎng)關(guān)指標過濾器就會運行趋翻。此過濾器添加名為“gateway.requests”的計時器指標,并帶有以下標記:

  • routeId: The route id
  • routeUri: API 將被轉(zhuǎn)發(fā)的URI
  • outcome: 結(jié)果分類依據(jù) HttpStatus.Series
  • status: 返回client的請求的Http Status

這些指標可以從/actuator/metrics/gateway.requests中獲取盒蟆,可以很容易地與Prometheus集成以創(chuàng)建Grafana dashboard.

注意 要將pometheus啟用踏烙,需要添加 micrometer-registry-prometheus為項目依賴。

6.9 Making An Exchange As Routed

網(wǎng)關(guān)路由ServerWebExchange之后历等,它將通過向Exchange屬性添加gatewayAlreadyRouted讨惩,將該exchange標記為“routed”。一旦一個請求被標記為routed寒屯,其他路由過濾器將不會再次路由該請求荐捻,將跳過該過濾器。有一些方便的方法可以用來將exchange標記為routed寡夹,或者檢查exchange是否已經(jīng)routed处面。

  • ServerWebExchangeUtils.isAlreadyRouted 有一個 ServerWebExchange對象并檢查它是否已"routed"
  • ServerWebExchangeUtils.setAlreadyRouted 有一個 ServerWebExchange 對象并將其標記為"routed"
7. TLS / SSL

網(wǎng)關(guān)可以通過常規(guī)的 Spring server configuration 來偵聽HTTPS上的請求。例子:

application.yml.

server:
  ssl:
    enabled: true
    key-alias: scg
    key-store-password: scg1234
    key-store: classpath:scg-keystore.p12
    key-store-type: PKCS12

網(wǎng)關(guān)路由可以路由到HTTP和HTTPS后端菩掏。如果路由到HTTPS后端魂角,則可以將網(wǎng)關(guān)配置為信任所有具有證書的下游服務(wù):

application.yml.

spring:
  cloud:
    gateway:
      httpclient:
        ssl:
          useInsecureTrustManager: true

不建議在生產(chǎn)環(huán)境使用不安全的信任管理器。對于生產(chǎn)部署智绸,可以使用一組已知證書配置網(wǎng)關(guān)野揪,這些證書可以通過以下方式進行配置:

application.yml.

spring:
  cloud:
    gateway:
      httpclient:
        ssl:
          trustedX509Certificates:
          - cert1.pem
          - cert2.pem

如果Spring Cloud Gateway未配置受信任證書,則使用默認信任庫(可以使用系統(tǒng)屬性javax.net.ssl.trustStore覆蓋)瞧栗。

7.1 TLS 握手

網(wǎng)關(guān)維護一個用于路由到后端的client池斯稳。當通過HTTPS通信時,客戶端啟動一個TLS握手迹恐,其中可能會有很多超時挣惰。這些超時可以這樣配置(顯示默認值):

application.yml.

spring:
  cloud:
    gateway:
      httpclient:
        ssl:
          handshake-timeout-millis: 10000
          close-notify-flush-timeout-millis: 3000
          close-notify-read-timeout-millis: 0
8. Configuration

Spring Cloud Gateway的配置由RouteDefinitionLocator的集合驅(qū)動。

RouteDefinitionLocator.java.

public interface RouteDefinitionLocator {
    Flux<RouteDefinition> getRouteDefinitions();
}

默認情況下,PropertiesRouteDefinitionLocator使用Spring Boot的@ConfigurationProperties機制加載屬性憎茂。

以下兩個示例是等效的:

application.yml.

spring:
  cloud:
    gateway:
      routes:
      - id: setstatus_route
        uri: http://example.org
        filters:
        - name: SetStatus
          args:
            status: 401
      - id: setstatusshortcut_route
        uri: http://example.org
        filters:
        - SetStatus=401

對于網(wǎng)關(guān)的大部分用法珍语,配置文件方式是夠用的,但一些生產(chǎn)用例更建議從外部源(如數(shù)據(jù)庫)加載配置唇辨。未來的里程碑版本將有基于Spring Data Repositories (如Redis廊酣、MongoDB和Cassandra)的RouteDefinitionLocator實現(xiàn)。

8.1 Fluent Java Routes API

為了可以更簡單在Java中配置赏枚,在RouteLocatorBuilder bean中定義了一個fluent API亡驰。

GatewaySampleApplication.java.

// static imports from GatewayFilters and RoutePredicates
@Bean
public RouteLocator customRouteLocator(RouteLocatorBuilder builder, ThrottleGatewayFilterFactory throttle) {
    return builder.routes()
            .route(r -> r.host("**.abc.org").and().path("/image/png")
                .filters(f ->
                        f.addResponseHeader("X-TestHeader", "foobar"))
                .uri("http://httpbin.org:80")
            )
            .route(r -> r.path("/image/webp")
                .filters(f ->
                        f.addResponseHeader("X-AnotherHeader", "baz"))
                .uri("http://httpbin.org:80")
            )
            .route(r -> r.order(-1)
                .host("**.throttle.org").and().path("/get")
                .filters(f -> f.filter(throttle.apply(1,
                        1,
                        10,
                        TimeUnit.SECONDS)))
                .uri("http://httpbin.org:80")
            )
            .build();
}

這種樣式還允許使用更多的自定義斷言。由RouteDefinitionLocator beans定義的斷言使用邏輯 and組合饿幅。通過使用fluent Java API凡辱,可以在 Predicate類上使用 and()or() 栗恩、 negate()運算符透乾。

8.2 DiscoveryClient Route Definition Locator

可以將網(wǎng)關(guān)配置為基于使用兼容DiscoveryClient注冊中心注冊的服務(wù)來創(chuàng)建路由。

要啟用此功能磕秤,請設(shè)置spring.cloud.gateway.discovery.locator.enabled=true乳乌,并確保DiscoveryClient實現(xiàn)位于classpath上并已啟用(如netflix eureka、consul或zookeeper)市咆。

8.2.1 Configuring Predicates and Filters For DiscoveryClient Routes

默認情況下汉操,網(wǎng)關(guān)為通過DiscoveryClient創(chuàng)建的路由定義單個斷言和過濾器。

默認斷言是使用/serviceId/**定義的path斷言蒙兰,其中serviceIdDiscoveryClient中服務(wù)的ID磷瘤。

默認過濾器是使用正則表達式 /serviceId/(?.*)和替換的/${remaining}進行重寫。這只是在請求被發(fā)送到下游之前從路徑中截取掉 service id 搜变。

可以通過設(shè)置spring.cloud.gateway.discovery.locator.predicates[x] and spring.cloud.gateway.discovery.locator.filters[y]來實現(xiàn)自定義DiscoveryClient路由使用的斷言and/or過濾器采缚。當你這樣做時,如果你想要保留這個功能挠他,你需要確保包括上面的默認斷言和過濾器扳抽。下面是這樣一個例子。

application.properties.

spring.cloud.gateway.discovery.locator.predicates[0].name: Path
spring.cloud.gateway.discovery.locator.predicates[0].args[pattern]: "'/'+serviceId+'/**'"
spring.cloud.gateway.discovery.locator.predicates[1].name: Host
spring.cloud.gateway.discovery.locator.predicates[1].args[pattern]: "'**.foo.com'"
spring.cloud.gateway.discovery.locator.filters[0].name: Hystrix
spring.cloud.gateway.discovery.locator.filters[0].args[name]: serviceId
spring.cloud.gateway.discovery.locator.filters[1].name: RewritePath
spring.cloud.gateway.discovery.locator.filters[1].args[regexp]: "'/' + serviceId + '/(?<remaining>.*)'"
spring.cloud.gateway.discovery.locator.filters[1].args[replacement]: "'/${remaining}'"
9. Reactor Netty Access Logs

設(shè)置 -Dreactor.netty.http.server.accessLogEnabled=true 來開啟Reactor Netty access logs绩社,注意必須是Java System Property而不是Spring Boot property摔蓝。

logging 模塊也可以通過配置單獨輸出一個access log文件,下面是logback的配置例子:

logback.xml.

 <appender name="accessLog" class="ch.qos.logback.core.FileAppender">
        <file>access_log.log</file>
        <encoder>
            <pattern>%msg%n</pattern>
        </encoder>
    </appender>
    <appender name="async" class="ch.qos.logback.classic.AsyncAppender">
        <appender-ref ref="accessLog" />
    </appender>

    <logger name="reactor.netty.http.server.AccessLog" level="INFO" additivity="false">
        <appender-ref ref="async"/>
    </logger>
10. CORS Configuration

我們可以通過配置網(wǎng)關(guān)來控制CORS行為愉耙,全局CORS配置是 Spring Framework CorsConfiguration模式的URL MAP。

application.yml.

spring:
  cloud:
    gateway:
      globalcors:
        corsConfigurations:
          '[/**]':
            allowedOrigins: "http://docs.spring.io"
            allowedMethods:
            - GET

例子中將允許從docs.spring.io發(fā)出的所有GET請求進行CORS請求拌滋。

11. Actuator API

/gateway的actuator端點允許監(jiān)視Spring Cloud Gateway應(yīng)用程序并與之交互朴沿。要進行遠程訪問,必須在應(yīng)用程序?qū)傩灾斜┞禜TTP或JMX 端口。

application.properties.

management.endpoint.gateway.enabled=true # default value
management.endpoints.web.exposure.include=gateway
11.1 Retrieving route filters

####### 11.1.1 Global Filters

要檢索應(yīng)用于所有路由的 [global filters]赌渣,請get請求 /actuator/gateway/globalfilters魏铅。返回的結(jié)果類似于以下內(nèi)容:

{
  "org.springframework.cloud.gateway.filter.LoadBalancerClientFilter@77856cc5": 10100,
  "org.springframework.cloud.gateway.filter.RouteToRequestUrlFilter@4f6fd101": 10000,
  "org.springframework.cloud.gateway.filter.NettyWriteResponseFilter@32d22650": -1,
  "org.springframework.cloud.gateway.filter.ForwardRoutingFilter@106459d9": 2147483647,
  "org.springframework.cloud.gateway.filter.NettyRoutingFilter@1fbd5e0": 2147483647,
  "org.springframework.cloud.gateway.filter.ForwardPathFilter@33a71d23": 0,
  "org.springframework.cloud.gateway.filter.AdaptCachedBodyGlobalFilter@135064ea": 2147483637,
  "org.springframework.cloud.gateway.filter.WebsocketRoutingFilter@23c05889": 2147483646
}

返回結(jié)果包含已就緒的global filters的詳細信息(如 org.springframework.cloud.gateway.filter.LoadBalancerClientFilter@77856cc5)。對于每個global filters坚芜,返回結(jié)果字符串對應(yīng)過濾器鏈中的相應(yīng)順序览芳。

####### 11.1.2 Route Filters

要檢索應(yīng)用于路由的 [GatewayFilter factories] ,請get請求/actuator/gateway/routefilters鸿竖。返回結(jié)果類似于以下內(nèi)容:

{
  "[AddRequestHeaderGatewayFilterFactory@570ed9c configClass = AbstractNameValueGatewayFilterFactory.NameValueConfig]": null,
  "[SecureHeadersGatewayFilterFactory@fceab5d configClass = Object]": null,
  "[SaveSessionGatewayFilterFactory@4449b273 configClass = Object]": null
}

返回結(jié)果包含應(yīng)用于所有路由的GatewayFilter的詳細信息沧竟。顯示每個工廠提供字符串格式的相應(yīng)對象(例如, [SecureHeadersGatewayFilterFactory@fceab5d configClass = Object])缚忧。請注意悟泵,null值是由于endpoint controller實現(xiàn)不完整造成的,因為它嘗試在filter chain中設(shè)置對象的順序闪水,這不適用于GatewayFilter工廠對象糕非。

11.2 Refreshing the route cache

如果要清理路由的緩存,請POST請求/actuator/gateway/refresh球榆。該請求將返回一個沒有body的200返回碼朽肥。

11.3 Retrieving the routes defined in the gateway

要檢索網(wǎng)關(guān)中定義的路由,發(fā)送GET請求/actuator/gateway/routes持钉,返回結(jié)果如下所示:

[{
  "route_id": "first_route",
  "route_object": {
    "predicate": "org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory$$Lambda$432/1736826640@1e9d7e7d",
    "filters": [
      "OrderedGatewayFilter{delegate=org.springframework.cloud.gateway.filter.factory.PreserveHostHeaderGatewayFilterFactory$$Lambda$436/674480275@6631ef72, order=0}"
    ]
  },
  "order": 0
},
{
  "route_id": "second_route",
  "route_object": {
    "predicate": "org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory$$Lambda$432/1736826640@cd8d298",
    "filters": []
  },
  "order": 0
}]
11.4 Retrieving information about a particular route

要獲取單個路由的信息衡招,發(fā)送GET請求 /actuator/gateway/routes/{id} (如: /actuator/gateway/routes/first_route),返回結(jié)果如下所示:

{
  "id": "first_route",
  "predicates": [{
    "name": "Path",
    "args": {"_genkey_0":"/first"}
  }],
  "filters": [],
  "uri": "http://www.uri-destination.org",
  "order": 0
}]
11.5 Creating and deleting a particular route

要創(chuàng)建一個路由右钾,發(fā)送POST請求 /gateway/routes/{id_route_to_create}蚁吝,參數(shù)為JSON結(jié)構(gòu),具體參數(shù)數(shù)據(jù)結(jié)構(gòu)參考上面章節(jié)舀射。

要刪除一個路由窘茁,發(fā)送 DELETE請求 /gateway/routes/{id_route_to_delete}

12. Developer Guide

TODO: overview of writing custom integrations

12.1 Writing Custom Route Predicate Factories

TODO: document writing Custom Route Predicate Factories

12.2 Writing Custom GatewayFilter Factories

如果要自定義一個GatewayFilter脆烟,需要實現(xiàn)GatewayFilterFactory山林。下面是一個你需要集成的抽象類 AbstractGatewayFilterFactory

PreGatewayFilterFactory.java.

public class PreGatewayFilterFactory extends AbstractGatewayFilterFactory<PreGatewayFilterFactory.Config> {

    public PreGatewayFilterFactory() {
        super(Config.class);
    }

    @Override
    public GatewayFilter apply(Config config) {
        // grab configuration from Config object
        return (exchange, chain) -> {
            //If you want to build a "pre" filter you need to manipulate the
            //request before calling chain.filter
            ServerHttpRequest.Builder builder = exchange.getRequest().mutate();
            //use builder to manipulate the request
            return chain.filter(exchange.mutate().request(request).build());
        };
    }

    public static class Config {
        //Put the configuration properties for your filter here
    }

}

PostGatewayFilterFactory.java.

public class PostGatewayFilterFactory extends AbstractGatewayFilterFactory<PostGatewayFilterFactory.Config> {

    public PostGatewayFilterFactory() {
        super(Config.class);
    }

    @Override
    public GatewayFilter apply(Config config) {
        // grab configuration from Config object
        return (exchange, chain) -> {
            return chain.filter(exchange).then(Mono.fromRunnable(() -> {
                ServerHttpResponse response = exchange.getResponse();
                //Manipulate the response in some way
            }));
        };
    }

    public static class Config {
        //Put the configuration properties for your filter here
    }

}
12.3 Writing Custom Global Filters

TODO: document writing Custom Global Filters

12.4 Writing Custom Route Locators and Writers

TODO: document writing Custom Route Locators and Writers

配置信息轉(zhuǎn)自:https://cloud.tencent.com/developer/article/1403887

NOTE: 博客內(nèi)容供參考學(xué)習(xí)邢羔,如有問題請指正驼抹,虛心接納

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市拜鹤,隨后出現(xiàn)的幾起案子框冀,更是在濱河造成了極大的恐慌,老刑警劉巖敏簿,帶你破解...
    沈念sama閱讀 212,383評論 6 493
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件明也,死亡現(xiàn)場離奇詭異宣虾,居然都是意外死亡,警方通過查閱死者的電腦和手機温数,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,522評論 3 385
  • 文/潘曉璐 我一進店門绣硝,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人撑刺,你說我怎么就攤上這事鹉胖。” “怎么了够傍?”我有些...
    開封第一講書人閱讀 157,852評論 0 348
  • 文/不壞的土叔 我叫張陵甫菠,是天一觀的道長。 經(jīng)常有香客問我王带,道長淑蔚,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 56,621評論 1 284
  • 正文 為了忘掉前任愕撰,我火速辦了婚禮刹衫,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘搞挣。我一直安慰自己带迟,他們只是感情好,可當我...
    茶點故事閱讀 65,741評論 6 386
  • 文/花漫 我一把揭開白布囱桨。 她就那樣靜靜地躺著仓犬,像睡著了一般。 火紅的嫁衣襯著肌膚如雪舍肠。 梳的紋絲不亂的頭發(fā)上搀继,一...
    開封第一講書人閱讀 49,929評論 1 290
  • 那天,我揣著相機與錄音翠语,去河邊找鬼叽躯。 笑死,一個胖子當著我的面吹牛肌括,可吹牛的內(nèi)容都是我干的点骑。 我是一名探鬼主播,決...
    沈念sama閱讀 39,076評論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼谍夭,長吁一口氣:“原來是場噩夢啊……” “哼黑滴!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起紧索,我...
    開封第一講書人閱讀 37,803評論 0 268
  • 序言:老撾萬榮一對情侶失蹤袁辈,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后珠漂,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體吵瞻,經(jīng)...
    沈念sama閱讀 44,265評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡葛菇,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,582評論 2 327
  • 正文 我和宋清朗相戀三年甘磨,在試婚紗的時候發(fā)現(xiàn)自己被綠了橡羞。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,716評論 1 341
  • 序言:一個原本活蹦亂跳的男人離奇死亡济舆,死狀恐怖卿泽,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情滋觉,我是刑警寧澤签夭,帶...
    沈念sama閱讀 34,395評論 4 333
  • 正文 年R本政府宣布,位于F島的核電站椎侠,受9級特大地震影響第租,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜我纪,卻給世界環(huán)境...
    茶點故事閱讀 40,039評論 3 316
  • 文/蒙蒙 一慎宾、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧浅悉,春花似錦趟据、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,798評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至荞估,卻和暖如春咳促,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背勘伺。 一陣腳步聲響...
    開封第一講書人閱讀 32,027評論 1 266
  • 我被黑心中介騙來泰國打工跪腹, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人娇昙。 一個月前我還...
    沈念sama閱讀 46,488評論 2 361
  • 正文 我出身青樓尺迂,卻偏偏與公主長得像,于是被迫代替她去往敵國和親冒掌。 傳聞我的和親對象是個殘疾皇子噪裕,可洞房花燭夜當晚...
    茶點故事閱讀 43,612評論 2 350

推薦閱讀更多精彩內(nèi)容