SpringCloud系列教程 | 第十三篇:Spring Cloud Gateway服務化和過濾器 Springboot: 2.1.6.RELEASE SpringCloud: Greenwich.SR1 如無特殊說明,本系列教程全採用以上版本 上一篇文章服務網關 Spring Cloud Gat ...
SpringCloud系列教程 | 第十三篇:Spring Cloud Gateway服務化和過濾器
Springboot: 2.1.6.RELEASE
SpringCloud: Greenwich.SR1
如無特殊說明,本系列教程全採用以上版本
上一篇文章服務網關 Spring Cloud GateWay 初級篇,介紹了 Spring Cloud Gateway 的相關術語、技術原理,以及如何快速使用 Spring Cloud Gateway。這篇文章我們繼續學習 Spring Cloud Gateway 的高級使用方式,比如如何配置服務中心來使用,如何使用熔斷、限流等高級功能。
1. 註冊中心
1.1 準備服務和註冊中心
上篇主要講解了網關代理單個服務的使用語法,在實際的工作中,服務的相互調用都是依賴於服務中心提供的入口來使用,服務中心往往註冊了很多服務,如果每個服務都需要單獨配置的話,這將是一份很枯燥的工作。Spring Cloud Gateway 提供了一種預設轉發的能力,只要將 Spring Cloud Gateway 註冊到服務中心,Spring Cloud Gateway 預設就會代理服務中心的所有服務,下麵用代碼演示。
在介紹Zuul的時候,我們用到了Eureka和producer,本次演示還是需要他們兩個,將他們兩個CV過來。
1.2 服務網關註冊到註冊中心
上一篇用到的gateway也CV過來,在依賴文件裡面加入:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
添加對eureka的依賴,在啟動文件加入註解@EnableEurekaClient。
修改配置文件application.yml:
server:
port: 8080
spring:
application:
name: api-gateway
cloud:
gateway:
discovery:
locator:
enabled: true
eureka:
client:
service-url:
defaultZone: http://localhost:8761/eureka/
logging:
level:
org.springframework.cloud.gateway: debug
配置說明:
- spring.cloud.gateway.discovery.locator.enabled:是否與服務註冊於發現組件進行結合,通過 serviceId 轉發到具體的服務實例。預設為 false,設為 true 便開啟通過服務中心的自動根據 serviceId 創建路由的功能。
- eureka.client.service-url.defaultZone指定註冊中心的地址,以便使用服務發現功能
- logging.level.org.springframework.cloud.gateway 調整相 gateway 包的 log 級別,以便排查問題
修改完成後啟動 gateway 項目,訪問註冊中心地址 http://localhost:8761/ 即可看到名為 API-GATEWAY的服務。
1.3 測試
將 gateway 註冊到服務中心之後,網關會自動代理所有的在註冊中心的服務,訪問這些服務的語法為:
http://網關地址:埠/服務中心註冊 serviceId/具體的url
比如我們的 producer 項目有一個 /hello 的服務,訪問此服務的時候會返回:"hello "+name+",producer is ready"。
比如訪問地址:http://localhost:8081/hello?name=spring,頁面返回:hello spring,producer is ready。
按照上面的語法我們通過網關來訪問,瀏覽器輸入:http://localhost:8080/SPRING-CLOUD-PRODUCER/hello?name=spring 同樣返回:hello spring,producer is ready。證明服務網關轉發成功。
我們將項目 producer 複製一份為 producer1,將/hello服務的返回值修改為 hello spring,producer1 is ready。修改埠號為 8082 ,修完完成後重啟,這時候訪問註冊中心後臺會發現有兩個名為 SPRING-CLOUD-PRODUCER的服務。
在瀏覽器多次訪問地址:http://localhost:8888/SPRING-CLOUD-PRODUCER/hello,頁面交替返回以下信息:
hello spring,producer is ready。
hello spring,producer1 is ready。
說明後端服務自動進行了均衡負載。
2. 基於 Filter(過濾器) 實現的高級功能
在Zuul高級篇中大概介紹過 Filter 的概念。
Spring Cloud Gateway 的 Filter 的生命周期不像 Zuul 的那麼豐富,它只有兩個:“pre” 和 “post”。
- PRE: 這種過濾器在請求被路由之前調用。我們可利用這種過濾器實現身份驗證、在集群中選擇請求的微服務、記錄調試信息等。
- POST:這種過濾器在路由到微服務以後執行。這種過濾器可用來為響應添加標準的 HTTP Header、收集統計信息和指標、將響應從微服務發送給客戶端等。
Spring Cloud Gateway 的 Filter 分為兩種:GatewayFilter 與 GlobalFilter。GlobalFilter 會應用到所有的路由上,而 GatewayFilter 將應用到單個路由或者一個分組的路由上。
Spring Cloud Gateway 內置了9種 GlobalFilter,比如 Netty Routing Filter、LoadBalancerClient Filter、Websocket Routing Filter 等,根據名字即可猜測出這些 Filter 的作者,具體大家可以參考官網內容:Global Filters
利用 GatewayFilter 可以修改請求的 Http 的請求或者響應,或者根據請求或者響應做一些特殊的限制。 更多時候我們會利用 GatewayFilter 做一些具體的路由配置,下麵我們做一些簡單的介紹。
2.1 快速上手 Filter 使用
我們以 AddRequestParameter GatewayFilter 來演示一下,如何在項目中使用 GatewayFilter,AddRequestParameter GatewayFilter 可以在請求中添加指定參數。
2.1.1 配置application.yml示例
server:
port: 8080
spring:
application:
name: api-gateway
cloud:
gateway:
discovery:
locator:
enabled: true
routes:
- id: add_request_parameter_route
uri: http://localhost:8081
filters:
- AddRequestParameter=foo, bar
predicates:
- Method=GET
eureka:
client:
service-url:
defaultZone: http://localhost:8761/eureka/
logging:
level:
org.springframework.cloud.gateway: debug
這裡的 routes 手動指定了服務的轉發地址,設置所有的 GET 方法都會自動添加foo=bar,http://localhost:8081 是 producer 項目,我們在此項目中添加一個 foo() 方法,用來接收轉發中添加的參數 foo。
@RequestMapping("/foo")
public String foo(String foo) {
return "hello "+foo+"!";
}
修改完成後重啟 gateway、producer 項目。訪問地址 http://localhost:8081/foo 頁面返回:hello null!,說明並沒有接受到參數 foo;通過網關來調用此服務,瀏覽器訪問地址 http://localhost:8080/foo 頁面返回:hello bar!,說明成功接收到參數 foo 參數的值 bar ,證明網關在轉發的過程中已經通過 filter 添加了設置的參數和值。
2.2 服務化路由轉發
面我們使用 uri 指定了一個服務轉發地址,單個服務這樣使用問題不大,但是我們在註冊中心往往會使用多個服務來共同支撐整個服務的使用,這個時候我們就期望可以將 Filter 作用到每個應用的實例上,spring cloud gateway 工了這樣的功能,只需要簡單配置即可。
為了測試兩個服務提供者是否都被調用,我們在 producer1 項目中也同樣添加 foo() 方法。
@RequestMapping("/foo")
public String foo(String foo) {
return "hello "+foo+"!@@@@";
}
為了和 producer 中 foo() 方法有所區別,這裡使用了多加了4個@。同時將 gateway 項目配置文件中的 uri 內容修改如下:
#格式為:lb://應用註冊服務名
uri: lb://spring-cloud-producer
修改完之後,重新啟動項目 gateway、producer1,瀏覽器訪問地址: http://localhost:8080/foo 頁面交替出現:
hello bar!
hello bar!@@@@
證明請求依據均勻轉發到後端服務,並且後端服務均接收到了 filter 增加的參數 foo 值。
這裡其實預設使用了全局過濾器 LoadBalancerClient ,當路由配置中 uri 所用的協議為 lb 時(以uri: lb://spring-cloud-producer為例),gateway 將使用 LoadBalancerClient 把 producer 通過 eureka 解析為實際的主機和埠,併進行負載均衡。
參考:
http://www.ityouknow.com/springcloud/2019/01/19/spring-cloud-gateway-service.html