Проблема выполнения асинхронного веб-запроса - PullRequest
Новая
       6

Проблема выполнения асинхронного веб-запроса

2 голосов
/ 26 марта 2010

Может кто-нибудь сказать мне, что я сделал не так с этим простым кодом? Когда я запускаю его, он зависает на 

using (Stream postStream = request.EndGetRequestStream(asynchronousResult))

Если я закомментирую requestState.Wait.WaitOne (); строка кода выполняется правильно, но, очевидно, не ждет ответа. Я предполагаю, что вызов EndGetRequestStream каким-то образом возвращает меня в контекст основного потока ?? Я уверен, что мой код по сути такой же, как в примере ( Документация MSDN ) 

using System;
using System.Net;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Documents;
using System.Windows.Ink;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Animation;
using System.Windows.Shapes;
using System.IO;
using System.Text;

namespace SBRemoteClient
{
    public class JSONClient
    {

        public string ExecuteJSONQuery(string url, string query)
        {
            System.Uri uri = new Uri(url);
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(uri);
            request.Method = "POST";
            request.Accept = "application/json";
            byte[] requestBytes = Encoding.UTF8.GetBytes(query);
            RequestState requestState = new RequestState(request, requestBytes);
            IAsyncResult resultRequest = request.BeginGetRequestStream(new AsyncCallback(GetRequestStreamCallback), requestState);
            requestState.Wait.WaitOne();
            IAsyncResult resultResponse = (IAsyncResult)request.BeginGetResponse(new AsyncCallback(GetResponseStreamCallback), requestState);
            requestState.Wait.WaitOne();

            return requestState.Response;
        }

        private static void GetRequestStreamCallback(IAsyncResult asynchronousResult)
        {
            try
            {
                RequestState requestState = (RequestState)asynchronousResult.AsyncState;
                HttpWebRequest request = requestState.Request;
                using (Stream postStream = request.EndGetRequestStream(asynchronousResult))
                {
                    postStream.Write(requestState.RequestBytes, 0, requestState.RequestBytes.Length);
                }
                requestState.Wait.Set();
            }
            catch (Exception e) {
                Console.Out.WriteLine(e);
            }
        }

        private static void GetResponseStreamCallback(IAsyncResult asynchronousResult)
        {
            RequestState requestState = (RequestState)asynchronousResult.AsyncState;
            HttpWebRequest request = requestState.Request;
            using (HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(asynchronousResult))
            {
                using (Stream responseStream = response.GetResponseStream())
                {
                    using (StreamReader streamRead = new StreamReader(responseStream))
                    {
                        requestState.Response = streamRead.ReadToEnd();
                        requestState.Wait.Set();
                    }
                }
            }
        }
    }
}

1 Ответ

1 голос
/ 28 марта 2010

пара вещей:

  1. Я не думаю, что вы можете повторно использовать один и тот же объект запроса. то есть вы можете вызывать BeginGetRequestStream один раз для каждого экземпляра HttpWebRequest. если вы хотите выполнить два запроса (обращения к серверу), вам нужно два экземпляра HttpWebRequest, по одному на запрос.

  2. если вы хотите синхронного поведения, у вас есть два варианта: использовать метод GetRespose или используйте начало / конец синхронно. для этого вам не нужно передавать обратный вызов методу BeginGetRequestStream (вместо этого вы можете передать ноль). возьмите возвращенное значение из BeginGetRequestStream (IAsyncResult) и передайте его методу EndGetRequestStream: 

    AsyncResult resultRequest = request.BeginGetRequestStream(null, null);
Stream postStream = request.EndGetRequestStream(asynchronousResult)

EndGetRequestStream будет блокироваться до тех пор, пока запрос не будет завершен (это плохо, если вы делаете это из пользовательского интерфейса, но он все равно будет работать).

...