diff --git a/fizz-common/src/main/java/we/util/NettyDataBufferUtils.java b/fizz-common/src/main/java/we/util/NettyDataBufferUtils.java index 440a377..352f840 100644 --- a/fizz-common/src/main/java/we/util/NettyDataBufferUtils.java +++ b/fizz-common/src/main/java/we/util/NettyDataBufferUtils.java @@ -59,7 +59,7 @@ public abstract class NettyDataBufferUtils extends org.springframework.core.io.b return dataBufferFactory.wrap(byteBuf); } - public static boolean release(@Nullable String reqId, @Nullable DataBuffer dataBuffer) { + public static boolean release(@Nullable String traceId, @Nullable DataBuffer dataBuffer) { if (dataBuffer instanceof PooledDataBuffer) { PooledDataBuffer pooledDataBuffer = (PooledDataBuffer) dataBuffer; if (pooledDataBuffer.isAllocated()) { @@ -69,7 +69,7 @@ public abstract class NettyDataBufferUtils extends org.springframework.core.io.b int refCnt = nativeBuffer.refCnt(); if (refCnt < 1) { if (log.isDebugEnabled()) { - log.debug(nativeBuffer + " ref cnt is " + refCnt, LogService.BIZ_ID, reqId); + log.debug(nativeBuffer + " ref cnt is " + refCnt, LogService.BIZ_ID, traceId); } return false; } diff --git a/fizz-core/src/main/java/we/plugin/requestbody/RequestBodyPlugin.java b/fizz-core/src/main/java/we/plugin/requestbody/RequestBodyPlugin.java index 4cbcbc1..8e85452 100644 --- a/fizz-core/src/main/java/we/plugin/requestbody/RequestBodyPlugin.java +++ b/fizz-core/src/main/java/we/plugin/requestbody/RequestBodyPlugin.java @@ -61,7 +61,7 @@ public class RequestBodyPlugin implements FizzPluginFilter { } finally { NettyDataBufferUtils.release(body); } - requestDecorator.getHeaders().remove(HttpHeaders.CONTENT_LENGTH); + // requestDecorator.getHeaders().remove(HttpHeaders.CONTENT_LENGTH); } ServerWebExchange mutatedExchange = exchange.mutate().request(requestDecorator).build(); ServerWebExchange newExchange = mutatedExchange;