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) {
        // 示例：检查请求参数中是否包含“?isBlocked=true”
        // 如果包含，则返回403 Forbidden
        return chain.filter(exchange).then(Mono.defer(() -> {
            String isBlocked = exchange.getRequest().getQueryParams().getFirst("isBlocked");
            if (Boolean.parseBoolean(isBlocked)) {
                exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);
                return Mono.empty();
            }
            return Mono.empty();
        }));
    }
 
    @Override
    public int getOrder() {
        // 定义过滤器的顺序，数字越小，优先级越高
        return -1;
    }
}

这段代码定义了一个全局过滤器，用于检查请求是否包含特定参数（本例中为isBlocked），如果包含且参数值为true，则响应403 Forbidden。这是一个简单的权限控制示例，实际应用中可以根据需要进行更复杂的逻辑判断。