修改日志打印
This commit is contained in:
@ -27,19 +27,20 @@ import java.nio.charset.StandardCharsets;
|
|||||||
@Slf4j
|
@Slf4j
|
||||||
@Component
|
@Component
|
||||||
public class LoggingGlobalFilter implements GlobalFilter, Ordered {
|
public class LoggingGlobalFilter implements GlobalFilter, Ordered {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
|
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
|
||||||
// 创建自定义 exchange 装饰器
|
// 创建自定义 exchange 装饰器
|
||||||
CustomExchange decoratedExchange = new CustomExchange(exchange);
|
CustomExchange decoratedExchange = new CustomExchange(exchange);
|
||||||
|
|
||||||
return chain.filter(decoratedExchange)
|
return chain.filter(decoratedExchange)
|
||||||
.then(Mono.fromRunnable(() -> {
|
.doOnSuccess(aVoid -> {
|
||||||
log.info("🌐 请求路径: {}", exchange.getRequest().getPath());
|
log.info("🌐 请求路径: {}", exchange.getRequest().getPath());
|
||||||
log.info("📥 请求头: {}", exchange.getRequest().getHeaders());
|
log.info("📥 请求头: {}", exchange.getRequest().getHeaders());
|
||||||
log.info("📥 请求体: {}", decoratedExchange.getRequestBody());
|
log.info("📥 请求体: {}", decoratedExchange.getRequestBody());
|
||||||
log.info("🔚 响应状态: {}", exchange.getResponse().getStatusCode());
|
log.info("🔚 响应状态: {}", exchange.getResponse().getStatusCode());
|
||||||
log.info("📤 响应内容: {}", decoratedExchange.getResponseBody());
|
log.info("📤 响应内容: {}", decoratedExchange.getResponseBody());
|
||||||
}));
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
Reference in New Issue
Block a user