欢迎访问Spring Cloud中国社区

《重新定义Spring Cloud实战》由Spring Cloud中国社区倾力打造,基于Spring Cloud的Finchley.RELEASE版本,本书内容宽度足够广、深度足够深,而且立足于生产实践,直接从生产实践出发,包含大量生产实践的配置。欢迎加微信Software_King进群答疑,国内谁在使用Spring Cloud?欢迎登记

Spring Cloud Gateway只有Pre和POST两种类型的Filter

xujin · 4月前 · 1623 ·

摘要:Spring Cloud Gateway只有两种类型的Filter,本文介绍如何在Spring Cloud Gateway中创建一个Pre或Post类型的Filter。

zuul的Filter类型

Zuul 的 Filter 是通过filterType()方法来指定,一个 Filter 只能对应一种类型。

Spring Cloud Gateway的Filter类型

Spring Cloud Gateway 基于 Project Reactor 和 WebFlux,采用响应式编程风格,打开它的 Filter 的接口GatewayFilter你会发现它只有一个方法filter

Pre类型的Filter

在Spring Cloud Gateway源码中定义了一个Pre类型的Filter,code将会在chain.filter() 之前被执行,代码:AddRequestHeader

  1. package org.springframework.cloud.gateway.filter.factory;
  2. import org.springframework.cloud.gateway.filter.GatewayFilter;
  3. import org.springframework.http.server.reactive.ServerHttpRequest;
  4. /**
  5. * @author Spencer Gibb
  6. */
  7. public class AddRequestHeaderGatewayFilterFactory extends AbstractNameValueGatewayFilterFactory {
  8. @Override
  9. public GatewayFilter apply(NameValueConfig config) {
  10. return (exchange, chain) -> {
  11. ServerHttpRequest request = exchange.getRequest().mutate()
  12. .header(config.getName(), config.getValue())
  13. .build();
  14. return chain.filter(exchange.mutate().request(request).build());
  15. };
  16. }
  17. }

Post类型的Filter

对于Post类型的Filter,SetStatus
代码将会在chain.filter(exchange).then()里面的代码运行。

  1. public class SetStatusGatewayFilterFactory extends AbstractGatewayFilterFactory<SetStatusGatewayFilterFactory.Config> {
  2. @Override
  3. public GatewayFilter apply(Config config) {
  4. final HttpStatus status = ServerWebExchangeUtils.parse(config.status);
  5. return (exchange, chain) -> {
  6. return chain.filter(exchange).then(Mono.fromRunnable(() -> {
  7. // check not really needed, since it is guarded in setStatusCode,
  8. // but it's a good example
  9. if (!exchange.getResponse().isCommitted()) {
  10. setResponseStatus(exchange, status);
  11. }
  12. }));
  13. };
  14. }
  15. }

原文: http://xujin.org/sc/gw/gw06/