Spring Cloud Alibaba微服务实战二十九 - SpringCloud Gateway 请求响应日志

在Spring Cloud Alibaba微服务实战中，我们通常需要记录请求和响应日志以便于调试和监控。对于Spring Cloud Gateway，我们可以通过定义全局过滤器来实现这一功能。

以下是一个简单的全局过滤器示例，用于记录请求和响应日志：

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.nio.charset.StandardCharsets;
 
public class RequestResponseLoggingFilter implements GlobalFilter {
 
    private Logger logger = LoggerFactory.getLogger(RequestResponseLoggingFilter.class);
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
 
        logger.info("Request Method: {}, URL: {}", request.getMethodValue(), request.getURI());
 
        return chain.filter(exchange).then(Mono.fromRunnable(() -> {
            ServerHttpResponse response = exchange.getResponse();
 
            // 由于response.getBody() 在之后的过滤器中可能被修改，所以我们需要先刷新并复制数据
            DataBufferUtils.join(response.getBody())
                    .subscribe(dataBuffer -> {
                        byte[] contents = new byte[dataBuffer.readableByteCount()];
                        dataBuffer.read(contents);
                        // 这里对响应内容进行了简单的转换，实际情况可能需要更复杂的处理
                        String responseBody = new String(contents, StandardCharsets.UTF_8);
                        logger.info("Response Body: {}", responseBody);
                    });
        }));
    }
}

然后，你需要将这个全局过滤器注册到Spring Cloud Gateway中：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
 
@Configuration
public class GatewayConfig {
 
    @Bean
    public RouteLocator customRouteLocator(RouteLocator routeLocator) {
        // ... 定义路由规则 ...
    }
 
    @Bean
    public AbstractGatewayFilterFactory myGatewayFi