前一篇文章介紹了Spring Cloud Gateway的一些基礎(chǔ)知識點(diǎn)，今天陳某就來嘮一嘮網(wǎng)關(guān)層面如何做限流？

文章目錄如下：

網(wǎng)關(guān)如何限流？

Spring Cloud Gateway本身自帶的限流實現(xiàn)，過濾器是RequestRateLimiterGatewayFilterFactory，不過這種上不了臺面的就不再介紹了，有興趣的可以實現(xiàn)下。

從1.6.0版本開始，Sentinel提供了SpringCloud Gateway的適配模塊，可以提供兩種資源維度的限流：

• route維度：即在配置文件中配置的路由條目，資源名為對應(yīng)的routeId，這種屬于粗粒度的限流，一般是對某個微服務(wù)進(jìn)行限流。
• 自定義API維度：用戶可以利用Sentinel提供的API來自定義一些API分組，這種屬于細(xì)粒度的限流，針對某一類的uri進(jìn)行匹配限流，可以跨多個微服務(wù)。

“sentinel官方文檔：https://github.com/alibaba/Sentinel/wiki/網(wǎng)關(guān)限流

”

Spring Cloud Gateway集成Sentinel實現(xiàn)很簡單，這就是阿里的魅力，提供簡單、易操作的工具，讓程序員專注于業(yè)務(wù)。

新建項目

新建一個gateway-sentinel9026模塊，添加如下依賴：


????<dependency>
??????<groupId>com.alibaba.cloudgroupId>
??????<artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
????dependency>

????
????<dependency>
??????<groupId>org.springframework.cloudgroupId>
??????<artifactId>spring-cloud-starter-gatewayartifactId>
????dependency>

????
????<dependency>
??????<groupId>com.alibaba.cloudgroupId>
??????<artifactId>spring-cloud-alibaba-sentinel-gatewayartifactId>
????dependency>

????
????<dependency>
??????<groupId>com.alibaba.cloudgroupId>
??????<artifactId>spring-cloud-starter-alibaba-sentinelartifactId>
????dependency>


“注意：這依然是一個網(wǎng)關(guān)服務(wù)，不要添加WEB的依賴

”

配置文件

配置文件中主要指定以下三種配置：

• nacos的地址
• sentinel控制臺的地址
• 網(wǎng)關(guān)路由的配置

配置如下：

