WebRequests asíncronas usando C#

Question

Hola tengo una función que pasa url Obtener parámetros a un archivo php en un servidor web y espera una respuesta del archivo (normalmente toma 10-20 segundos). Quiero poner esto dentro de un bucle porque tengo que enviar estas solicitudes Get a aproximadamente 5 archivos php diferentes a la vez, pero cuando intento agregarlo a un bucle, la función hace que el bucle espere hasta que el archivo devuelva la respuesta antes de que vaya. en el siguiente.

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

¿Hay alguna manera de que pueda enviar las 5 solicitudes a la vez sin esperar a que el anterior termine? (Estaba pensando en enhebrarlo pero, por desgracia, nunca lo toqué antes, no sé por dónde empezar)

Answer 1

En lugar de usar el método GetResponse(), puede usar BeginGetResponse() que es una llamada sin bloqueo. Toma una devolución de llamada que luego puede manejar el objeto WebResponse cuando finalmente regresa. El ejemplo en el enlace le dará una buena idea de cómo hacer que el hilo principal espere a que vuelvan todas las respuestas.

Answer 2

En lugar de GetResponse utilice el método BeginGetResonse de la clase de solicitud. Puede encontrar ejemplos y documentación en http://msdn.microsoft.com/en-us/library/system.net.httpwebrequest.begingetresponse.aspx

Answer 3

Use WebClient con métodos Async.

Begin \ End es más difícil de usar.

Answer 4

Aquí hay dos enfoques que utilizan el TPL.

Las primeras espera a que todas las solicitudes para completar antes de acceder a cualquiera de los resultados

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

y el segundo lo hace algo con cada resultado, ya que viene en:

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