Gateway网关-全局过滤器
生活随笔
收集整理的這篇文章主要介紹了
Gateway网关-全局过滤器
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
全局過濾器
上一節學習的過濾器,網關提供了31種,但每一種過濾器的作用都是固定的。如果我們希望攔截請求,做自己的業務邏輯則沒辦法實現。
全局過濾器作用
全局過濾器的作用也是處理一切進入網關的請求和微服務響應,與GatewayFilter的作用一樣。區別在于GatewayFilter通過配置定義,處理邏輯是固定的;而GlobalFilter的邏輯需要自己寫代碼實現。
定義方式是實現GlobalFilter接口。
public interface GlobalFilter {/*** 處理當前請求,有必要的話通過{@link GatewayFilterChain}將請求交給下一個過濾器處理** @param exchange 請求上下文,里面可以獲取Request、Response等信息* @param chain 用來把請求委托給下一個過濾器 * @return {@code Mono<Void>} 返回標示當前過濾器業務結束*/Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain); }在filter中編寫自定義邏輯,可以實現下列功能:
-
登錄狀態判斷
-
權限校驗
-
請求限流等
自定義全局過濾器
需求:定義全局過濾器,攔截請求,判斷請求的參數是否滿足下面條件:
-
參數中是否有authorization,
-
authorization參數值是否為admin
如果同時滿足則放行,否則攔截
實現:
在gateway中定義一個過濾器:
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.獲取請求參數MultiValueMap<String, String> params = exchange.getRequest().getQueryParams();// 2.獲取authorization參數String auth = params.getFirst("authorization");// 3.校驗if ("admin".equals(auth)) {// 放行return chain.filter(exchange);}// 4.攔截// 4.1.禁止訪問,設置狀態碼exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);// 4.2.結束處理return exchange.getResponse().setComplete();} }總結
以上是生活随笔為你收集整理的Gateway网关-全局过滤器的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Gateway网关-路由的过滤器配置
- 下一篇: Gateway网关-过滤器链执行顺序