WebRequals không đồng bộ sử dụng C#

Question

Xin chào, tôi có một chức năng chuyển url Nhận tham số cho tệp php trên máy chủ web và chờ phản hồi từ tệp (thường mất 10-20 giây). Tôi muốn đặt điều này bên trong một vòng lặp vì tôi phải gửi các yêu cầu này đến khoảng 5 tệp php khác nhau cùng một lúc nhưng khi tôi cố gắng thêm nó vào vòng lặp, hàm làm cho vòng lặp chờ cho đến khi tệp trả về phản hồi trước khi nó đi Ngày kế tiếp.

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

Có cách nào để tôi có thể gửi tất cả 5 yêu cầu cùng một lúc mà không phải chờ kết thúc trước? (Tôi đã nghĩ về việc đọc nó nhưng tôi chưa bao giờ chạm vào nó trước đây là tôi không biết bắt đầu từ đâu.)

Answer 1

Thay vì sử dụng phương pháp GetResponse() bạn có thể sử dụng số BeginGetResponse(). Phải mất một cuộc gọi lại mà sau đó có thể xử lý các đối tượng WebResponse khi nó cuối cùng trở về. Ví dụ trong liên kết sẽ cung cấp cho bạn ý tưởng tốt về cách yêu cầu chủ đề chính chờ tất cả các phản hồi trả về.

Answer 2

Thay vì GetResponse sử dụng phương thức lớp yêu cầu BeginGetResonse. Mẫu và tài liệu có thể được tìm thấy tại http://msdn.microsoft.com/en-us/library/system.net.httpwebrequest.begingetresponse.aspx

Answer 3

Sử dụng WebClient bằng phương pháp Không đồng bộ.

Bắt đầu \ Kết thúc khó sử dụng hơn.

Answer 4

Dưới đây là hai cách tiếp cận sử dụng TPL.

Các chờ đợi đầu tiên cho tất cả các yêu cầu để hoàn thành trước khi bạn truy cập vào bất kỳ kết quả

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

và lần thứ hai làm điều gì đó với mỗi kết quả vì nó đi kèm trong:

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