Spring Cloud 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 someHeader = exchange.getRequest().getHeaders().getFirst("Some-Header");
        if (someHeader == null) {
            // 如果没有这个头，返回403 Forbidden
            exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);
            return exchange.getResponse().setComplete();
        }
 
        // 如果有这个头，继续请求处理
        return chain.filter(exchange);
    }
 
    @Override
    public int getOrder() {
        // 定义全局过滤器的顺序，数字越小，优先级越高
        return -1;
    }
}

这段代码定义了一个全局过滤器，用于检查进入Spring Cloud Gateway的请求中是否包含特定的头信息。如果请求中没有这个头信息，过滤器会直接返回403 Forbidden响应，否则请求会继续传递给下一个过滤器或目标微服务。通过设置过滤器的顺序为最高，我们确保了这个过滤器会在请求处理的早期阶段执行。