sczx_group/sczx_gateway
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改返回值日志

Browse Source
This commit is contained in:
zhangli
2025-09-08 17:43:14 +08:00
parent bb92857db9
commit 8b5648a3dc
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/sczx/gateway/filter/LoggingGlobalFilter.java
View File

@ -94,7 +94,7 @@ public class LoggingGlobalFilter implements GlobalFilter, Ordered {
@Override @Override
public ServerHttpResponse getResponse() { public ServerHttpResponse getResponse() {
ServerHttpResponse originalResponse = super.getResponse(); ServerHttpResponse originalResponse = super.getResponse();
DataBufferFactory bufferFactory = originalResponse.bufferFactory(); // DataBufferFactory bufferFactory = originalResponse.bufferFactory();
return new ServerHttpResponseDecorator(originalResponse) { return new ServerHttpResponseDecorator(originalResponse) {
@Override @Override
@ -102,12 +102,15 @@ public class LoggingGlobalFilter implements GlobalFilter, Ordered {
if (body instanceof Flux) { if (body instanceof Flux) {
Flux<? extends DataBuffer> flux = (Flux<? extends DataBuffer>) body; Flux<? extends DataBuffer> flux = (Flux<? extends DataBuffer>) body;
return super.writeWith(flux.doOnNext(dataBuffer -> { return super.writeWith(flux.doOnNext(dataBuffer -> {
// 读取数据内容用于日志记录
byte[] bytes = new byte[dataBuffer.readableByteCount()]; byte[] bytes = new byte[dataBuffer.readableByteCount()];
dataBuffer.read(bytes); dataBuffer.read(bytes);
String bodyContent = new String(bytes, StandardCharsets.UTF_8); String bodyContent = new String(bytes, StandardCharsets.UTF_8);
responseBodyBuilder.append(bodyContent); responseBodyBuilder.append(bodyContent);
DataBufferUtils.release(dataBuffer);
}).map(bytes -> bufferFactory.wrap((ByteBuffer) bytes))); // 重置读取位置，以便后续处理可以正常读取
dataBuffer.readPosition(0);
}));
} }
return super.writeWith(body); return super.writeWith(body);
} }