你好兄弟这里是我的loggingFilter。我只记录请求对象，因为在我的项目中，响应对象可以是4 5 mb，我不想在日志中看到它。在你的情况下，你应该释放databuffer与这样的东西。doOnDiscard（PooledDataBuffer.class，DataBufferUtils：：release）;

@Slf4j
@Component
public class LoggingFilter implements GlobalFilter, Ordered {

  @Autowired private Tracer tracer;
  private static final Set<String> LOGGABLE_CONTENT_TYPES =
      new HashSet<>(
          Arrays.asList(
              MediaType.APPLICATION_JSON_VALUE.toLowerCase(),
              MediaType.APPLICATION_JSON_UTF8_VALUE.toLowerCase(),
              MediaType.TEXT_PLAIN_VALUE,
              MediaType.TEXT_XML_VALUE));

  @Override
  public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
    String traceId =
        tracer.currentSpan() != null
            ? tracer.currentSpan().context().traceIdString()
            : tracer.nextSpan().context().traceIdString();
    ServerHttpRequest mutatedServerHttpRequest =
        exchange.getRequest().mutate().header("x-b3-traceid", traceId).build();
    var requestMutated =
        new ServerHttpRequestDecorator(mutatedServerHttpRequest) {
          @Override
          public Flux<DataBuffer> getBody() {
            var requestLogger = new Logger(getDelegate());
            if (LOGGABLE_CONTENT_TYPES.contains(
                String.valueOf(getHeaders().getContentType()).toLowerCase())) {
              return super.getBody()
                  .map(
                      ds -> {
                        requestLogger.appendBody(ds.asByteBuffer());
                        return ds;
                      })
                  .doFinally((s) -> requestLogger.log())
                      .doOnDiscard(PooledDataBuffer.class, DataBufferUtils::release);
            } else {
              requestLogger.log();
              return super.getBody().doOnDiscard(PooledDataBuffer.class, DataBufferUtils::release);
            }
          }
        };
    var responseMutated =
        new ServerHttpResponseDecorator(exchange.getResponse()) {
          @Override
          public Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {
            //var responseLogger = new Logger(getDelegate());
            if (LOGGABLE_CONTENT_TYPES.contains(
                String.valueOf(getHeaders().getContentType()).toLowerCase())) {
              return join(body)
                  .flatMap(
                      db -> {
                        //responseLogger.appendBody(db.asByteBuffer());
                        //responseLogger.log();
                        return getDelegate().writeWith(Mono.just(db));
                      }).doOnDiscard(PooledDataBuffer.class, DataBufferUtils::release);
            } else {
              //responseLogger.log();
              return getDelegate().writeWith(body).doOnDiscard(PooledDataBuffer.class, DataBufferUtils::release);
            }
          }
        };

    return chain.filter(
        exchange.mutate().request(requestMutated).response(responseMutated).build());
  }

  private Mono<? extends DataBuffer> join(Publisher<? extends DataBuffer> dataBuffers) {
    Assert.notNull(dataBuffers, "'dataBuffers' must not be null");
    return Flux.from(dataBuffers)
        .collectList()
        .filter((list) -> !list.isEmpty())
        .map((list) -> list.get(0).factory().join(list))
        .doOnDiscard(PooledDataBuffer.class, DataBufferUtils::release);
  }

  @Override
  public int getOrder() {
    return Ordered.HIGHEST_PRECEDENCE;
  }

  @ToString
  private class Logger {
    private Map<String, String> headers;
    private HttpStatus status;
    private String path;
    private String body;

    Logger(ServerHttpResponse response) {
      headers = response.getHeaders().toSingleValueMap();
      status = HttpStatus.valueOf(response.getStatusCode().value());
    }

    Logger(ServerHttpRequest request) {
      if (tracer.currentSpan() == null || tracer.currentSpan().context() == null) {
        MDC.put("traceId", request.getHeaders().getFirst("x-b3-traceid"));
      } else {
        MDC.put("traceId", tracer.currentSpan().context().traceIdString());
      }
      headers = request.getHeaders().toSingleValueMap();
      path = request.getMethod() + " " + request.getPath();
    }

    void appendBody(ByteBuffer byteBuffer) {
      body = StandardCharsets.UTF_8.decode(byteBuffer).toString();
    }

    void log() {
      log.info(this.toString());
    }
  }
}

字符串