目錄1.網(wǎng)關(guān)簡(jiǎn)介2.什么是spring cloud gateway2.1核心概念3.Spring Cloud Gateway快速開(kāi)始5.路由斷言工廠(chǎng)（Route Predicate Factories）配置6.自定義路由斷言工廠(chǎng)7.Filter過(guò)濾器8.自定義過(guò)濾器9.自定義全局過(guò)濾器（Global Filters）10.Gateway跨域配置（CORS Configuration）11.Gateway整合Sentinel進(jìn)行流控12.流控配置說(shuō)明13.自定義重寫(xiě)流控返回信息1.網(wǎng)關(guān)簡(jiǎn)介

所謂的網(wǎng)關(guān)就是指系統(tǒng)的統(tǒng)一入口，它封裝了運(yùn)用程序的內(nèi)部結(jié)構(gòu)，為客戶(hù)端提供統(tǒng)一的服務(wù)，一些與業(yè)務(wù)功能無(wú)關(guān)的公共邏輯可以在這里實(shí)現(xiàn)，諸如認(rèn)證、鑒權(quán)、監(jiān)控、路由轉(zhuǎn)發(fā)等。

2.什么是spring cloud gateway

網(wǎng)關(guān)作為流量的入口，常用的功能包括路由轉(zhuǎn)發(fā)、權(quán)限校驗(yàn)、限流等。

spring cloud gateway是spring cloud推出的第二代網(wǎng)關(guān)，是由WebFlux+Netty+Reactor實(shí)現(xiàn)的響應(yīng)式的API網(wǎng)關(guān)，它不能在傳統(tǒng)的servlet容器中工作，也不能構(gòu)建成war包；旨在為微服務(wù)提供一種簡(jiǎn)單且有效的API路由的管理方式，并基于Filter的方式提供網(wǎng)關(guān)的基本功能，例如安全認(rèn)證、監(jiān)控、限流等。

spring cloud gateway功能特性：

（1）基于spring Framework5、Project Reactor和spring boot 2.0進(jìn)行構(gòu)建

（2）動(dòng)態(tài)路由：能夠匹配任何請(qǐng)求屬性

（3）支持路徑重寫(xiě)

（4）集成spring cloud服務(wù)發(fā)現(xiàn)功能（nacos）

（5）可集成流控級(jí)功能（sentinel）

（6）可以對(duì)路由指定易于編寫(xiě)的Predicate（斷言）、Filter（過(guò)濾器）

2.1核心概念

路由（Route）：

路由是網(wǎng)關(guān)中最重要的部分，路由信息包括一個(gè)ID、一個(gè)目的URL、一組斷言工廠(chǎng)、一組Filter組成。如果斷言為真，則說(shuō)明請(qǐng)求的URL和配置的路由匹配。

斷言（Predicate）：

java8中的斷言函數(shù)，spring cloud gateway中的斷言函數(shù)類(lèi)型是spring 5.0框架中的ServerWebExchange。斷言函數(shù)運(yùn)行開(kāi)發(fā)者去定義匹配Http request中的任何信息，比如請(qǐng)求頭和參數(shù)。

過(guò)濾器（Filter）：

分為Gateway filter和Global filter，F(xiàn)ilter可以對(duì)請(qǐng)求和響應(yīng)進(jìn)行處理。

3.Spring Cloud Gateway快速開(kāi)始

（1）創(chuàng)建maven工程

（2）pom.xml中導(dǎo)入需要的依賴(lài)

<!-- gateway依賴(lài)--><dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-gateway</artifactId> <version>3.0.1</version></dependency>

（3）application.properties中配置路由斷言和過(guò)濾器

server.port=8086 spring.application.name=api-gateway #gateway配置#網(wǎng)關(guān)唯一標(biāo)識(shí)，路由到order，routes是集合，使用數(shù)組索引來(lái)設(shè)置spring.cloud.gateway.routes[0].id=order_route#需要轉(zhuǎn)發(fā)的地址spring.cloud.gateway.routes[0].uri=http://localhost:8084#斷言規(guī)則,predicates也是一個(gè)集合，http://localhost:8086/order-serv/order/add 路由到#http://localhost:8085/order-serv/order/addspring.cloud.gateway.routes[0].predicates[0]=Path=/order-serv/**#過(guò)濾器，轉(zhuǎn)發(fā)之前去掉第一層路徑：http://localhost:8085/order/addspring.cloud.gateway.routes[0].filters[0]=StripPrefix=1

