1.斷言工廠

我們?cè)谂渲梦募袑懙臄嘌砸?guī)則只是字符串，這些字符串會(huì)被Predicate Factory讀取并處理，轉(zhuǎn)變?yōu)槁酚膳袛嗟臈l件

例如Path=/user/**是按照路徑匹配，這個(gè)規(guī)則是由

org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory類來

處理的，像這樣的斷言工廠在SpringCloudGateway還有十幾個(gè):

名稱	說明	示例
After	是某個(gè)時(shí)間點(diǎn)后的請(qǐng)求	– After=2037-01-20T17:42:47.789-07:00[America/Denver]
Before	是某個(gè)時(shí)間點(diǎn)之前的請(qǐng)求	– Before=2031-04-13T15:14:47.433+08:00[Asia/Shanghai]
Between	是某兩個(gè)時(shí)間點(diǎn)之前的請(qǐng)求	– Between=2037-01-20T17:42:47.789-07:00[America/Denver], 2037-01-21T17:42:47.789-07:00[America/Denver]
Cookie	請(qǐng)求必須包含某些cookie	– Cookie=chocolate, ch.p
Header	請(qǐng)求必須包含某些header	– Header=X-Request-Id, \d+
Host	請(qǐng)求必須是訪問某個(gè)host（域名）	– Host=.somehost.org,.anotherhost.org
Method	請(qǐng)求方式必須是指定方式	– Method=GET,POST
Path	請(qǐng)求路徑必須符合指定規(guī)則	– Path=/red/{segment},/blue/**
Query	請(qǐng)求參數(shù)必須包含指定參數(shù)	– Query=name, Jack或者- Query=name
RemoteAddr	請(qǐng)求者的ip必須是指定范圍	– RemoteAddr=192.168.1.1/24
Weight	權(quán)重處理

我們只需要掌握Path這種路由工程就可以了。

2.過濾器工廠

GatewayFilter是網(wǎng)關(guān)中提供的一種過濾器，可以對(duì)進(jìn)入網(wǎng)關(guān)的請(qǐng)求和微服務(wù)返回的響應(yīng)做處理：

2.1.路由過濾器的種類

Spring提供了31種不同的路由過濾器工廠。例如：

名稱	說明
AddRequestHeader	給當(dāng)前請(qǐng)求添加一個(gè)請(qǐng)求頭
RemoveRequestHeader	移除請(qǐng)求中的一個(gè)請(qǐng)求頭
AddResponseHeader	給響應(yīng)結(jié)果中添加一個(gè)響應(yīng)頭
RemoveResponseHeader	從響應(yīng)結(jié)果中移除有一個(gè)響應(yīng)頭
RequestRateLimiter	限制請(qǐng)求的流量

2.2.請(qǐng)求頭過濾器

下面我們以AddRequestHeader 為例來講解。

需求：給所有進(jìn)入userservice的請(qǐng)求添加一個(gè)請(qǐng)求頭：Truth=itcast is freaking awesome!

只需要修改gateway服務(wù)的application.yml文件，添加路由過濾即可：

spring:cloud:gateway:routes:- id: user-service uri: lb://userservice predicates: - Path=/user/** filters: # 過濾器- AddRequestHeader=Truth, Itcast is freaking awesome! # 添加請(qǐng)求頭

當(dāng)前過濾器寫在userservice路由下，因此僅僅對(duì)訪問userservice的請(qǐng)求有效。

3.3.默認(rèn)過濾器

如果要對(duì)所有的路由都生效，則可以將過濾器工廠寫到default下。格式如下：

spring:cloud:gateway:routes:- id: user-service uri: lb://userservice predicates: - Path=/user/**default-filters: # 默認(rèn)過濾項(xiàng)- AddRequestHeader=Truth, Itcast is freaking awesome! 

3.4.總結(jié)

過濾器的作用是什么？

① 對(duì)路由的請(qǐng)求或響應(yīng)做加工處理，比如添加請(qǐng)求頭

② 配置在路由下的過濾器只對(duì)當(dāng)前路由的請(qǐng)求生效

defaultFilters的作用是什么？

① 對(duì)所有路由都生效的過濾器

3.5.全局過濾器

上一節(jié)學(xué)習(xí)的過濾器，網(wǎng)關(guān)提供了31種，但每一種過濾器的作用都是固定的。如果我們希望攔截請(qǐng)求，做自己的業(yè)務(wù)邏輯則沒辦法實(shí)現(xiàn)。

3.5.1.全局過濾器作用

全局過濾器的作用也是處理一切進(jìn)入網(wǎng)關(guān)的請(qǐng)求和微服務(wù)響應(yīng)，與GatewayFilter的作用一樣。區(qū)別在于GatewayFilter通過配置定義，處理邏輯是固定的；而GlobalFilter的邏輯需要自己寫代碼實(shí)現(xiàn)。

定義方式是實(shí)現(xiàn)GlobalFilter接口。

public interface GlobalFilter {/***  處理當(dāng)前請(qǐng)求，有必要的話通過{@link GatewayFilterChain}將請(qǐng)求交給下一個(gè)過濾器處理** @param exchange 請(qǐng)求上下文，里面可以獲取Request、Response等信息* @param chain 用來把請(qǐng)求委托給下一個(gè)過濾器 * @return {@code Mono<Void>} 返回標(biāo)示當(dāng)前過濾器業(yè)務(wù)結(jié)束*/Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);
}

