Spring Cloud Alibaba 网关 Gateway 集成
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;
@Component
public class CustomGlobalFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
// 示例:检查请求参数是否合法
String param = exchange.getRequest().getQueryParams().getFirst("param");
if (param == null || !param.equals("expected")) {
// 如果请求参数不合法,返回400 Bad Request
exchange.getResponse().setStatusCode(HttpStatus.BAD_REQUEST);
return exchange.getResponse().setComplete();
}
// 如果请求参数合法,继续执行后续过滤器
return chain.filter(exchange);
}
@Override
public int getOrder() {
// 定义过滤器的顺序,数值越小,优先级越高
return -1;
}
}
这段代码定义了一个全局过滤器,用于检查请求中的参数是否符合预期。如果请求参数不合法,则返回400 Bad Request错误。这是一个简单的权限校验或参数验证的例子,展示了如何在请求处理之前对其进行检查和控制。
评论已关闭