欢迎大家关注我的微信公众号【老周聊架构】，Java后端主流技术栈的原理、源码分析、架构以及各种互联网高并发、高性能、高可用的解决方案。
前几篇我们讲了 Gateway 相应的初始化、路由相关模型以及 Predicate 谓词详解，这一篇我们再来讲一下 Filter Chain 过滤器链，讲完这一篇，相信你对 Gateway 源码整体设计思想有个深刻的体会了，后续你想去抠细节也不是什么难事了。前几篇可以回顾下：
Spring Cloud Gateway 源码剖析之配置初始化
Spring Cloud Gateway 源码剖析之Route数据模型
Spring Cloud Gateway 源码剖析之Predicate谓词详解
回顾完了我们再来看一张 Spring Cloud Gateway 的整体流程图，相信一直看完这个系列的很快的就能知道上一篇我们讲到了 Predicate 断言这一块，如果 Handler Mapping 匹配成功则会通过 GatewayWebHandler 创建请求对应的 Route 对应的 Filter Chain 来进行处理请求。我们按照这个流程图来看的话，接下来要讲的是通过网关自定义的 WebHandler 来处理请求，这里就来讲一下最重要 FilteringWebHandler 过滤器链。
// org.springframework.cloud.gateway.handler.FilteringWebHandler
/**
* 通过过滤器处理web请求的处理器
*/
public class FilteringWebHandler implements WebHandler {
protected static final Log logger = LogFactory.getLog(FilteringWebHandler.class);
/**
* 全局过滤器
*/
private final List<GatewayFilter> globalFilters;
public FilteringWebHandler(List<GlobalFilter> globalFilters) {
this.globalFilters = loadFilters(globalFilters);
}
/**
* 组成过滤链
* 包装加载全局的过滤器，将全局过滤器包装成GatewayFilter
*/
private static List<GatewayFilter> loadFilters(List<GlobalFilter> filters) {
return (List)filters.stream().map((filter) -> {
FilteringWebHandler.GatewayFilterAdapter gatewayFilter = new FilteringWebHandler.GatewayFilterAdapter(filter);
// 当 GlobalFilter 子类实现了 org.springframework.core.Ordered 接口，在委托一层 OrderedGatewayFilter 。
// 这样 AnnotationAwareOrderComparator#sort(List) 方法好排序。
if (filter instanceof Ordered) {
int order = ((Ordered)filter).getOrder();
return new OrderedGatewayFilter(gatewayFilter, order);
} else {
return gatewayFilter;
}
}).collect(Collectors.toList());
}
// 按照过滤链的顺序依次执行
public Mono<Void> handle(ServerWebExchange exchange) {
// 获取请求上下文设置的路由实例
Route route = (Route)exchange.getRequiredAttribute(ServerWebExchangeUtils.GATEWAY_ROUTE_ATTR);
// 获取路由定义下的网关过滤器集合
List<GatewayFilter> gatewayFilters = route.getFilters();
// 组合全局的过滤器与路由配置的过滤器
List<GatewayFilter> combined = new ArrayList(this.globalFilters);
// 添加路由配置过滤器到集合尾部
combined.addAll(gatewayFilters);
// 对过滤器进行排序
AnnotationAwareOrderComparator.sort(combined);
if (logger.isDebugEnabled()) {
logger.debug("Sorted gatewayFilterFactories: " + combined);
}
// 创建过滤器链表对其进行链式调用
return (new FilteringWebHandler.DefaultGatewayFilterChain(combined)).filter(exchange);
}
...
}
FilteringWebHandler 的执行顺序：
2.1 GatewayFilter 与 GlobalFilter 的关系
private final List<GatewayFilter> globalFilters;
public FilteringWebHandler(List<GlobalFilter> globalFilters) {
this.globalFilters = loadFilters(globalFilters);
}
2.1.1 GatewayFilter 网关过滤器接口
public interface GatewayFilter extends ShortcutConfigurable {
String NAME_KEY = "name";
String VALUE_KEY = "value";
Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);
}
GatewayFilter 有三种类型的子类实现
OrderedGatewayFilter ：有序的网关过滤器实现类。在 FilterChain 里，过滤器数组首先会按照 order 升序排序，按照顺序过滤请求。
public class OrderedGatewayFilter implements GatewayFilter, Ordered {
// 委托的 GatewayFilter
private final GatewayFilter delegate;
// order代表顺序
private final int order;
public OrderedGatewayFilter(GatewayFilter delegate, int order) {
this.delegate = delegate;
this.order = order;
}
public GatewayFilter getDelegate() {
return this.delegate;
}
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
return this.delegate.filter(exchange, chain);
}
public int getOrder() {
return this.order;
}
public String toString() {
StringBuilder sb = new StringBuilder("OrderedGatewayFilter{");
sb.append("delegate=").append(this.delegate);
sb.append(", order=").append(this.order);
sb.append('}');
return sb.toString();
}
}
GatewayFilterAdapter：网关过滤器适配器。在 GatewayFilterChain 使用 GatewayFilter 过滤请求，所以通过 GatewayFilterAdapter 将 GlobalFilter 适配成 GatewayFilter。
private static class GatewayFilterAdapter implements GatewayFilter {
// 委托的 GlobalFilter
private final GlobalFilter delegate;
public GatewayFilterAdapter(GlobalFilter delegate) {
this.delegate = delegate;
}
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
return this.delegate.filter(exchange, chain);
}
public String toString() {
StringBuilder sb = new StringBuilder("GatewayFilterAdapter{");
sb.append("delegate=").append(this.delegate);
sb.append('}');
return sb.toString();
}
}
ModifyResponseGatewayFilter：用于修改 Response
public class ModifyResponseGatewayFilter implements GatewayFilter, Ordered {
private final ModifyResponseBodyGatewayFilterFactory.Config config;
public ModifyResponseGatewayFilter(ModifyResponseBodyGatewayFilterFactory.Config config) {
this.config = config;
}
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
ServerHttpResponseDecorator responseDecorator = new ServerHttpResponseDecorator(exchange.getResponse()) {
public Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {
Class inClass = ModifyResponseGatewayFilter.this.config.getInClass();
Class outClass = ModifyResponseGatewayFilter.this.config.getOutClass();
String originalResponseContentType = (String)exchange.getAttribute("original_response_content_type");
HttpHeaders httpHeaders = new HttpHeaders();
httpHeaders.add("Content-Type", originalResponseContentType);
ModifyResponseBodyGatewayFilterFactory.ResponseAdapter responseAdapter = ModifyResponseBodyGatewayFilterFactory.this.new ResponseAdapter(body, httpHeaders);
DefaultClientResponse clientResponse = new DefaultClientResponse(responseAdapter, ExchangeStrategies.withDefaults());
Mono modifiedBody = clientResponse.bodyToMono(inClass).flatMap((originalBody) -> {
return ModifyResponseGatewayFilter.this.config.rewriteFunction.apply(exchange, originalBody);
});
BodyInserter bodyInserter = BodyInserters.fromPublisher(modifiedBody, outClass);
CachedBodyOutputMessage outputMessage = new CachedBodyOutputMessage(exchange, exchange.getResponse().getHeaders());
return bodyInserter.insert(outputMessage, new BodyInserterContext()).then(Mono.defer(() -> {
Flux<DataBuffer> messageBody = outputMessage.getBody();
HttpHeaders headers = this.getDelegate().getHeaders();
if (!headers.containsKey("Transfer-Encoding")) {
messageBody = messageBody.doOnNext((data) -> {
headers.setContentLength((long)data.readableByteCount());
});
}
return this.getDelegate().writeWith(messageBody);
}));
}
public Mono<Void> writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body) {
return this.writeWith(Flux.from(body).flatMapSequential((p) -> {
return p;
}));
}
};
return chain.filter(exchange.mutate().response(responseDecorator).build());
}
public int getOrder() {
return -2;
}
}
2.1.2 GlobalFilter 全局过滤器接口，会作用到所有的Route上。
public interface GlobalFilter {
Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);
}
在上一篇 Spring Cloud Gateway 源码剖析之Predicate谓词详解 中，已经详细介绍了 PredicateFactory 的各种子类实现。GatewayFilterFactory 也一样，这里就详细分析了哈。
欢迎大家关注我的公众号【老周聊架构】，Java后端主流技术栈的原理、源码分析、架构以及各种互联网高并发、高性能、高可用的解决方案。
喜欢的话，一键三连走一波。
详解 Spring注解的（ListMap）特殊注入功能 最近接手一个新项目，已经没有原开发...
OBJECT ID="agobjOraSession" RUNAT="Server" PROGID="OracleInProcServer.XOraS...
H5支付是指商户在微信客户端外的移动端网页展示商品或服务，用户在前述页面确认...
1，父传子 子组件中定义 props 字段，类型为数组（如果需要限制字段值类型，也可...
我们通常衡量一个Web系统的吞吐率的指标是QPS（Query Per Second，每秒处理请求...
先看代码 复制代码 代码如下: div style="position:relative; width:[flash的宽]...
0x01 Mysql Mysql划分：权限 root 普通用户 版本 mysql5.0 mysql5.0 1.1 root权...
CentOS版本:7.6.1810 3台 JDK版本:1.8.0_191 Zookeeper版本:3.4.10 安装包 链接h...
XML/HTML Code 复制内容到剪贴板 input id = username name = username type = t...
本文转载自微信公众号「 jinjunzhu」，作者 jinjunzhu 。转载本文请联系 jinjunz...
