Apache HttpClient 4.3 nicht honor keep alive

Question

Auf der nGinx-Server-Seite ist Connection-keep alive für Clients für bis zu 30 Sekunden festgelegt. Aber mit diesem Code und den angehängten Logs, HttpClient 4.3. honor nicht am Leben und schließt die Verbindung nach jeder Anfrage. Warum passiert dies?

Ich komme zu dieser Schlussfolgerung nach dem Versuch, Netstat -an wiederholt und herauszufinden, dass der Client verschiedene Ports zu verschiedenen Zeiten während der For-Schleife Ausführung und FIN Staaten alle 2 Sekunden.

Die Protokolle unten auch gegeben zeigen, dass die Verbindung nach everyrequest

geschlossen ist

static ConnectionKeepAliveStrategy myStrategy = new ConnectionKeepAliveStrategy() { 
    public long getKeepAliveDuration(HttpResponse response, HttpContext context) { 
      return 30 * 1000; 
    } 
}; 

public static void main(String[] args) throws Exception { 

    java.util.logging.Logger.getLogger("org.apache.http.wire").setLevel(java.util.logging.Level.FINER); 
    java.util.logging.Logger.getLogger("org.apache.http.headers").setLevel(java.util.logging.Level.FINER); 

    System.setProperty("org.apache.commons.logging.Log", "org.apache.commons.logging.impl.SimpleLog"); 
    System.setProperty("org.apache.commons.logging.simplelog.showdatetime", "true"); 
    System.setProperty("org.apache.commons.logging.simplelog.log.httpclient.wire", "debug"); 
    System.setProperty("org.apache.commons.logging.simplelog.log.org.apache.http", "debug"); 
    System.setProperty("org.apache.commons.logging.simplelog.log.org.apache.http.headers", "debug"); 

    callServer(); 
} 

public static void callServer() throws Exception { 

    KeyStore keyStore = KeyStore.getInstance("pkcs12"); 

    FileInputStream instream = new FileInputStream(new File("/engineering/workspace/nginx_pilot/keystores/clientkeystore.pkcs")); 
    try { 
     keyStore.load(instream, "****".toCharArray()); 
    } finally { 
     instream.close(); 
    } 

    KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType()); 

    instream = new FileInputStream(new File("/engineering/workspace/nginx_pilot/keystores/serverKeystore.jks")); 
    try { 
     trustStore.load(instream, "****".toCharArray()); 
    } finally { 
     instream.close(); 
    } 

    SSLContext sslContext = SSLContexts.custom().loadKeyMaterial(keyStore, "pass".toCharArray()).loadTrustMaterial(trustStore).build(); 
    SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext, SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); 

    CloseableHttpClient httpclient = HttpClients.custom().setSSLSocketFactory(sslsf).setConnectionReuseStrategy(DefaultConnectionReuseStrategy.INSTANCE).build(); 

    CloseableHttpResponse response = null; 

    try { 
     HttpGet httpget = new HttpGet("https://" + getString() + ":8443/GenevaServers/GetConfig/unit.test.asset.ast1"); 

     System.out.println("executing request" + httpget.getRequestLine()); 

     for (int i = 0; i < 10000; i++) { 
      System.out.println("Beginning"); 
      long currentTimeMillis = System.currentTimeMillis(); 
      response = httpclient.execute(httpget); 
      System.out.println((System.currentTimeMillis() - currentTimeMillis) + "ms"); 
      HttpEntity entity = response.getEntity(); 
      System.out.println(IOUtils.toString(entity.getContent())); 
      EntityUtils.consume(entity); 
      System.out.println("End"); 
     } 
    } catch (Exception e) { 
     e.printStackTrace(); 
    }finally { 
     response.close(); 
     httpclient.close(); 
    } 
} 

Das sind die Protokolle sind.

