OkHttp：避免泄漏连接警告

Question

我正在使用 OkHttp 3，并且不断收到泄漏连接警告：

WARNING: A connection to https://help.helpling.com/ was leaked. Did you forget to close a response body?
Jul 14, 2016 6:57:09 PM okhttp3.ConnectionPool pruneAndGetAllocationCount

每次我得到一个

ResponseBody

时，我要么调用

.string()

来为我关闭流，要么我通过以下方式在

finally

块中明确关闭它：

ResponseBody responseBody = response.body();
try (Reader responseReader = responseBody.charStream()) {
    ...
}
finally {
    responseBody.close();
}

我的应用程序大量使用网络，但该警告频繁出现。我从未观察到由这种假定的泄漏引起的任何问题，但我仍然想了解if和what我做错了。

有人能解释一下吗？

Answer 1

通过升级到 OkHttp 3.7，Eclipse 开始警告我潜在的资源泄漏。我发现我的问题出在我写的这个方法中：

public static Response getResponse(HttpUrl url, OkHttpClient client) throws IOException {
    Builder request = new Request.Builder().url(url);
    Response response = client.newCall(request.build()).execute();
    if (!response.isSuccessful()) {
        boolean repeatRequest = handleHttpError(response);
        if (repeatRequest)
            return getResponse(url, client, etag);
        else
            throw new IOException(String.format("Cannot get successful response for url %s", url));
    }
    return response;
}

我假设总是调用

getResponse(url, client).body().string()

流会自动关闭。但是，每当响应不成功时，就会在执行

.string()

之前引发异常，因此流将保持打开状态。

在响应不成功的情况下添加显式关闭解决了问题。

if (!response.isSuccessful()) {
    boolean repeatRequest = handleHttpError(response);
    response.close();
}

Answer 2

正如其他答案中提到的，您必须关闭回复。一个稍微简洁的方法是在 try 块中声明

ResponseBody

，这样它就会自动关闭。

try(ResponseBody body = ....){
....
}

Answer 3

即使成功了，我也需要为我关闭回复。并且 body().string() 没有关闭连接。因此，即使响应是 200 OK，我们也需要明确地关闭连接。

 response = client.newCall(request).execute();
if (HttpStatus.valueOf(response.code()).is2xxSuccessful()) {

    try (ResponseBody body = response.peekBody(Long.MAX_VALUE)) {
      Identifier identifier = objectMapper.readValue(body.string(), Identifier.class);
      response.close();
      return identifier;
    } catch (RuntimeException e) {
      response.close();
      throw new SomeException( .....);
    }
  } else {
    response.close();
    throw new SomeException(...);
  } .....