缺少[FIN，ACK]和连接重置

Question

我试图使用Apache的Java async HTTP客户端库开发对HTTP请求的代理链接支持。这主要是通过提供一些自定义的SchemeIOSessionStrategy类来完成的。我发现在配置多个代理时，[FIN，ACK]序列和丢失连接重置存在一些问题。

如果没有配置代理，正在开发的代码将独占地使用Apache库。如果配置了多个代理，则自定义SchemeIOSessionStrategy类提供连接到代理的安装程序。

若要通过代理进行连接，代码将打开到第一个代理服务器的连接，然后发出连接请求。如果代理服务器是链中的最后一个，它将连接到目标服务器，否则它将连接到链中的下一个代理服务器。所有设置完成后，将使用Apache库发送HTTP请求。

对于只有一个代理的配置，适用以下内容：客户机-->代理1-->HTTP服务器

有两个代理服务器：客户端-->代理1-->代理2-->HTTP服务器

目标是尽可能重用连接。当转到特定的HTTP服务器时，服务器会在空闲一段时间后关闭连接。如果使用相同的连接执行请求，代码将经历重新连接过程。

目前正在HTTP代理上进行测试，到代理的连接如下所示：

    HttpRequest request = null;

    String uri = _proxyHost.getTargetHost().getHostName() + ":" + _proxyHost.getTargetHost().getPort();
    ProtocolVersion protocolVersion = new ProtocolVersion("HTTP", 1, 0);
    request = new BasicHttpRequest("CONNECT", uri, protocolVersion);

    if ((_proxyHost.getPrincipal() != null) && !_proxyHost.getPrincipal().isEmpty()) {
        StringBuilder builder = new StringBuilder(_proxyHost.getPrincipal());

        if ((_proxyHost.getCredentials() != null) && !_proxyHost.getCredentials().isEmpty()) {
            builder.append(":");
            builder.append(_proxyHost.getCredentials());
        }

        String encodedAuthString = DatatypeConverter.printBase64Binary(builder.toString().getBytes("UTF-8"));
        request.addHeader("Proxy-Authorization", "Basic " + encodedAuthString);
    }

    request.addHeader("Pragma", "No-Cache");
    request.addHeader("Proxy-Connection", "Keep-Alive");
    request.addHeader("Connection", "Keep-Alive");

要写入连接请求：

    StringBuilder builder = new StringBuilder();
    RequestLine requestLine = request.getRequestLine();

    builder.append(requestLine.getMethod());
    builder.append(" ");
    builder.append(requestLine.getUri());
    builder.append(" ");
    builder.append(requestLine.getProtocolVersion().toString());
    builder.append(CRLF);

    for (Header header : request.getAllHeaders()) {
        builder.append(header.toString());
        builder.append(CRLF);
    }

    builder.append(CRLF);

    ByteBuffer byteBuffer = ByteBuffer.wrap(builder.toString().getBytes());
    ioSession.channel().write(byteBuffer);

使用iosession.channel().read（）准备好响应。ioSession是org.apache.http.nio.reactor.ioSession对象。

        HttpAsyncClientBuilder builder = HttpAsyncClients.custom().setRedirectStrategy(new LaxRedirectStrategy());
        ConnectingIOReactor ioReactor = IOReactorFactory.getInstance().createConnectingReactor();
        Registry<SchemeIOSessionStrategy> registry = generateRegistry(config);

        builder.setConnectionManager(new PoolingNHttpClientConnectionManager(ioReactor, registry));

        if (config.getProxy() != null) {
            proxyHost = new ProxyHost(config.getProxy());
            builder.setProxy(proxyHost);
        }

        CloseableHttpAsyncClient client = builder.build();
        client.start();

    RequestConfig.Builder configBuilder = RequestConfig.custom();
    configBuilder.setRedirectsEnabled(true);
    requestBuilder.setConfig(configBuilder.build());

    client.execute(requestBuilder.build(), context, handler);

客户端将挂起以下堆栈跟踪：

线程15996：(state=IN_NATIVE)-sun.nio.ch.fileDispatcherimpl.read0(java.io.fileDescriptor,long,int)@bci=0（编译帧；信息可能不精确）-sun.nio.ch.socketDispatcher.read(java.io.fileDescriptor,long,int)@bci=4（编译帧）-sun.nio.ch.socketDispatcher.read(java.io.fileDescriptor,long,int)@bci=4（编译帧）long,sun.nio.ch.nativeDispatcher)@bci=48（编译帧）-sun.nio.ch.socketchannelimpl.read(java.nio.bytebuffer)@bci=234（编译帧）-com...io.proxy.impl.passthroughchannel.read(java.nio.bytebuffer)-com...io.proxy.impl.passthroughchannel.read(java.nio.bytechannel)@bci=28,line=42（编译帧）PutBufferImpl.Fill(java.nio.channels.ReadableByteChannel)@bci=30,line=164（编译帧）-org.apache.http.impl.nio.codecs.abstractMessageParser.fillBuffer(java.nio.channels.readableByteChannel)@bci=5,line=136（编译帧）-org.apache.http.impl.nio.defaultNHttpClientConnection.consumeInput(org.apache.http.nio.nHttpClientEventHandler)@bci=38,line=241（编译帧）编译帧）-org.apache.http.impl.nio.client.internaliodispatch.oninputready(java.lang.object)@bci=5,line=37（编译帧）-org.apache.http.impl.nio.reactor.abstractiodispatch.inputtready(org.apache.http.nio.reactor.abstractiodispatch.inputtready(org.apache.http.nio.reactor.iosession)@bci=32,line=113（编译帧）ProcessEvent(java.nio.channels.selectionKey)@bci=45,line=338（编译帧）-org.apache.http.impl。processEvents(java.util.set)@bci=28,line=316（编译帧）-org.apache.http.impl.nio.reactor.abstractionoreactor.execute()@bci=80,line=277（编译帧）-org.apache.http.impl.nio.reactor.baseioreactor.execute(org.apache.http.nio.reactor.ioeventdispatch)@bci=13,line=105（解释帧）-org.apache.http.nio.reactor.abstrated run()@bci=11（已解释帧）

Answer 1

我的第一个问题是为什么客户机不向Proxy1发送结束[FIN，ACK]？我找不到任何挂起的写入或其他可以找到的数据。

如果客户端从对等端接收到fin，但还没有发送，则客户端端口将处于close-wait状态，等待客户端本地应用程序关闭其套接字。客户机可能仍在尝试连接池，下次使用该连接时将发现关闭。

为什么链中不同数量的代理不同，这是一个谜，除非它以某种方式影响连接:头。也许Apache库会发送一个？