如何在 WebFilter 上配置 Spring DataBuffer 大小

Question

我从客户端获取了一个 gzip 压缩的内容，我需要在它到达控制器之前对其进行解压缩，否则我会遇到杰克逊解析异常。

我创建了一个 WebFilter 来包装请求并将正文映射到一个缩小的字节数组，如下所示：

  @Override
    public Flux<DataBuffer> getBody() {
      return request.getBody().map(requestDataBuffer -> {
        try {
          GZIPInputStream gzipInputStream = new GZIPInputStream(requestDataBuffer.asInputStream());
          StringWriter writer = new StringWriter();
          IOUtils.copy(gzipInputStream, writer, UTF_8);
          byte[] targetArray = writer.toString().getBytes();
          return new DefaultDataBufferFactory().wrap(targetArray);
        }
        catch (IOException e) {
          LOG.error("failed to create gzip input stream. content-encoding is {}", request.getHeaders().getFirst(CONTENT_ENCODING));
          return requestDataBuffer;
        }
      });
    }

但是，当请求正文太大时，数据缓冲区不包含所有数据，因此会出现流异常。

任何想法如何配置数据缓冲区或如何接受 gzip 压缩的内容？

Answer 1

我认为最好的方法是依赖 Netty 实现，并将服务器配置为使用 Netty 的支持。

您可以创建自定义 Reactor Netty 服务器的组件（或直接从 @Bean 方法返回 this 的新实例）：

@Component
public class RequestInflateCustomizer implements NettyServerCustomizer {

    @Override
    public HttpServer apply(HttpServer httpServer) {
        return httpServer.tcpConfiguration(
                tcp -> tcp.doOnConnection(conn -> conn.addHandlerFirst(new HttpContentDecompressor())));
    }

}