Как использовать HttpWebRequest (.NET) асинхронно?
-
03-07-2019 - |
Вопрос
Как я могу использовать HttpWebRequest (.NET, C#) асинхронно?
Решение
Использовать HttpWebRequest.BeginGetResponse()
HttpWebRequest webRequest;
void StartWebRequest()
{
webRequest.BeginGetResponse(new AsyncCallback(FinishWebRequest), null);
}
void FinishWebRequest(IAsyncResult result)
{
webRequest.EndGetResponse(result);
}
Функция обратного вызова вызывается после завершения асинхронной операции.Вам нужно хотя бы позвонить EndGetResponse()
из этой функции.
Другие советы
Учитывая ответ:
HttpWebRequest webRequest;
void StartWebRequest()
{
webRequest.BeginGetResponse(new AsyncCallback(FinishWebRequest), null);
}
void FinishWebRequest(IAsyncResult result)
{
webRequest.EndGetResponse(result);
}
Вы можете отправить указатель запроса или любой другой объект следующим образом:
void StartWebRequest()
{
HttpWebRequest webRequest = ...;
webRequest.BeginGetResponse(new AsyncCallback(FinishWebRequest), webRequest);
}
void FinishWebRequest(IAsyncResult result)
{
HttpWebResponse response = (result.AsyncState as HttpWebRequest).EndGetResponse(result) as HttpWebResponse;
}
Привет
До сих пор все ошибались, потому что BeginGetResponse()
выполняет некоторую работу в текущем потоке.Из документация:
Метод BeggeTresponse требует выполнения некоторых задач синхронной настройки (например, разрешение DNS, обнаружение прокси и подключение к сокету TCP), прежде чем этот метод станет асинхронным.В результате этот метод никогда не следует вызывать в потоке пользовательского интерфейса (UI), потому что это может занять значительное время (до нескольких минут в зависимости от настройки сети), чтобы выполнить начальные задачи синхронных настроек, прежде чем будет выброшено исключение для ошибки или Метод добивается успеха.
Итак, чтобы сделать это правильно:
void DoWithResponse(HttpWebRequest request, Action<HttpWebResponse> responseAction)
{
Action wrapperAction = () =>
{
request.BeginGetResponse(new AsyncCallback((iar) =>
{
var response = (HttpWebResponse)((HttpWebRequest)iar.AsyncState).EndGetResponse(iar);
responseAction(response);
}), request);
};
wrapperAction.BeginInvoke(new AsyncCallback((iar) =>
{
var action = (Action)iar.AsyncState;
action.EndInvoke(iar);
}), wrapperAction);
}
Затем вы можете делать с ответом все, что вам нужно.Например:
HttpWebRequest request;
// init your request...then:
DoWithResponse(request, (response) => {
var body = new StreamReader(response.GetResponseStream()).ReadToEnd();
Console.Write(body);
});
Безусловно, самый простой способ — использовать TaskFactory.FromAsync из ВГЗ.Это буквально пара строк кода при использовании вместе с новым асинхронный/ожидание ключевые слова:
var request = WebRequest.Create("http://www.stackoverflow.com");
var response = (HttpWebResponse) await Task.Factory
.FromAsync<WebResponse>(request.BeginGetResponse,
request.EndGetResponse,
null);
Debug.Assert(response.StatusCode == HttpStatusCode.OK);
Если вы не можете использовать компилятор C#5, описанное выше можно выполнить с помощью Task.ContinueWith метод:
Task.Factory.FromAsync<WebResponse>(request.BeginGetResponse,
request.EndGetResponse,
null)
.ContinueWith(task =>
{
var response = (HttpWebResponse) task.Result;
Debug.Assert(response.StatusCode == HttpStatusCode.OK);
});
В итоге я использовал BackgroundWorker, он определенно асинхронен, в отличие от некоторых из вышеперечисленных решений, он обрабатывает возврат в поток графического интерфейса за вас, и его очень легко понять.
Также очень легко обрабатывать исключения, поскольку они попадают в метод RunWorkerCompleted, но обязательно прочтите это: Необработанные исключения в BackgroundWorker
Я использовал WebClient, но, очевидно, вы могли бы использовать HttpWebRequest.GetResponse, если хотите.
var worker = new BackgroundWorker();
worker.DoWork += (sender, args) => {
args.Result = new WebClient().DownloadString(settings.test_url);
};
worker.RunWorkerCompleted += (sender, e) => {
if (e.Error != null) {
connectivityLabel.Text = "Error: " + e.Error.Message;
} else {
connectivityLabel.Text = "Connectivity OK";
Log.d("result:" + e.Result);
}
};
connectivityLabel.Text = "Testing Connectivity";
worker.RunWorkerAsync();
.NET изменилась с тех пор, как были опубликованы многие из этих ответов, и я хотел бы предоставить более актуальный ответ.Используйте асинхронный метод для запуска Task
который будет работать в фоновом потоке:
private async Task<String> MakeRequestAsync(String url)
{
String responseText = await Task.Run(() =>
{
try
{
HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
WebResponse response = request.GetResponse();
Stream responseStream = response.GetResponseStream();
return new StreamReader(responseStream).ReadToEnd();
}
catch (Exception e)
{
Console.WriteLine("Error: " + e.Message);
}
return null;
});
return responseText;
}
Чтобы использовать асинхронный метод:
String response = await MakeRequestAsync("http://example.com/");
Обновлять:
Это решение не работает для приложений UWP, которые используют WebRequest.GetResponseAsync()
вместо WebRequest.GetResponse()
, и он не вызывает Dispose()
методы, где это необходимо.У @dragansr есть хорошее альтернативное решение, решающее эти проблемы.
public void GetResponseAsync (HttpWebRequest request, Action<HttpWebResponse> gotResponse)
{
if (request != null) {
request.BeginGetRequestStream ((r) => {
try { // there's a try/catch here because execution path is different from invokation one, exception here may cause a crash
HttpWebResponse response = request.EndGetResponse (r);
if (gotResponse != null)
gotResponse (response);
} catch (Exception x) {
Console.WriteLine ("Unable to get response for '" + request.RequestUri + "' Err: " + x);
}
}, null);
}
}
public static async Task<byte[]> GetBytesAsync(string url) {
var request = (HttpWebRequest)WebRequest.Create(url);
using (var response = await request.GetResponseAsync())
using (var content = new MemoryStream())
using (var responseStream = response.GetResponseStream()) {
await responseStream.CopyToAsync(content);
return content.ToArray();
}
}
public static async Task<string> GetStringAsync(string url) {
var bytes = await GetBytesAsync(url);
return Encoding.UTF8.GetString(bytes, 0, bytes.Length);
}