（4）瀏覽器中訪(fǎng)問(wèn)網(wǎng)關(guān)配置的地址，可以路由到我們配置服務(wù)器地址

4.Gateway

整合Nacos

在配置文件中寫(xiě)死的轉(zhuǎn)發(fā)地址，會(huì)存在很多問(wèn)題，我們需要集成nacos，從注冊(cè)中心中獲取此地址

（1）pom.xml中添加nacos的依賴(lài)

<!-- Nacos服務(wù)注冊(cè)發(fā)現(xiàn)--><dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency>

（2）application.properties中配置nacos連接信息

#nacos服務(wù)連接地址spring.cloud.nacos.server-addr=127.0.0.1:8848#nacos discovery連接用戶(hù)名spring.cloud.nacos.discovery.username=nacos#nacos discovery連接密碼spring.cloud.nacos.discovery.password=nacos#nacos discovery工作空間spring.cloud.nacos.discovery.workspace=public

（3）application.properties中配置路由的uri為需要訪(fǎng)問(wèn)的服務(wù)名，前綴lb（loadBalance負(fù)載均衡）

對(duì)應(yīng)需要訪(fǎng)問(wèn)的order服務(wù)

此時(shí)nacos中是有order-service服務(wù)的

（4）重啟服務(wù)，是可以路由到我們的order服務(wù)的

（5）簡(jiǎn)寫(xiě)：去掉關(guān)于路由的配置，自動(dòng)尋找服務(wù)，根據(jù)訪(fǎng)問(wèn)的地址，自動(dòng)從nacos中找到服務(wù)進(jìn)行路由。application.properties中配置

#自動(dòng)識(shí)別nacos服務(wù)，默認(rèn)是關(guān)閉的，開(kāi)啟后會(huì)根據(jù)訪(fǎng)問(wèn)的地址http://localhost:8086/order-service/order/add#自動(dòng)路由到order-service服務(wù)上spring.cloud.gateway.discovery.locator.enabled=true

注釋了其它路由的配置

自動(dòng)尋找服務(wù)也是可以正常訪(fǎng)問(wèn)服務(wù)

5.路由斷言工廠(chǎng)（Route Predicate Factories）配置

作用：當(dāng)請(qǐng)求gateway的時(shí)候，使用斷言對(duì)請(qǐng)求進(jìn)行匹配，如果匹配成功就路由轉(zhuǎn)發(fā)，匹配不成功返回404

類(lèi)型：內(nèi)置

官網(wǎng)參考地址：https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#gateway-request-predicates-factories

SpringCloud Gateway包括許多內(nèi)置的斷言工廠(chǎng)，所有這些斷言都與HTTP請(qǐng)求的不同屬性匹配。

（1）基于DateTime類(lèi)型的斷言工廠(chǎng)

此類(lèi)型的斷言工廠(chǎng)根據(jù)時(shí)間做判斷，主要有三個(gè)：

AfterRoutePredicateFactory：接收一個(gè)日期參數(shù)，判斷請(qǐng)求日期是否晚于指定日期。

BeforeRoutePredicateFactory：接收一個(gè)日期參數(shù)，判斷請(qǐng)求日期是否早于指定日期

BetweenRoutePredicateFactory：接收兩個(gè)日期參數(shù)，判斷請(qǐng)求日期是否在指定時(shí)間段內(nèi)

- After=2019-12-31T23:59:59.789+08:00[Asia/Shanghai]

路由規(guī)則改為當(dāng)前時(shí)間之后

系統(tǒng)訪(fǎng)問(wèn)404

日期改為當(dāng)前日期之前

服務(wù)正常訪(fǎng)問(wèn)

（2）基于遠(yuǎn)程地址的斷言工廠(chǎng)

RemoteAddrRoutePredicateFactory：接收一個(gè)IP地址段，判斷請(qǐng)求主機(jī)地址是否在地址段中

- RemoteAddr=192.168.1.1/24

（3）基于Cookie的斷言工廠(chǎng)

CookieRoutePredicateFactory：接收兩個(gè)參數(shù)，cookie名字和一個(gè)正則表達(dá)式，判斷cookie是否具有給定名稱(chēng)且值與正則表達(dá)式匹配。

-Cookie=chocolate,ch.

（4）基于Header的斷言工廠(chǎng)