在filter中編寫自定義邏輯，可以實(shí)現(xiàn)下列功能：

• 登錄狀態(tài)判斷
• 權(quán)限校驗(yàn)
• 請(qǐng)求限流等

3.5.2.自定義全局過濾器

需求：定義全局過濾器，攔截請(qǐng)求，判斷請(qǐng)求的參數(shù)是否滿足下面條件：

• 參數(shù)中是否有authorization，
• authorization參數(shù)值是否為admin

如果同時(shí)滿足則放行，否則攔截

實(shí)現(xiàn)：

在gateway中定義一個(gè)過濾器：

package cn.itcast.gateway.filters;
?
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.annotation.Order;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
?
@Order(-1)
@Component
public class AuthorizeFilter implements GlobalFilter {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 1.獲取請(qǐng)求參數(shù)MultiValueMap<String, String> params = exchange.getRequest().getQueryParams();// 2.獲取authorization參數(shù)String auth = params.getFirst("authorization");// 3.校驗(yàn)if ("admin".equals(auth)) {// 放行return chain.filter(exchange);}// 4.攔截// 4.1.禁止訪問，設(shè)置狀態(tài)碼exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);// 4.2.結(jié)束處理return exchange.getResponse().setComplete();}
}

3.5.3.過濾器執(zhí)行順序

請(qǐng)求進(jìn)入網(wǎng)關(guān)會(huì)碰到三類過濾器：當(dāng)前路由的過濾器、DefaultFilter、GlobalFilter

請(qǐng)求路由后，會(huì)將當(dāng)前路由過濾器和DefaultFilter、GlobalFilter，合并到一個(gè)過濾器鏈（集合）中，排序后依次執(zhí)行每個(gè)過濾器：

排序的規(guī)則是什么呢？

• 每一個(gè)過濾器都必須指定一個(gè)int類型的order值，order值越小，優(yōu)先級(jí)越高，執(zhí)行順序越靠前。
• GlobalFilter通過實(shí)現(xiàn)Ordered接口，或者添加@Order注解來指定order值，由我們自己指定
• 路由過濾器和defaultFilter的order由Spring指定，默認(rèn)是按照聲明順序從1遞增。
• 當(dāng)過濾器的order值一樣時(shí)，會(huì)按照 defaultFilter > 路由過濾器 > GlobalFilter的順序執(zhí)行。

詳細(xì)內(nèi)容，可以查看源碼：

org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator#getFilters()方法是先加載defaultFilters，然后再加載某個(gè)route的filters，然后合并。

org.springframework.cloud.gateway.handler.FilteringWebHandler#handle()方法會(huì)加載全局過濾器，與前面的過濾器合并后根據(jù)order排序，組織過濾器鏈