Spring Cloud Gateway中的GlobalFilter：构建强大的API网关过滤器

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 AuthorizationGlobalFilter implements GlobalFilter, Ordered {
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 示例：检查请求中是否包含有效的API密钥
        String apiKey = exchange.getRequest().getQueryParams().getFirst("apiKey");
        if (apiKey == null || !apiKey.equals("mySecretApiKey")) {
            // 如果API密钥无效，则返回401未授权状态码
            exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
            return exchange.getResponse().setComplete();
        }
        // 如果API密钥有效，则继续请求处理
        return chain.filter(exchange);
    }
 
    @Override
    public int getOrder() {
        // 确保此过滤器在其他过滤器之前运行
        return -1;
    }
}

这段代码定义了一个全局过滤器，用于检查进入API网关的请求中是否包含有效的API密钥。如果密钥无效，则过滤器会直接返回HTTP状态码401，表示请求未被授权。这种方式可以用来实现简单的API访问控制，在实际应用中可以根据需要进行更复杂的权限控制。