深入解析Spring Cloud Gateway的GlobalFilter

Spring Cloud Gateway的GlobalFilter是Spring Cloud Gateway中提供的一种全局过滤器，它可以拦截和修改进入和离开网关的请求。

要深入理解Spring Cloud Gateway的GlobalFilter，需要对Java 8的Functional Interface（函数式接口）有所了解。

以下是一个简单的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.io.buffer.DataBufferUtils;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
import java.time.ZonedDateTime;
 
public class CustomGlobalFilter implements GlobalFilter {
    private Logger logger = LoggerFactory.getLogger(CustomGlobalFilter.class);
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
        logger.info("Request: " + request.getPath().value() + " - " + ZonedDateTime.now());
 
        // 在response写入之前，对response的内容进行修改
        ServerHttpResponse response = exchange.getResponse();
        // 可以添加自定义的响应头或者响应内容
        // response.getHeaders().set("Custom-Header", "CustomHeaderValue");
        // return response.writeWith(Mono.just(response.bufferFactory().wrap("Custom response".getBytes())));
 
        // 继续执行过滤器链
        return chain.filter(exchange).then(Mono.fromRunnable(() -> {
            logger.info("Response: " + request.getPath().value() + " - " + ZonedDateTime.now());
        })).then(Mono.defer(() -> {
            // 对response的内容进行再次修改，例如记录响应时间等
            // 注意：这里不能直接修改response的内容，因为数据流已经发送
            // 可以记录响应时间，或者做日志
            return chain.filter(exchange);
        }));
    }
}

在这个例子中，我们创建了一个自定义的GlobalFilter，它记录请求的路径和接收到请求的时间，然后继续执行过滤器链，在过滤器链完成后记录响应的时间。

要注册这个自定义的GlobalFilter，你可以在Spring Cloud Gateway的配置中添加它：

@Configuration
public class GatewayConfig {
 
    @Bean
    public GlobalFilter customGlobalFilter() {
        return new CustomGlobalFilter();
    }
}

这样，每次请求经过Spring Cloud Gateway时，都会调用这个GlobalFilter，并且会记录请求和响应的相关信息。