HeaderRoutePredicateFactory：接收兩個(gè)參數(shù)，標(biāo)題名稱(chēng)和正則表達(dá)式，判斷請(qǐng)求Header是否具有給定名稱(chēng)值與正則表達(dá)式匹配。

-Header=X-Request-Id,d+

（5）基于Host的斷言工廠(chǎng)

HostRoutePredicateFactory：接收一個(gè)參數(shù)，主機(jī)名模式，判斷請(qǐng)求的Host是否滿(mǎn)足匹配規(guī)則。

-Host=**.testhost.org

（6）基于Method請(qǐng)求方法的斷言工廠(chǎng)

MethodRoutePredicateFactory：接收一個(gè)參數(shù)，判斷請(qǐng)求類(lèi)型是否跟指定的類(lèi)型匹配

-Method=GET

（7）基于Path請(qǐng)求路徑的斷言工廠(chǎng)

PathRoutePredicateFactory：接收一個(gè)參數(shù)，判斷請(qǐng)求的URI部分是否滿(mǎn)足路徑規(guī)則

-Path=/foo/{segment}

（8）基于Query請(qǐng)求參數(shù)的斷言工廠(chǎng)

QueryRoutePredicateFactory：接收兩個(gè)參數(shù)，請(qǐng)求param和正則表達(dá)式，判斷請(qǐng)求參數(shù)是否具有給定個(gè)名稱(chēng)且值與正則表達(dá)式匹配

-Query=baz,ba.

（9）基于路由權(quán)重的斷言工廠(chǎng)

WeightRoutePredicateFactory：接收一個(gè)[組名,權(quán)重]，然后對(duì)于同一個(gè)組內(nèi)的路由按照權(quán)重轉(zhuǎn)發(fā)

spring: cloud: gateway: routes: - id: weight_highuri: https://weighthigh.orgpredicates:- Weight=group1, 8 - id: weight_lowuri: https://weightlow.orgpredicates:- Weight=group1, 26.自定義路由斷言工廠(chǎng)

自定義路由斷言工廠(chǎng)需要繼承AbstractRoutePredicateFactory類(lèi)，重寫(xiě)apply的方法邏輯，在apply方法中通過(guò)exchange.getRequest()拿到ServerHttpRequest對(duì)象，從而可以獲取到請(qǐng)求的參數(shù)、請(qǐng)求方式、請(qǐng)求頭等信息

注意：

類(lèi)的命名需要以RoutePredicateFactory結(jié)尾；

必須使用spring的bean加載到容器中；

必須繼承AbstractRoutePredicateFactory；

必須聲明靜態(tài)內(nèi)部類(lèi)，聲明屬性來(lái)接收配置文件中對(duì)應(yīng)的斷言信息；

需要結(jié)合shortcutFieldOrder進(jìn)行綁定；

通過(guò)apply進(jìn)行邏輯判斷，true就是匹配成功，false則匹配失敗

（1）創(chuàng)建一個(gè)類(lèi)CheckAuthRoutePredicateFactory，里面的處理代碼，可以直接復(fù)制一份

QueryRoutePredicateFactory邏輯代碼

package com.qingyun.predicate; import org.springframework.cloud.gateway.handler.predicate.AbstractRoutePredicateFactory;import org.springframework.cloud.gateway.handler.predicate.GatewayPredicate;import org.springframework.stereotype.Component;import org.springframework.util.StringUtils;import org.springframework.validation.annotation.Validated;import org.springframework.web.server.ServerWebExchange; import javax.validation.constraints.NotEmpty;import java.util.Arrays;import java.util.Iterator;import java.util.List;import java.util.function.Predicate;import java.util.Arrays;import java.util.Iterator;import java.util.List;import java.util.function.Predicate;import javax.validation.constraints.NotEmpty;import org.springframework.util.StringUtils;import org.springframework.validation.annotation.Validated;import org.springframework.web.server.ServerWebExchange; /** * 自定義斷言工廠(chǎng) */@Componentpublic class CheckAuthRoutePredicateFactory extends AbstractRoutePredicateFactory<CheckAuthRoutePredicateFactory.Config> { public static final String PARAM_KEY = 'param'; public static final String REGEXP_KEY = 'regexp'; public CheckAuthRoutePredicateFactory() {super(CheckAuthRoutePredicateFactory.Config.class); } public List<String> shortcutFieldOrder() {return Arrays.asList('param', 'regexp'); } public Predicate<ServerWebExchange> apply(CheckAuthRoutePredicateFactory.Config config) {return new GatewayPredicate() { public boolean test(ServerWebExchange exchange) {if (!StringUtils.hasText(config.regexp)) { return exchange.getRequest().getQueryParams().containsKey(config.param);} else { List<String> values = (List)exchange.getRequest().getQueryParams().get(config.param); if (values == null) {return false; } else {Iterator var3 = values.iterator(); String value;do { if (!var3.hasNext()) {return false; } value = (String)var3.next();} while(value == null || !value.matches(config.regexp)); return true; }} } public String toString() {return String.format('Query: param=%s regexp=%s', config.getParam(), config.getRegexp()); }}; } @Validated public static class Config {@NotEmptyprivate String param;private String regexp; public Config() {} public String getParam() { return this.param;} public CheckAuthRoutePredicateFactory.Config setParam(String param) { this.param = param; return this;} public String getRegexp() { return this.regexp;} public CheckAuthRoutePredicateFactory.Config setRegexp(String regexp) { this.regexp = regexp; return this;} }}

