跟我學SpringCloud | 第十四篇:Spring Cloud Gateway高級應用

来源:https://www.cnblogs.com/babycomeon/archive/2019/07/14/11173609.html
-Advertisement-
Play Games

SpringCloud系列教程 | 第十四篇:Spring Cloud Gateway高級應用 Springboot: 2.1.6.RELEASE SpringCloud: Greenwich.SR1 如無特殊說明,本系列教程全採用以上版本 上一篇我們聊了Gateway和註冊中心的使用,以及 Gat ...


SpringCloud系列教程 | 第十四篇:Spring Cloud Gateway高級應用

Springboot: 2.1.6.RELEASE

SpringCloud: Greenwich.SR1

如無特殊說明,本系列教程全採用以上版本

上一篇我們聊了Gateway和註冊中心的使用,以及 Gataway 中 Filter 的基本使用,這篇文章我們將繼續介紹 Filter 的一些高級功能。

  • 熔斷
  • 限流
  • 重試

1. 限速路由器

限速在高併發場景中比較常用的手段之一,可以有效的保障服務的整體穩定性,Spring Cloud Gateway 提供了基於 Redis 的限流方案。所以我們首先需要添加對應的依賴包spring-boot-starter-data-redis-reactive

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis-reactive</artifactId>
</dependency>

配置文件中需要添加 Redis 地址和限流的相關配置

server:
  port: 8080
spring:
  application:
    name: spring-cloud-gateway
  redis:
    host: localhost
    password: password
    port: 6379
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true
      routes:
        - id: requestratelimiter_route
          uri: http://example.org
          filters:
            - name: RequestRateLimiter
              args:
                redis-rate-limiter.replenishRate: 10
                redis-rate-limiter.burstCapacity: 20
                key-resolver: "#{@userKeyResolver}"
          predicates:
            - Method=GET
  • filter 名稱必須是 RequestRateLimiter
  • redis-rate-limiter.replenishRate:允許用戶每秒處理多少個請求
  • redis-rate-limiter.burstCapacity:令牌桶的容量,允許在一秒鐘內完成的最大請求數
  • key-resolver:使用 SpEL 按名稱引用 bean

項目中設置限流的策略,創建 Config 類。

package com.springcloud.gateway.config;

import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import reactor.core.publisher.Mono;

/**
 * Created with IntelliJ IDEA.
 *
 * @Date: 2019/7/11
 * @Time: 23:45
 * @email: [email protected]
 * Description:
 */
@Configuration
public class Config {
    @Bean
    KeyResolver userKeyResolver() {
        return exchange -> Mono.just(exchange.getRequest().getQueryParams().getFirst("user"));
    }
}

Config類需要加@Configuration註解。

根據請求參數中的 user 欄位來限流,也可以設置根據請求 IP 地址來限流,設置如下:

@Bean
public KeyResolver ipKeyResolver() {
    return exchange -> Mono.just(exchange.getRequest().getRemoteAddress().getHostName());
}

這樣網關就可以根據不同策略來對請求進行限流了。

2. 熔斷路由器

在之前的 Spring Cloud 系列文章中,大家對熔斷應該有了一定的瞭解,如過不瞭解可以先讀這篇文章:《跟我學SpringCloud | 第四篇:熔斷器Hystrix》

Spring Cloud Gateway 也可以利用 Hystrix 的熔斷特性,在流量過大時進行服務降級,同樣我們還是首先給項目添加上依賴。

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

配置示例

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

配置後,gateway 將使用 myCommandName 作為名稱生成 HystrixCommand 對象來進行熔斷管理。如果想添加熔斷後的回調內容,需要在添加一些配置。

spring:
  cloud:
    gateway:
      routes:
      - id: hystrix_route
        uri: lb://spring-cloud-producer
        predicates:
        - Path=/consumingserviceendpoint
        filters:
        - name: Hystrix
          args:
            name: fallbackcmd
            fallbackUri: forward:/incaseoffailureusethis

fallbackUri: forward:/incaseoffailureusethis配置了 fallback 時要會調的路徑,當調用 Hystrix 的 fallback 被調用時,請求將轉發到/incaseoffailureuset這個 URI。

3. 重試路由器

RetryGatewayFilter 是 Spring Cloud Gateway 對請求重試提供的一個 GatewayFilter Factory。

配置示例

