我正在调试我的 Android 应用程序中的一个问题。我发现根本原因是文件描述符超出了限制。经过进一步调查，我发现该应用程序打开了太多套接字。我将 OkHttpClient 2.5 用于我所有的网络通信，因此我想知道我应该如何限制我的连接池大小。下面是我的代码 fragment :

    OkHttpClient okHttpClient = new OkHttpClient().setConnectTimeout(TIMEOUT);
    ConnectionPool connectionPool = new ConnectionPool(MAX_IDLE_CONNECTIONS,
                                                       KEEP_ALIVE_DURATION_MS);
    okHttpClient.set(connectionPool);

    @RequireArgsConstructor
    public HttpEngineCallable implements Callable<IHttpResponse>
    {
      private final String url;

      public IHttpResponse call () throws Exception 
      {
         try
        {
           Request request = Request.Builder().url(url).build();
           Call call = okHttpClient.newCall(request);
           Response rawResponse = call.execute();
           return new OkHttpResponse(rawResponse);
        }
        catch (Exception e)
        {
           throw new IllegalStateException(e);
        }
    }  

    private final Function<IHttpResponse, T> httpResponseParser = new Function<IHttpResponse, T>()
    {
        @Nullable
        @Override
        public T apply(@Nullable IHttpResponse httpResponse)
        {
            if(httpResponse == null)
            {
               return null;
            }

            InputStream stream = httpResponse.getBody();
            JsonParser parser = null;
            T result = null;

            try
            {
               parser = jsonFactory.createParser(stream);
               result = strategy.parseData(parser);
            }
            catch (Exception e)
            {
               log.error("Unable to convert {} with {}.", stream, strategy, e);
            }
            finally
            {
               IOUtils.closeQuietly(parser);
               IOUtils.closeQuietly(stream);
            } 

          return result;
        }
     };

     Future<T> future = executorService.submit(new HttpEngineCallable(url));
     Future<V> finalFuture = Futures.transform(future, httpResponseParser, executorService);

     T result = timeoutExecutorService.submit(new Runnable() 
     {
        try
        { 
          T result = finalFuture.get(CLIENT_TIMEOUT, TIMEUNIT)
          if (result == null)
          { 
            notify onFailure listeners
          }
          else
          {
            notify onSuccess Listeners
          }
        }
        catch(Exception ex)
        {
          notify onFailure listeners
        }
     } 

所以我对这个实现有几个问题:

1. 我的 CLIENT_TIMEOUT 比 OkHttp ConnectTimeout 短。如果我的 finalFuture.get(CLINT_TIMEOUT, TIMEUNIT) 抛出超时异常，我在 Parser Function 中的 finally block 还会被执行吗？我指望它关闭我的连接。
2. 如何限制我的 ConnectionPool 的大小？如果连接超出限制，我有没有办法自动回收最旧的连接？

最佳答案

我们遇到了类似的问题，打开的文件描述符太多导致我们的应用程序崩溃。

问题是我们为每个请求创建了一个 OkHttpClient。默认情况下，每个 OkHttpClient 都带有它自己的连接池，这当然会增加连接/线程/文件句柄的数量，并阻止在池中正确重用。

我们通过在单例中手动创建一个global ConnectionPool 解决了这个问题，然后将其传递给构建实际 OkHttpClient 的 OkHttpClient.Builder 对象。

...
builder.connectionPool(GLOBAL_CONNECTION_POOL);
OkHttpClient client = builder.build();
...

这仍然允许使用 OkHttpClient.Builder 进行每个请求的配置，并确保所有 OkHttpClient 实例仍在使用公共(public)连接池。 然后，我们能够正确调整全局连接池的大小。

关于java - 如何控制 okHttpClient 的连接大小？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35807965/