springcloud gateway自定义Filter

### Spring Cloud Gateway 自定义过滤器实现 在 Spring Cloud Gateway 中，自定义过滤器可以通过继承 `GatewayFilter` 或者通过工厂模式创建来实现。以下是关于如何实现自定义过滤器的具体方法。 #### 创建全局过滤器 要创建一个全局过滤器，可以实现 `GlobalFilter` 接口并注册到 Spring 容器中。下面是一个简单的例子： ```java import org.springframework.cloud.gateway.filter.GatewayFilterChain; import org.springframework.cloud.gateway.filter.GlobalFilter; import org.springframework.core.Ordered; import org.springframework.http.server.reactive.ServerHttpRequest; import org.springframework.stereotype.Component; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Mono; @Component public class CustomGlobalFilter implements GlobalFilter, Ordered { @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { ServerHttpRequest request = exchange.getRequest(); System.out.println("Custom Filter: " + request.getMethod() + " " + request.getURI()); // 可在此处添加逻辑处理请求或响应 return chain.filter(exchange); } @Override public int getOrder() { return 0; // 设置优先级，数值越低优先级越高 } } ``` 此代码片段展示了如何创建一个打印日志的简单全局过滤器[^1]。 #### 使用 Factory 方法创建局部过滤器 如果需要针对特定路由应用过滤器，则应使用工厂类的方式。以下是如何创建和配置局部过滤器的一个实例： ```java import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory; import org.springframework.http.HttpHeaders; import org.springframework.stereotype.Component; @Component public class AddRequestHeaderGatewayFilterFactory extends AbstractGatewayFilterFactory<AddRequestHeaderGatewayFilterFactory.Config> { public static class Config { private String name; private String value; public void setName(String name) { this.name = name;} public String getName() {return this.name;} public void setValue(String value){this.value=value;} public String getValue(){return this.value;} } public AddRequestHeaderGatewayFilterFactory(){ super(Config.class); } @Override public org.springframework.cloud.gateway.filter.GatewayFilter apply(Config config){ return (exchange,chain)->{ exchange.getRequest().mutate() .header(config.getName(),config.getValue()) .build(); return chain.filter(exchange); }; } } ``` 上述代码展示了一个用于向请求头添加字段的局部过滤器工厂[^2]。 #### 配置文件中的设置 为了使这些过滤器生效，在 application.yml 文件中需做如下配置： ```yaml spring: cloud: gateway: routes: - id: add_request_header_route uri: http://example.org filters: - AddRequestHeader=foo, bar ``` 以上 YAML 片段说明了如何将前面定义好的局部过滤器应用于指定 URI 的路由上[^3]。 ### 注意事项 - **线程安全性**：由于网关可能运行于高并发环境之下，因此编写过滤器时需要注意其线程安全特性。 - **性能影响**：复杂的业务逻辑可能会增加延迟时间，故建议仅执行必要的操作。