（2）自定義的斷言類(lèi)名為CheckAuthRoutePredicateFactory，所以application.properties中使用CheckAuth作為斷言規(guī)則配置

（3）修改CheckAuthRoutePredicateFactory類(lèi)，定義靜態(tài)類(lèi)Config的字段，添加get和set方法，可以接收到application.properties中配置的CheckAuth的值

（4）結(jié)合中shortcutFieldOrder使用，添加name屬性到集合中

（5）apply方法中獲取Config中的name值，進(jìn)行判斷匹配，返回true或false

（6）訪(fǎng)問(wèn)系統(tǒng)可以正常訪(fǎng)問(wèn)

（7）當(dāng)改了application.properties中的CheckAuth值后，訪(fǎng)問(wèn)不到服務(wù)

（8）完整自定義CheckAuthRoutePredicateFactory代碼

package com.qingyun.predicate; import org.springframework.cloud.gateway.handler.predicate.AbstractRoutePredicateFactory;import org.springframework.cloud.gateway.handler.predicate.GatewayPredicate;import org.springframework.stereotype.Component;import org.springframework.util.StringUtils;import org.springframework.validation.annotation.Validated;import org.springframework.web.server.ServerWebExchange; import javax.validation.constraints.NotEmpty;import java.util.Arrays;import java.util.Iterator;import java.util.List;import java.util.function.Predicate;import java.util.Arrays;import java.util.Iterator;import java.util.List;import java.util.function.Predicate;import javax.validation.constraints.NotEmpty;import org.springframework.util.StringUtils;import org.springframework.validation.annotation.Validated;import org.springframework.web.server.ServerWebExchange; /** * 自定義斷言工廠(chǎng) */@Componentpublic class CheckAuthRoutePredicateFactory extends AbstractRoutePredicateFactory<CheckAuthRoutePredicateFactory.Config> { public CheckAuthRoutePredicateFactory() {super(CheckAuthRoutePredicateFactory.Config.class); } public List<String> shortcutFieldOrder() {return Arrays.asList('name'); } public Predicate<ServerWebExchange> apply(CheckAuthRoutePredicateFactory.Config config) {return new GatewayPredicate() { public boolean test(ServerWebExchange exchange) {if(config.getName().equals('qingyun')){ return true;}return false; } }; } @Validated public static class Config {private String name; public String getName() { return name;} public void setName(String name) { this.name = name;} }}7.Filter過(guò)濾器

官網(wǎng)參考：https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#gatewayfilter-factories

（1）添加請(qǐng)求頭AddRequestHeader

被調(diào)用接口中接收參數(shù)

參數(shù)傳遞成功

（2）為路由轉(zhuǎn)發(fā)添加前綴PrefixPath

被調(diào)用服務(wù)需要配置context-path服務(wù)前綴

（3）RedirectTo重定向到其他服務(wù)，訪(fǎng)問(wèn)接口后跳轉(zhuǎn)到配置的服務(wù)地址

8.自定義過(guò)濾器

注意：

類(lèi)的命名需要以GatewayFilterFactory結(jié)尾；

必須使用spring的bean加載到容器中；

必須繼承AbstractNameValueGatewayFilterFactory；

