Asynchronous WebRequests mit C#

Question

Hallo, ich habe eine Funktion, die URL-Parameter auf eine PHP-Datei auf einem Webserver und wartet auf eine Antwort aus der Datei Get passiert (dauert in der Regel 10 bis 20 Sekunden). Ich möchte dies in eine Schleife einfügen, weil ich diese Get-Anfragen an ungefähr 5 verschiedene php-Dateien gleichzeitig senden muss, aber wenn ich versuche, sie zu einer Schleife hinzuzufügen, lässt die Funktion die Schleife warten, bis die Datei die Antwort zurückgibt weiter zum nächsten.

Gibt es eine Möglichkeit, dass ich alle 5 Anfragen auf einmal senden konnte, ohne auf die vorherige zu warten? (Ich dachte über das Threading, aber ach, ich habe es nie vorher berührt, ich weiß nicht, wo ich anfangen soll.)

Answer 1

Anstelle der GetResponse() Methode könnten Sie die BeginGetResponse() verwenden, die ein nicht blockierender Anruf ist. Es dauert ein Rückruf, der dann das WebResponse Objekt behandeln kann, wenn es schließlich zurückkehrt. Das Beispiel im Link gibt Ihnen eine gute Vorstellung davon, wie der Haupt-Thread auf alle Antworten warten muss.

Answer 2

Statt GetResponse verwenden BeginGetResonse Methode der Anforderungsklasse. Beispiel und Dokumentation finden Sie unter http://msdn.microsoft.com/en-us/library/system.net.httpwebrequest.begingetresponse.aspx

Answer 3

Verwenden Sie WebClient mit Async-Methoden.

Begin \ End ist schwieriger zu verwenden.

Answer 4

Hier sind zwei Ansätze, die die TPL verwendet.

Die erste wartet auf alle Anfragen zu vervollständigen, bevor Sie eines der Ergebnisse zugreifen

var runningTasks = new List<Task<string>>(); 

for (int ii = 0; ii <= 4; ii++) 
{ 
    var wreq = (HttpWebRequest)WebRequest.Create("..." + ii); 

    var taskResp = Task.Factory.FromAsync<WebResponse>(wreq.BeginGetResponse, 
                wreq.EndGetResponse, 
                null); 
    var taskResult = taskResp.ContinueWith(tsk => new StreamReader(tsk.Result.GetResponseStream()).ReadToEnd().Trim()); 
    runningTasks.Add(taskResult); 
} 

Task.WaitAll(runningTasks.ToArray()); 
IEnumerable<string> results = runningTasks.Select(tsk => tsk.Result); 

und die zweite etwas tut, mit jedem Ergebnis, wie es kommt:

for (int ii = 0; ii <= 4; ii++) 
{ 
    var wreq = (HttpWebRequest)WebRequest.Create("..." + ii); 

    var taskResp = Task.Factory.FromAsync<WebResponse>(wreq.BeginGetResponse, 
                wreq.EndGetResponse, 
                null); 
    taskResp.ContinueWith(tsk => new StreamReader(tsk.Result.GetResponseStream()).ReadToEnd().Trim()) 
      .ContinueWith((Task<string> trs) => 
       { 
        var result = trs.Result; 
        DoSomthingWithTheResult(result); 
       }); 
}