在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