必須聲明靜態(tài)內(nèi)部類(lèi)，聲明屬性來(lái)接收配置文件中對(duì)應(yīng)的斷言信息；

需要結(jié)合shortcutFieldOrder進(jìn)行綁定；

通過(guò)apply進(jìn)行邏輯判斷

（1）創(chuàng)建一個(gè)類(lèi)CheckAuthGatewayFilterFactory，里面的處理代碼，可以直接復(fù)制一份

RedirectToGatewayFilterFactory邏輯代碼

（2）自定義的斷言類(lèi)名為CheckAuthGatewayFilterFactory，所以application.properties中使用CheckAuth作為過(guò)濾器配置

（3）修改CheckAuthGatewayFilterFactory類(lèi)，定義靜態(tài)類(lèi)Config的字段，添加get和set方法，可以接收到application.properties中配置的CheckAuth的值

（4）結(jié)合中shortcutFieldOrder使用，添加value屬性到集合中

（5）apply方法中獲取Config中的value值，進(jìn)行判斷匹配，繼續(xù)執(zhí)行或者返回404狀態(tài)

（6）不帶參數(shù)或者帶的參數(shù)不匹配時(shí)，訪(fǎng)問(wèn)不到系統(tǒng)

（7）當(dāng)參數(shù)與application.properties中的CheckAuth匹配后，正常訪(fǎng)問(wèn)服務(wù)

（8）完整自定義CheckAuthGatewayFilterFactory代碼

