为什么OkHttp不重用其连接？

Question

我正在使用OkHttp 3.5.0执行超文本传输协议-基准测试。我正在向同一个URL发送数千个请求。

我期望OkHttp-client使用ConnectionPool并一遍又一遍地重用它的连接。但是如果我们研究netstat，我们会看到许多连接处于TIME_WAIT状态：

TCP    127.0.0.1:80           127.0.0.1:51752        TIME_WAIT
TCP    127.0.0.1:80           127.0.0.1:51753        TIME_WAIT
TCP    127.0.0.1:80           127.0.0.1:51754        TIME_WAIT
TCP    127.0.0.1:80           127.0.0.1:51755        TIME_WAIT
TCP    127.0.0.1:80           127.0.0.1:51756        TIME_WAIT
...

在数千个请求之后，我得到了一个SocketException：没有可用的缓冲区空间（达到最大连接数？）

代码预执行请求（Kotlin）：

val client = OkHttpClient.Builder()
        .connectionPool(ConnectionPool(5, 1, TimeUnit.MINUTES))
        .build()

val request = Request.Builder().url("http://192.168.0.50").build()

while (true) {
    val response = client.newCall(request).execute()
    response.close()
}

而不是响应。close（）我使用响应。body（）。string（），则不会发生SocketException，但netstat仍显示大量等待连接的时间，并且基准性能越来越低。

我哪里做错了？

PS：我尝试过使用ApacheHttpClient及其PoolighttpClientConnectionManager，看起来它工作得很好。但我想找出OkHttp的问题所在。




Answer 1

感谢toien和我找到了我的解决方案（对于非标准超文本传输协议服务器）。

public class Http1CodecWrapper implements HttpCodec {
    private HttpCodec codec;

    public Http1CodecWrapper(HttpCodec codec) {
        this.codec = codec;
    }

    // ...

    @Override
    public Response.Builder readResponseHeaders(boolean expectContinue) throws IOException {
        return codec.readResponseHeaders(expectContinue)
            .addHeader("Connection", "keep-alive");
    }
}

OkHttpClient httpClient = new OkHttpClient.Builder()
    .addNetworkInterceptor(new Interceptor() {
            @Override
            public Response intercept(Chain chain) throws IOException {
                RealInterceptorChain realChain = (RealInterceptorChain) chain;
                Request request = realChain.request();
                StreamAllocation allocation = realChain.streamAllocation();
                HttpCodec codec = new Http1CodecWrapper(realChain.httpStream());
                RealConnection connection = (RealConnection) realChain.connection();

                return realChain.proceed(request, allocation, codec, connection);
            }
        })
    .build();

Answer 2

我的版本是3.13.0，离3.5.0不远，我也遇到了时间等待问题。

在深入研究源代码之后，我在CallServerInterceptor中找到了。java第142行：

if ("close".equalsIgnoreCase(response.request().header("Connection"))
    || "close".equalsIgnoreCase(response.header("Connection"))) {
   streamAllocation.noNewStreams();
}

在流量分配方面。java第367行：

public void noNewStreams() {
    Socket socket;
    Connection releasedConnection;
    synchronized (connectionPool) {
      releasedConnection = connection;
      socket = deallocate(true, false, false); // close connection!
      if (connection != null) releasedConnection = null;
    }
    closeQuietly(socket);
    if (releasedConnection != null) {
      eventListener.connectionReleased(call, releasedConnection);
    }
}

这意味着，如果请求或响应中存在“connection:CLOSE”头，okhttp将关闭连接

虽然问题提交已经很久了，但我希望这个答案能帮助遇到这个问题的人，祝你们好运。