WebRequests asynchrones utilisant C#

Question

Salut j'ai une fonction qui passe url Obtenir des paramètres à un fichier php sur un serveur web et attend une réponse du fichier (prend normalement 10-20 secondes). Je veux mettre ceci dans une boucle parce que je dois envoyer ces demandes de Get à environ 5 fichiers php différents à la fois mais quand j'essaye de l'ajouter à une boucle, la fonction attend que le fichier retourne la réponse avant que ça ne passe sur le prochain.

public string HttpGet(string URI, string Parameters) 
    { 
     HttpWebRequest request = (HttpWebRequest)WebRequest.Create(URI + Parameters); 

     HttpWebResponse response = (HttpWebResponse)request.GetResponse(); 
     StreamReader resStream = new StreamReader(response.GetResponseStream()); 
      return resStream.ReadToEnd().Trim(); 
    } 

    private void SendCommand() 
    { 
     for(int i = 0; i <= 4; i++) 
     { 
      AddRTB(HttpGet(url, paramater)); 
     } 
    } 

Y at-il un moyen que je puisse envoyer les 5 demandes à la fois sans attendre la fin de la précédente? (Je pensais à l'enfiler, mais hélas je ne l'ai jamais touché auparavant, je ne sais pas par où commencer.)

Answer 1

Au lieu d'utiliser la méthode GetResponse(), vous pouvez utiliser le BeginGetResponse() qui est un appel non bloquant. Il prend un rappel qui peut ensuite gérer l'objet WebResponse quand il revient finalement. L'exemple dans le lien vous donnera une bonne idée de la manière dont le thread principal attendra que toutes les réponses soient renvoyées.

Answer 2

Au lieu de GetResponse, utilisez la méthode BeginGetResonse de la classe de requête. Échantillon et documentation peuvent être trouvés à http://msdn.microsoft.com/en-us/library/system.net.httpwebrequest.begingetresponse.aspx

Answer 3

Utilisez WebClient avec des méthodes asynchrones.

Début \ Fin est plus difficile à utiliser.

Answer 4

Voici deux approches qui utilisent le TPL.

Le premier attend toutes les demandes de compléter avant d'accéder à l'un des résultats

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); 

et le second fait quelque chose avec chaque résultat comme il vient:

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); 
       }); 
}