SpringCloud-Gateway的Filter(Day8)
Filter介绍路由过滤器是用于修改进入的HTTP请求和返回的HTTP响应,路由过滤器只能指定路由进行使用。Spring Cloud Gateway内置了多种路由过滤器,他们都由Gateway Filter的工厂类来产生。编辑自定义过滤器(要求必须有参数args)package com.gcl.springcloud.filter;import lombok.Data;import lombok.
·
Filter介绍
路由过滤器是用于修改进入的HTTP请求和返回的HTTP响应,路由过滤器只能指定路由进行使用。Spring Cloud Gateway内置了多种路由过滤器,他们都由Gateway Filter的工厂类来产生。
编辑自定义过滤器(要求必须有参数args)
package com.gcl.springcloud.filter;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
import java.util.Date;
@Component
@Slf4j
public class MyGateWayFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
log.info("************* My GateWay Filter " + new Date() );
String args = exchange.getRequest().getQueryParams().getFirst("args");
if ( args == null ){
log.info( "************ 此次请求未携带参数" );
exchange.getResponse().setStatusCode( HttpStatus.NOT_ACCEPTABLE );
return exchange.getResponse().setComplete();
}
return chain.filter(exchange);
}
@Override
public int getOrder() {
// 优先级 ,0最高优先加载此过滤器
return 0;
}
}
运行演示
不携带参数
携带参数
由于我没有写对应的接口,所以才会报错,可以明显的看出来下边的Error Page并不是被自定义Filter拦截的。
更多推荐
已为社区贡献18条内容
所有评论(0)