spring:
  cloud:
    gateway:
      routes:
      - id: retry_test
        uri: lb://spring-cloud-producer
        predicates:
        - Path=/retry
        filters:
        - name: Retry
          args:
            retries: 3
            statuses: BAD_GATEWAY

Retry GatewayFilter 通過這四個參數來控制重試機制: retries, statuses, methods, 和 series。

  • retries:重試次數,預設值是 3 次
  • statuses:HTTP 的狀態返回碼,取值請參考:org.springframework.http.HttpStatus
  • methods:指定哪些方法的請求需要進行重試邏輯,預設值是 GET 方法,取值參考:org.springframework.http.HttpMethod
  • series:一些列的狀態碼配置,取值參考:org.springframework.http.HttpStatus.Series。符合的某段狀態碼才會進行重試邏輯,預設值是 SERVER_ERROR,值是 5,也就是 5XX(5 開頭的狀態碼),共有5 個值。

以上便是項目中常用的一些網關操作,更多關於 Spring Cloud GateWay 的使用請參考官網。

spring-cloud-gateway官網

示例代碼-Github

參考:

https://cloud.spring.io/spring-cloud-gateway/single/spring-cloud-gateway.html
https://windmt.com/2018/05/11/spring-cloud-16-spring-cloud-gateway-others/


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 一、開閉原則(是面向對象開發中最基礎的原則,它指導建立更加穩定靈活的系統) 開閉原則是對擴展和修改行為的一個原則,指的是軟體中的函數、類、模塊應該對擴展開放,對修改關閉。強調的是用抽象構建框架,用實現擴展細節。常用於解決的問題如:更新版本時,儘量在不修改源代碼,但增加新功能。 二、依賴倒置 依賴倒置 ...
  • 來自:Python編程與實戰(微信號:pthon1024),作者:Jerryning 沒有辦法轉,整個複製下來了 本文要點 字元串拼接 拆分含有多種分隔符的字元串 判讀字元串a是否以字元串b開頭或結尾 調整字元串中文本的格式 對字元串進行左,右,居中對齊 刪除字元串中不需要的字元 字元串拼接 拆分含 ...
  • Spring Cloud Alibaba | 序言 @[TOC] 1. Spring Cloud Alibaba是什麼? Spring Cloud Alibaba 致力於提供微服務開發的一站式解決方案。此項目包含開發分散式應用微服務的必需組件,方便開發者通過 Spring Cloud 編程模型輕鬆使 ...
  • 我們分析軟體項目開發過程中各階段的時間占比可以慢慢體會到,一套軟體項目 UI及基本業務的設計會占到整個項目開發的50%以上的時間,再看UI設計,通用的部分占到70%以上,我們會想,如果能將這些重覆簡易的工作能否通過簡易的操作來快速實現呢? 這樣可以將大部分的時間用到後續的真實業務邏輯處理上去,就可以 ...
  • 接著學習設計模式系列,今天講解的是代理模式。 定義 什麼是代理模式? 代理模式,也叫委托模式,其定義是給某一個對象提供一個代理對象,並由代理對象控制對原對象的引用。它包含了三個角色: Subject:抽象主題角色。可以是抽象類也可以是介面,是一個最普通的業務類型定義。 RealSubject:具體主 ...
  • 《Head First設計模式》已經讀了不止一遍,但是始終沒有進行系統的進行總結。所以近期開始總結設計模式相關的知識,從模板方法模式開始,因為是一個我認為是最簡單的設計模式。(推薦視頻資源 "23個設計模式" ) 提出&解決問題 提出問題 實現製作咖啡功能 。且製作咖啡需要四個步驟 : 1. 燒水 ...
  • 舉個慄子 問題描述 小時候數學老師的隨堂測驗,都是在黑板上抄題目,然後再作答案。寫一個抄題目的程式。 簡單實現 學生甲抄的試卷 學生乙抄的試卷 測試 測試結果 存在問題 兩個學生抄試卷都非常類似,除了答案不同,沒什麼不一樣,這樣又容易錯,又難以維護。因此老師出一份試卷,列印多份,讓學生填寫答案就可以 ...
  • 架構雜談《三》 一致性問題 前面的《架構雜談一》和《架構雜談二》 雜談了從服務化到微服務架構的演進,並肯定了服務化和微服務架構是一脈相承的。微服務在服務化架構的基礎上,對服務化的細節和方案進行了優化和細化,重點突出了無中心化管理的微服務架構,通過對服務進行有效的拆分來實現敏捷開發和自動化部署,併在海 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...