如何使用spring web客户端响应

Question

我正在spring应用程序中使用web客户端

我在执行相同操作时面临内存泄漏问题

我正在使用下面的代码获取来自服务的非2xx响应的响应体：

return client.get()
                .uri(uriString)
                .headers(ServiceCommonUtil.getHttpHeaderConsumer(headersMap))
                .exchange()
                .flatMap(clientResponse -> {
                    try {
                        clientResponse.body((clientHttpResponse, context) ->
                                clientHttpResponse.getBody());
                        logResponseStatus(clientResponse.statusCode(), serviceName);
                        return clientResponse.bodyToMono(String.class);
                    } catch (Exception e) {
                        return null;
                    }

                })

responseMono.subscribe(response -> {
    //process response string
},error->{
    //process error response
});

我的问题是，如果我在responseMono上使用dispose方法，处理过程需要很长的时间，而没有它，我会面临内存泄漏问题。我在这里做错什么了吗？

Answer 1

是的，实际上您并不是在抛出异常的情况下完成响应。

如果要使用exchange()，您的责任是消耗响应。参见：文档

请查看“ClientResponse”API中的TobodilessEntity()/ReleaseBody()。