package com.qingyun.filter; import org.springframework.cloud.gateway.filter.GatewayFilter;import org.springframework.cloud.gateway.filter.GatewayFilterChain;import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;import org.springframework.cloud.gateway.filter.factory.RedirectToGatewayFilterFactory;import org.springframework.cloud.gateway.support.HttpStatusHolder;import org.springframework.http.HttpHeaders;import org.springframework.http.HttpStatus;import org.springframework.http.server.reactive.ServerHttpResponse;import org.springframework.stereotype.Component;import org.springframework.util.Assert;import org.springframework.web.server.ServerWebExchange;import reactor.core.publisher.Mono; import java.net.URI;import java.util.Arrays;import java.util.List; import static org.springframework.cloud.gateway.support.GatewayToStringStyler.filterToStringCreator;import static org.springframework.cloud.gateway.support.ServerWebExchangeUtils.setResponseStatus; @Componentpublic class CheckAuthGatewayFilterFactory extends AbstractGatewayFilterFactory<CheckAuthGatewayFilterFactory.Config> { public CheckAuthGatewayFilterFactory() {super(CheckAuthGatewayFilterFactory.Config.class); } @Override public List<String> shortcutFieldOrder() {return Arrays.asList('value'); } @Override public GatewayFilter apply(Config config) {return new GatewayFilter() { @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {//獲取到請(qǐng)求的參數(shù)值String name = exchange.getRequest().getQueryParams().getFirst('name');if(config.getValue().equals(name)){ //參數(shù)name的值等于配置的值 return chain.filter(exchange); //正常訪(fǎng)問(wèn)服務(wù)}else{ //直接返回404 exchange.getResponse().setStatusCode(HttpStatus.NOT_FOUND); //設(shè)置狀態(tài)碼 return exchange.getResponse().setComplete(); //設(shè)置結(jié)束訪(fǎng)問(wèn)} }}; } public static class Config { private String value; public String getValue() { return value;} public void setValue(String value) { this.value = value;} }}9.自定義全局過(guò)濾器（Global Filters）

局部過(guò)濾器和全局過(guò)濾器區(qū)別:

局部：局部針對(duì)某個(gè)路由，需要在路由中進(jìn)行配置

全局：針對(duì)所有路由請(qǐng)求，一旦配置就會(huì)投入使用

實(shí)現(xiàn)GlobalFilter接口，重寫(xiě)filter方法

/** * 全局過(guò)濾器 */@Componentpublic class GlobalLogFilter implements GlobalFilter { Logger log = LoggerFactory.getLogger(this.getClass()); @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {log.info('請(qǐng)求的路徑:'+exchange.getRequest().getPath().value());//直接返回驗(yàn)證通過(guò)return chain.filter(exchange); }}

當(dāng)訪(fǎng)問(wèn)接口時(shí)，全局過(guò)濾器攔截到請(qǐng)求信息

10.Gateway跨域配置（CORS Configuration）

官網(wǎng)參考：https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#cors-configuration

跨域請(qǐng)求錯(cuò)誤提示信息：在63342端口的頁(yè)面調(diào)用8086端口的后臺(tái)，出現(xiàn)跨域

在application.properties中配置：

#配置跨域允許（端口1的頁(yè)面調(diào)用端口2的后臺(tái)，出現(xiàn)跨域）#允許跨域訪(fǎng)問(wèn)的資源：[/**] allowed-origins：跨域允許來(lái)源spring.cloud.gateway.globalcors.cors-configurations.[/**].allowed-origins=*#跨域允許的請(qǐng)求方法（GET/POST...)spring.cloud.gateway.globalcors.cors-configurations.[/**].allowed-methods=*spring.cloud.gateway.globalcors.cors-configurations.[/**].allowed-headers=*spring.cloud.gateway.globalcors.cors-configurations.[/**].allow-credentials=true

寫(xiě)配置類(lèi)允許跨域：

/** * 配置跨域 */@Configurationpublic class CorsConfig { @Bean public CorsWebFilter corsFilter(){//配置允許的設(shè)置CorsConfiguration config = new CorsConfiguration();config.addAllowedMethod('*');config.addAllowedOrigin('*');config.addAllowedHeader('*'); //配置添加到資源中UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();source.registerCorsConfiguration('/**',config);return new CorsWebFilter(source); }}

配置跨域后請(qǐng)求成功：

11.Gateway整合Sentinel進(jìn)行流控

網(wǎng)關(guān)作為內(nèi)部系統(tǒng)外的一層屏障，對(duì)內(nèi)起到一定的保護(hù)作用，限流便是其中之一。網(wǎng)關(guān)層的限流可以針對(duì)不同路由進(jìn)行限流，也可以針對(duì)接口進(jìn)行限流，或者根據(jù)接口的特征進(jìn)行分組限流。

（1）pom.xml中添加依賴(lài)

<!--sentinel整合gateway--><dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId></dependency> <!--sentinel依賴(lài)--><dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>

（2）application.properties中添加sentinel控制臺(tái)連接

#整合sentinel控制臺(tái)spring.cloud.sentinel.transport.dashboard=127.0.0.1:8090

（3）重啟服務(wù)，啟動(dòng)sentinel控制臺(tái)服務(wù)，訪(fǎng)問(wèn)接口，打開(kāi)sentinel控制臺(tái)，可以看到sentinel為gateway單獨(dú)開(kāi)放不同的菜單

（4）針對(duì)order_route進(jìn)行流控設(shè)置

（5）快速訪(fǎng)問(wèn)網(wǎng)關(guān)服務(wù)，達(dá)到設(shè)置的qps后，出現(xiàn)流控

12.流控配置說(shuō)明

（1）API類(lèi)型：RouteId和Api分組

RouteId對(duì)應(yīng)application.properties中配置的id

Api分組可以在API管理處添加具有相同屬性控制的分組

在流控管理頁(yè)面添加設(shè)置，此流控設(shè)置將會(huì)對(duì)這組中設(shè)置的接口都有流控效果

（2）針對(duì)請(qǐng)求屬性設(shè)置

可以設(shè)置ip、請(qǐng)求頭等信息，匹配模式有精確、子串（結(jié)尾匹配）、正則表達(dá)式

13.自定義重寫(xiě)流控返回信息

默認(rèn)的流控返回信息不太友好

通過(guò)GatewayCallbackManager自定義流控信息

/** * 自定義流控返回信息 */@Configurationpublic class GatewayConfig { @PostConstruct public void init(){BlockRequestHandler blockRequestHandler = new BlockRequestHandler() { @Override public Mono<ServerResponse> handleRequest(ServerWebExchange exchange, Throwable t) {Map<String,Object> map = new HashMap<String,Object>();map.put('code', HttpStatus.TOO_MANY_REQUESTS);map.put('message','被流控了'); return ServerResponse.status(HttpStatus.OK).contentType(MediaType.APPLICATION_JSON).body(BodyInserters.fromValue(map)); }};GatewayCallbackManager.setBlockHandler(blockRequestHandler); }}

此時(shí)在訪(fǎng)問(wèn)接口，被流控后返回自定義的流控信息

到此這篇關(guān)于Spring cloud alibaba之Gateway網(wǎng)關(guān)功能特征詳解的文章就介紹到這了,更多相關(guān)Spring cloud alibaba內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！