在Spring Cloud Gateway中，可以通过实现GlobalFilter接口来创建一个全局过滤器。全局过滤器会应用于所有路由。以下是一个简单的全局过滤器示例，它会在请求被路由前和响应被发送回客户端后记录日志：
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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;
public class LoggingFilter implements GlobalFilter, Ordered {
private Logger logger = LoggerFactory.getLogger(LoggingFilter.class);
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
long startTime = System.currentTimeMillis();
return chain.filter(exchange)
.then(Mono.fromRunnable(() -> {
long endTime = System.currentTimeMillis();
this.logger.info("请求URI: {}，耗时: {}ms", exchange.getRequest().getURI(), endTime - startTime);
}));
}
@Override
public int getOrder() {
// 确保这个过滤器是在其他过滤器之前
return -1;
}
}
在上述代码中，LoggingFilter类实现了GlobalFilter接口，并定义了filter方法来记录请求的URI和处理时间。getOrder()方法返回的整数值代表了过滤器的执行顺序，返回-1意味着这是最高优先级的过滤器，将会最先执行。
要将这个全局过滤器注册到Spring Cloud Gateway中，可以将其定义为Spring的Bean：
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class GatewayConfig {
@Bean
public LoggingFilter loggingFilter() {
return new LoggingFilter();
}
}
这样配置后，每次请求通过Spring Cloud Gateway时都会经过这个日志记录过滤器。