spring:
??cloud:
????##?整合sentinel，配置sentinel控制臺的地址
????sentinel:
??????transport:
????????##?指定控制臺的地址，默認(rèn)端口8080
????????dashboard:?localhost:8080
????nacos:
??????##?注冊中心配置
??????discovery:
????????#?nacos的服務(wù)地址，nacos-server中IP地址:端口號
????????server-addr:?127.0.0.1:8848
????gateway:
??????##?路由
??????routes:
????????##?id只要唯一即可，名稱任意
????????-?id:?gateway-provider
??????????uri:?lb://gateway-provider
??????????##?配置斷言
??????????predicates:
????????????##?Path?Route?Predicate?Factory斷言，滿足/gateway/provider/**這個請求路徑的都會被路由到http://localhost:9024這個uri中
????????????-?Path=/gateway/provider/**
上述配置中設(shè)置了一個路由gateway-provider，只要請求路徑滿足/gateway/provider/**都會被路由到gateway-provider這個服務(wù)中。

限流配置

經(jīng)過上述兩個步驟其實已經(jīng)整合好了Sentinel，此時訪問一下接口：http://localhost:9026/gateway/provider/port

然后在sentinel控制臺可以看到已經(jīng)被監(jiān)控了，監(jiān)控的路由是gateway-provider，如下圖：

此時我們可以為其新增一個route維度的限流，如下圖：

上圖中對gateway-provider這個路由做出了限流，QPS閾值為1。

此時快速訪問：http://localhost:9026/gateway/provider/port，看到已經(jīng)被限流了，如下圖：

以上route維度的限流已經(jīng)配置成功，小伙伴可以自己照著上述步驟嘗試一下。

API分組限流也很簡單，首先需要定義一個分組，API管理-> 新增API分組，如下圖：

匹配模式選擇了精確匹配（還有前綴匹配，正則匹配），因此只有這個uri：http://xxxx/gateway/provider/port會被限流。

第二步需要對這個分組添加流控規(guī)則，流控規(guī)則->新增網(wǎng)關(guān)流控，如下圖：

API名稱那里選擇對應(yīng)的分組即可，新增之后，限流規(guī)則就生效了。

陳某不再測試了，小伙伴自己動手測試一下吧...............

“陳某這里只是簡單的配置一下，至于限流規(guī)則持久化一些內(nèi)容請看陳某的Sentinel文章，這里就不再過多的介紹了。

”

如何自定義限流異常信息？

從上面的演示中可以看到默認(rèn)的異常返回信息是："Block........."，這種肯定是客戶端不能接受的，因此需要定制自己的異常返回信息。

下面介紹兩種不同的方式定制異常返回信息，開發(fā)中自己選擇其中一種。

直接配置文件中定制

開發(fā)者可以直接在配置文件中直接修改返回信息，配置如下：

spring:
??cloud:
????##?整合sentinel，配置sentinel控制臺的地址
????sentinel:
??????#配置限流之后，響應(yīng)內(nèi)容
??????scg:
????????fallback:
??????????##?兩種模式，一種是response返回文字提示信息，
??????????##?一種是redirect，重定向跳轉(zhuǎn)，需要同時配置redirect(跳轉(zhuǎn)的uri)
??????????mode:?response
??????????##?響應(yīng)的狀態(tài)
??????????response-status:?200
??????????##?響應(yīng)體
??????????response-body:?'{"code": 200,"message":?"請求失敗，稍后重試！"}'
上述配置中mode配置的是response，一旦被限流了，將會返回JSON串。

{
????"code":?200,
????"message":?"請求失敗，稍后重試！"
}
重定向的配置如下：

spring:
??cloud:
????##?整合sentinel，配置sentinel控制臺的地址
????sentinel:
??????#配置限流之后，響應(yīng)內(nèi)容
??????scg:
????????fallback:
??????????##?兩種模式，一種是response返回文字提示信息，一種是redirect，重定向跳轉(zhuǎn)，需要同時配置redirect(跳轉(zhuǎn)的uri)
??????????mode:?redirect
??????????##?跳轉(zhuǎn)的URL
??????????redirect:?http://www.baidu.com
一旦被限流，將會直接跳轉(zhuǎn)到：http://www.baidu.com

編碼定制

這種就不太靈活了，通過硬編碼的方式，完整代碼如下：

@Configuration
public?class?GatewayConfig?{
????/**
?????*?自定義限流處理器
?????*/
????@PostConstruct
????public?void?initBlockHandlers()?{
????????BlockRequestHandler?blockHandler?=?(serverWebExchange,?throwable)?->?{
????????????Map?map?=?new?HashMap();
????????????map.put("code",200);
????????????map.put("message","請求失敗，稍后重試！");
????????????return?ServerResponse.status(HttpStatus.OK)
????????????????????.contentType(MediaType.APPLICATION_JSON_UTF8)
????????????????????.body(BodyInserters.fromObject(map));
????????};
????????GatewayCallbackManager.setBlockHandler(blockHandler);
????}
}
兩種方式介紹完了，根據(jù)業(yè)務(wù)需求自己選擇適合的方式，當(dāng)然陳某更喜歡第一種，理由：約定>配置>編碼。

網(wǎng)關(guān)限流了，服務(wù)就安全了嗎？

很多人認(rèn)為只要網(wǎng)關(guān)層面做了限流，躲在身后的服務(wù)就可以高枕無憂了，你是不是也有這種想法？

很顯然這種想法是錯誤的，復(fù)雜的微服務(wù)架構(gòu)一個獨(dú)立服務(wù)不僅僅被一方調(diào)用，往往是多方調(diào)用，如下圖：

商品服務(wù)不僅僅被網(wǎng)關(guān)層調(diào)用，還被內(nèi)部訂單服務(wù)調(diào)用，這時候僅僅在網(wǎng)關(guān)層限流，那么商品服務(wù)還安全嗎？

一旦大量的請求訂單服務(wù)，比如大促秒殺，商品服務(wù)不做限流會被瞬間擊垮。

因此需要根據(jù)公司業(yè)務(wù)場景對自己負(fù)責(zé)的服務(wù)也要進(jìn)行限流兜底，最常見的方案：網(wǎng)關(guān)層集群限流 內(nèi)部服務(wù)的單機(jī)限流兜底，這樣才能保證不被流量沖垮。

總結(jié)

文章介紹了Spring Cloud Gateway整合Sentinel對網(wǎng)關(guān)層進(jìn)行限流，以及關(guān)于限流的一些思考。如有錯誤之處，歡迎留言指正。