如何解压通量 （以及如何写一个）？

如何解压通量 （以及如何写一个）？

public class HttpResponseHeadersHandler extends ChannelInboundHandlerAdapter {
private final HttpHeaders httpHeaders;

    @Override    public void channelRead(ChannelHandlerContext ctx, Object msg) {        if (msg instanceof HttpResponse &&     !HttpStatus.resolve(((HttpResponse) msg).status().pre()).is1xxInformational()) { HttpHeaders headers = ((HttpResponse) msg).headers(); httpHeaders.forEach(e -> {     log.warn("Modifying {} from: {} to: {}.", e.getKey(), headers.get(e.getKey()), e.getValue());     headers.set(e.getKey(), e.getValue()); });        }        ctx.fireChannelRead(msg);    }}

然后，我创建一个和

ClientHttpConnector

一起使用

WebClient

并

afterNettyContextInit

添加处理程序：

ctx.addHandlerLast(new ReadTimeoutHandler(readTimeoutMillis, TimeUnit.MILLISECONDS));ctx.addHandlerLast(new Slf4JLoggingHandler());if (forceDecompression) {    io.netty.handler.prec.http.HttpHeaders httpHeaders = new ReadonlyHttpHeaders( true, CONTENT_ENCODING, GZIP, CONTENT_TYPE, APPLICATION_JSON    );    HttpResponseHeadersHandler headersModifier = new HttpResponseHeadersHandler(httpHeaders);    ctx.addHandlerFirst(headersModifier);}ctx.addHandlerLast(new HttpContentDecompressor());

当然，对于未经GZIP压缩的响应，这将失败，因此，我

WebClient

仅在特定的用例中使用此的实例，在这种情况下，我确定响应是压缩的。

编写很容易：Spring有一个

ResourceEnprer

，因此

InputStream

可以简单地转换为

InputStreamResource

，瞧！