HTTP POST Reactive Extention асинхронный.ошибки обработки шаблона - PullRequest
Новая
       17

HTTP POST Reactive Extention асинхронный.ошибки обработки шаблона

1 голос
/ 01 ноября 2011

Я пытаюсь использовать следующий код, но он не работает, когда возникает исключение. Кто-нибудь может мне помочь в этом? я пытаюсь бросить веб-исключение в fetchresponse (). catch (). возможно ли вернуть разный тип данных в ответ (больше, чем просто строка). 

IObservable<string> tempReturnData = null;
        try
        {
            // create http web request
            HttpWebRequest WSrequest = (HttpWebRequest)WebRequest.Create(WebURL);
            // instantiate Request class object
            RequestState rs = new RequestState();
            rs.Request = WSrequest;
            // Lock current webrequest object.. incase of retry attempt 
            lock (WSrequest)
            {
                rs.Request.ContentType = "application/x-www-form-urlencoded";
                rs.Request.Method = "POST";
                rs.Request.Timeout = 100;
                // bug in .net that closes the connection prior to it being finished 
                rs.Request.KeepAlive = false;
                rs.Request.ProtocolVersion = HttpVersion.Version10;
                // async pattern get request
                var fetchRequestStream = Observable.FromAsyncPattern<Stream>(rs.Request.BeginGetRequestStream, rs.Request.EndGetRequestStream);
                // async pattern get response
                var fetchResponse = Observable.FromAsyncPattern<WebResponse>(rs.Request.BeginGetResponse, rs.Request.EndGetResponse);
                // 
                tempReturnData = (from tempResult in fetchRequestStream() select tempResult).SelectMany(stream =>
                    {
                        using (var writer = new StreamWriter(stream)) writer.Write(postData);
                        // here i wants to catch web exception in fetchResponse()   FYI : in my function i am returning IObservable<string>
                        return fetchResponse().Catch(Observable.Empty<WebResponse>()).Retry(5);
                    }).Select(result =>
                    {
                        lock (rs)
                        {
                            rs.Response = (HttpWebResponse)result;

                            string s = "";
                            // if response is ok then read response stream data
                            if (rs.Response.StatusCode == HttpStatusCode.OK)
                            {
                                using (StreamReader reader = new StreamReader(rs.Response.GetResponseStream())) s = reader.ReadToEnd();
                            }
                            // Error case if error occurs then try after random time period
                            else
                            {
                                if (Attempt < appConfig.PSPRequestAttempt)
                                {
                                    Attempt++;
                                    RandomisePost(WebURL, postData, Attempt);
                                }
                            }
                            return s;
                        }
                    }); // get response stream data
                return tempReturnData;
            }
        }
        catch (Exception ex)
        {
            // Debug.WriteLine("Exception Occurs   " + ex.Message);
            return null;
        }

1 Ответ

2 голосов
/ 02 ноября 2011

Я думаю, вы слишком стараетесь смешать код Rx и код не-Rx вместе.Попробуйте заставить ваш код Rx работать в терминах простого запроса Rx, например: 

    return
        from st in fetchRequestStream()
        from rp in postDataAndFetchResponse(st)
        from s in fetchResult(rp)
        select s;

Этот запрос опирается на три функции, которые выглядят следующим образом: Func<X, IObservable<Y>>.

обрабатывать все повторные попытки и обработку исключений, используя стандартные операторы RX.Нет необходимости делать какие-то «случайные» звонки!

Вы можете назвать это так: 

FetchStringFromPost("url", "postData")
.Retry(3)
.Subscribe(s => { }, ex =>
{
    /* Exceptions here! */
}, () => { });

Вот полный код: 

public IObservable<string> FetchStringFromPost(string WebURL, string postData)
{
    var request = (HttpWebRequest)WebRequest.Create(WebURL);
    request.ContentType = "application/x-www-form-urlencoded";
    request.Method = "POST";
    request.Timeout = 100;
    request.KeepAlive = false;
    request.ProtocolVersion = HttpVersion.Version10;

    var fetchRequestStream = Observable
        .FromAsyncPattern<Stream>(
            request.BeginGetRequestStream,
            request.EndGetRequestStream);

    var fetchResponse = Observable
        .FromAsyncPattern<WebResponse>(
            request.BeginGetResponse,
            request.EndGetResponse);

    Func<Stream, IObservable<HttpWebResponse>> postDataAndFetchResponse = st =>
    {
        using (var writer = new StreamWriter(st))
        {
            writer.Write(postData);
        }
        return fetchResponse().Select(rp => (HttpWebResponse)rp);
    };

    Func<HttpWebResponse, IObservable<string>> fetchResult = rp =>
    {
        if (rp.StatusCode == HttpStatusCode.OK)
        {
            using (var reader = new StreamReader(rp.GetResponseStream()))
            {
                return Observable.Return<string>(reader.ReadToEnd());
            }
        }
        else
        {
            var msg = "HttpStatusCode == " + rp.StatusCode.ToString();
            var ex = new System.Net.WebException(msg,
                WebExceptionStatus.ReceiveFailure);
            return Observable.Throw<string>(ex);
        }
    };

    return
        from st in fetchRequestStream()
        from rp in postDataAndFetchResponse(st)
        from s in fetchResult(rp)
        select s;
}

Когда я проверялприведенный выше код я попытался позвонить FetchStringFromPost("http://www.microsoft.com", "foo").Materialize() и получил следующее:

WebException

Кажется, работает как удовольствие.Дайте мне знать, как вы идете.

...