2014/01/22 19:24:50:252 PST [DEBUG] RequestAddCookies - CookieSpec selected: best-match 
2014/01/22 19:24:50:252 PST [DEBUG] RequestAuthCache - Auth cache not set in the context 
2014/01/22 19:24:50:252 PST [DEBUG] PoolingHttpClientConnectionManager - Connection  request: [route: {s}->https://ichor.corp.com:8443][total kept alive: 2; route allocated: 2 of 2; total allocated: 2 of 20] 
2014/01/22 19:24:50:253 PST [DEBUG] DefaultManagedHttpClientConnection - http-outgoing-0: Close connection 
2014/01/22 19:24:50:254 PST [DEBUG] PoolingHttpClientConnectionManager - Connection leased: [id: 2][route: {s}->https://ichor.corp.com:8443][total kept alive: 1; route allocated: 2 of 2; total allocated: 2 of 20] 
2014/01/22 19:24:50:254 PST [DEBUG] MainClientExec - Opening connection {s}- >https://ichor.corp.com:8443 
2014/01/22 19:24:50:254 PST [DEBUG] HttpClientConnectionManager - Connecting to ichor.corp.com/17.169.1.18:8443 
2014/01/22 19:24:50:392 PST [DEBUG] MainClientExec - Executing request GET /GenevaServers/GetConfig/unit.test.asset.ast1 HTTP/1.1 
2014/01/22 19:24:50:392 PST [DEBUG] MainClientExec - Target auth state: UNCHALLENGED 
2014/01/22 19:24:50:392 PST [DEBUG] MainClientExec - Proxy auth state: UNCHALLENGED 
2014/01/22 19:24:50:392 PST [DEBUG] headers - http-outgoing-2 >> GET /GenevaServers/GetConfig/unit.test.asset.ast1 HTTP/1.1 
2014/01/22 19:24:50:392 PST [DEBUG] headers - http-outgoing-2 >> Host: ichor.corp.com:8443 
2014/01/22 19:24:50:392 PST [DEBUG] headers - http-outgoing-2 >> Connection: Keep-Alive 
2014/01/22 19:24:50:392 PST [DEBUG] headers - http-outgoing-2 >> User-Agent: Apache- HttpClient/4.3.1 (java 1.5) 
2014/01/22 19:24:50:392 PST [DEBUG] headers - http-outgoing-2 >> Accept-Encoding: gzip,deflate 
2014/01/22 19:24:50:392 PST [DEBUG] wire - http-outgoing-2 >> "GET /GenevaServers/GetConfig/unit.test.asset.ast1 HTTP/1.1[\r][\n]" 
2014/01/22 19:24:50:392 PST [DEBUG] wire - http-outgoing-2 >> "Host: ichor.corp.com:8443[\r][\n]" 
2014/01/22 19:24:50:392 PST [DEBUG] wire - http-outgoing-2 >> "Connection: Keep-Alive[\r][\n]" 
2014/01/22 19:24:50:392 PST [DEBUG] wire - http-outgoing-2 >> "User-Agent: Apache-HttpClient/4.3.1 (java 1.5)[\r][\n]" 
2014/01/22 19:24:50:392 PST [DEBUG] wire - http-outgoing-2 >> "Accept-Encoding: gzip,deflate[\r][\n]" 
2014/01/22 19:24:50:393 PST [DEBUG] wire - http-outgoing-2 >> "[\r][\n]" 
2014/01/22 19:24:50:462 PST [DEBUG] wire - http-outgoing-2 << "HTTP/1.1 200 OK[\r][\n]" 
2014/01/22 19:24:50:462 PST [DEBUG] wire - http-outgoing-2 << "Server: nginx/1.4.1[\r][\n]" 
2014/01/22 19:24:50:463 PST [DEBUG] wire - http-outgoing-2 << "Date: Thu, 23 Jan 2014 03:24:09 GMT[\r][\n]" 
2014/01/22 19:24:50:463 PST [DEBUG] wire - http-outgoing-2 << "Content-Type: application/json[\r][\n]" 
2014/01/22 19:24:50:463 PST [DEBUG] wire - http-outgoing-2 << "Content-Length: 270[\r][\n]" 
2014/01/22 19:24:50:463 PST [DEBUG] wire - http-outgoing-2 << "Connection: keep-alive[\r][\n]" 
2014/01/22 19:24:50:463 PST [DEBUG] wire - http-outgoing-2 << "[\r][\n]" 

Jeder Rat wäre eine große Hilfe. Vielen Dank im Voraus.

Answer 1

Es sicherlich nicht, aber dies ist ein Sonderfall

SSLContext sslContext = SSLContexts.custom().loadKeyMaterial(keyStore, "pass".toCharArray()).loadTrustMaterial(trustStore).build(); 
SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext, SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); 

Sie SSL-Schlüssel verwenden, um mit dem Zielserver zu authentifizieren. Dadurch stellt die Verbindung einen bestimmten Benutzer dar und enthält einen bestimmten Sicherheitskontext. Mit anderen Worten, die Verbindung hat einen bestimmten Status (Benutzerprinzipal). Höchstwahrscheinlich möchten Sie nicht, dass diese Verbindung an einen beliebigen Ausführungsthread vermietet wird, der möglicherweise einen völlig anderen Benutzer darstellt, oder? HttpClient 4 (im Gegensatz zu seinen Vorgängern) verfolgt zustandsbehaftete Verbindungen und stellt sicher, dass sie nicht von Threads mit einem anderen Ausführungskontext wiederverwendet werden können.

Es gibt mehrere Möglichkeiten, wie Sie das Problem lösen können

1. empfohlen. Machen Sie alle logisch zusammenhängenden Anfragen, die

2. manuell manage connection state

3. Disable Verbindungszustand Tracking same execution context teilen. Diese Maßnahme hat Sicherheitsrückwirkungen, so dass sie sorgfältig berücksichtigt werden muss.