摘要: 原创出处 http://www.iocoder.cn/Spring-Cloud-Gateway/handler-filtering-web-handler/ 「芋道源码」欢迎转载,保留摘要,谢谢!
本文主要基于 Spring-Cloud-Gateway 2.0.X M4
阅读源码最好的方式,是使用 IDEA 进行调试 Spring Cloud Gateway 源码,不然会一脸懵逼。
1. 概述
本文主要分享 FilteringWebHandler。
在 《Spring-Cloud-Gateway 源码解析 —— 处理器 (3.2) 之 RoutePredicateHandlerMapping 路由匹配 》「2.1 SimpleHandlerAdapter」 里,我们看到 SimpleHandlerAdapter#handle(ServerWebExchange, Object) 调用 FilteringWebHandler#handle(ServerWebExchange) 方法,处理请求。
FilteringWebHandler 通过创建请求对应的 Route 对应的 GatewayFilterChain 进行处理。

推荐 Spring Cloud 书籍:
请支持正版。下载盗版,等于主动编写低级 BUG 。
程序猿DD —— 《Spring Cloud微服务实战》
两书齐买,京东包邮。
2. FilteringWebHandler
org.springframework.cloud.gateway.handler.FilteringWebHandler ,#handle(ServerWebExchange) 代码如下 :
public class FilteringWebHandler implements WebHandler {
/**
* 全局过滤器
*/
private final List<GatewayFilter> globalFilters;
@Override
public Mono<Void> handle(ServerWebExchange exchange) {
// 获得 Route
Route route = exchange.getRequiredAttribute(GATEWAY_ROUTE_ATTR);
// 获得 GatewayFilter
List<GatewayFilter> gatewayFilters = route.getFilters();
List<GatewayFilter> combined = new ArrayList<>(this.globalFilters);
combined.addAll(gatewayFilters);
// 排序
//TODO: needed or cached?
AnnotationAwareOrderComparator.sort(combined);
logger.debug("Sorted gatewayFilterFactories: "+ combined);
// 创建 DefaultGatewayFilterChain
return new DefaultGatewayFilterChain(combined).filter(exchange);
}
}本方法涉及到的过滤器 GlobalFilter / GatewayFilter / GatewayFilterAdapter / OrderedGatewayFilter 类,我们在 《Spring-Cloud-Gateway 源码解析 —— 过滤器 (4.1) 之 GatewayFilter 一览》 详细解析。
本方法涉及到的过滤器链 GatewayFilterChain / DefaultGatewayFilterChain 类,我们在 《Spring-Cloud-Gateway 源码解析 —— 过滤器 (4.1) 之 GatewayFilter 一览》 详细解析。
第 11 行 :从
GATEWAY_ROUTE_ATTR获得 请求对应的 Route 。第 13 至 15 行 :获得 GatewayFilter 数组,包含
route.filters和globalFilters。第 19 行 :排序获得的 GatewayFilter 数组。
第 23 行 :使用获得的 GatewayFilter 数组创建 DefaultGatewayFilterChain ,过滤处理请求。