Spring Cloud Gateway 04 扩展

在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.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
import java.util.logging.Logger;
 
public class CustomGlobalFilter implements GlobalFilter, Ordered {
 
    private Logger logger = Logger.getLogger(getClass().getName());
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        // 在发送请求前记录日志
        logger.info("Custom Global Filter: Request URL: " + exchange.getRequest().getURI().getPath());
 
        // 继续执行过滤器链
        return chain.filter(exchange);
    }
 
    @Override
    public int getOrder() {
        // 定义过滤器顺序，数字越小，优先级越高
        return -1;
    }
}

在上述代码中，我们定义了一个CustomGlobalFilter类，它实现了GlobalFilter接口和Ordered接口。filter方法会在请求被路由之前被调用，我们可以在这里添加任何我们想要的逻辑，比如记录日志、进行身份验证等。getOrder方法返回的数字越小，过滤器的优先级越高，这意味着它将更早地被调用。

要将此自定义过滤器注册到Spring Cloud Gateway中，可以将其定义为Spring Bean：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class FilterConfig {
 
    @Bean
    public CustomGlobalFilter customGlobalFilter() {
        return new CustomGlobalFilter();
    }
}

这样，CustomGlobalFilter就会作为全局过滤器被Spring Cloud Gateway应用于所有路由的请求之前。