Comment fonctionne HttpAsyncClient 4?

Question

Dans les versions précédentes de HttpClient, l'hôte cible était configuré dans le client lui-même. Dans la dernière version (pour HttpAsyncClient c'est 4.1.1) l'hôte est mis en place dans HttpRequest (HttpGet, HttpPost etc.) chaque fois que je fais une demande.

Je souhaite utiliser une connexion persistante, donc j'utilise HttpAsyncClient. Créer et utiliser comme ceci:

CloseableHttpAsyncClient client = HttpAsyncClients.createDefault(); 
client.start(); 
List<Future<HttpResponse>> responses = new ArrayList<>(); 
for (int i = 0; i < 10; i++) 
{ 
    HttpGet get = new HttpGet("https://google.com/"); 
    responses.add(client.execute(get, null)); 
} 
for (Future<HttpResponse> response : responses) { 
    response.get(); //wait for the response 
} 

Comme je l'ai testé, il fonctionne plus vite que d'habitude HttpClient (si je fais toutes les demandes, puis attendre toutes les réponses).

Mais je ne peux pas entièrement comprendre, comment cela fonctionne à l'intérieur. Combien de connexions avec https://google.com/ sont établies? Que se passe-t-il si j'utilise client pour un hôte, puis pour un autre? (comme je l'ai testé, les réponses peuvent venir dans n'importe quel ordre, donc je suppose qu'il y a au moins 2 connexions en parallèle). Quelle est la différence entre HttpAsyncClients.createDefault() et HttpAsyncClients.createPipelining()?

Merci!

Answer 1

Par défaut, HttpAsyncClient autorise uniquement deux connexions simultanées au même hôte par spécification RFC 2616. Cette limite n'a rien à voir avec le nombre de threads d'envoi d'e/s utilisés en interne par le réacteur d'E/S.

Le code ci-dessus va créer au plus deux connexions sortantes.

Le traitement en pipeline de messages HTTP n'a rien à voir avec la persistance de connexion en soi, bien que l'exécution de requêtes en pipeline implique l'utilisation de connexions persistantes.

Le pipelinage HTTP concerne le séquençage des messages. HttpAsyncClient en mode Pipeline peut envoyer plusieurs demandes sans attendre chaque réponse.

Mode par défaut:

C -> request1 -> S 
C <- response1 <- S 
C -> request2 -> S 
C <- response2 <- S 

mode Pipelining:

C -> request1 -> S 
C -> request2 -> S 
C <- response1 <- S 
C <- response2 <- S