.NET HttpClient多線程

Question

我在多線程中使用HttpClient時遇到了一些麻煩。

如果我同時推出很多下載，每個線程的第一下載速度很慢（與並行線程增加）

舉例來說，如果我有一個線程，一切都很好

First download Elapsed Time Download: 197 ms 
Second download Elapsed Time Download: 171 ms 

但有一個線程，下載時間增加

First download Elapsed Time Download: 3881 ms 
... 
Second download Elapsed Time Download: 96 ms 
... 

網絡帶寬是不是一個問題，我有同樣的問題localhost。

下面是一些代碼來重現問題：

static void Main(string[] args) 
{ 
    ServicePointManager.DefaultConnectionLimit = 200; 
    List<Task> tasks = new List<Task>(); 
    for (var i = 0; i < 10; i++) 
    { 
     tasks.Add(
      Task.Factory.StartNew(() => 
      { 
       Stopwatch s = Stopwatch.StartNew(); 
       HttpClient httpClient = new HttpClient(); 
       HttpResponseMessage httpDownloadResponse = httpDownloadResponse = httpClient.GetAsync("http://www.google.fr/", HttpCompletionOption.ResponseHeadersRead).Result; 
       s.Stop(); 
       Console.WriteLine("First download Elapsed Time Download: {0} ms", s.ElapsedMilliseconds); 

       s = Stopwatch.StartNew(); 
       httpClient = new HttpClient(); 
       httpDownloadResponse = httpClient.GetAsync("http://www.google.fr/", HttpCompletionOption.ResponseHeadersRead).Result; 
       s.Stop(); 
       Console.WriteLine("Second download Elapsed Time Download: {0} ms", s.ElapsedMilliseconds); 
      }) 
     ); 
    } 
    Task.WaitAll(tasks.ToArray()); 
    while (Console.ReadLine() != null) ; 
} 

Answer 1

我實際上並不能在我的機器上重現您的問題。無論我做什麼，第一個請求總是需要大約相同的時間，第二個請求更快。

我最好的猜測是你正在用盡線程池。每次您撥打Task.Factory.StartNew時，它都會啓動一個新的Task，它將採用新的線程池線程。然後您撥打HttpClient.GetAsync，在另一個線程上啓動另一個Task並阻止第一個線程。所以你爲每個請求佔用兩個線程。如果你足夠的話，你將使用線程池中的所有線程，並且請求將開始排隊。線程池將添加更多的線程，但速度很慢 - 通常每0.5秒一個新線程。所以這可能是其中的一部分。

此外，您正在使用HttpClient錯誤。每個HttpClient實例都擁有一個連接池，因此您通常需要創建一個實例並重用它。這裏有一些更乾淨的代碼 - 試試看看它是否能解決你的問題。

public static void Main() 
{ 
    ServicePointManager.DefaultConnectionLimit = 200; 
    List<Task> tasks = new List<Task>(); 
    using (var client = new HttpClient()) 
    { 
     for (var i = 0; i < 10; i++) 
     { 
      tasks.Add(DoRequest(i, client)); 
     } 

     Task.WaitAll(tasks.ToArray()); 
    } 
} 

private async Task DoRequest(int id, HttpClient client) 
{ 
    const string url = "http://www.google.fr/"; 
    Stopwatch s = Stopwatch.StartNew(); 
    HttpResponseMessage httpDownloadResponse = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead); 
    s.Stop(); 
    Console.WriteLine("Task {1} - First download Elapsed Time Download: {0} ms", s.ElapsedMilliseconds, id); 

    s = Stopwatch.StartNew(); 
    httpDownloadResponse = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead); 
    s.Stop(); 
    Console.WriteLine("Task {1} - Second download Elapsed Time Download: {0} ms", s.ElapsedMilliseconds, id); 

}