Как проверить ответ HTTP, продолжая публиковать данные с помощью HttpWebRequest - PullRequest
Новая
       22

Как проверить ответ HTTP, продолжая публиковать данные с помощью HttpWebRequest

0 голосов
/ 15 ноября 2018

Мне нужно отправить данные на REST-сервер. Эти данные являются динамическими, и поэтому я не знаю, насколько они будут большими, пока я отправляю сообщение, поскольку я получаю его в режиме реального времени из другого места. Однако сервер отвечает, когда получено достаточно данных.

Я попытался использовать HttpWebRequest для этого. Однако если я вызываю BeginGetResponse перед записью в поток запросов, то запись в поток запросов вызывает исключение. Видимо, получение ответа мешает мне отправить дополнительную информацию. Как я могу узнать, отправил ли сервер ответ без фактического ответа?

Вот код. 

async private Task SendDataFile(ChannelParameters cp)
    {
        var uri = new Uri("http://" + Properties.Settings.Default.dnn_servers[0] + ":" + Properties.Settings.Default.dnn_ports[0]);
        string request_uri = "http://" + Properties.Settings.Default.dnn_servers[0] + ":" + Properties.Settings.Default.dnn_ports[0] + String.Format("/v1/speech:recognize/{0}?key={1}&confidence-threshold={2}&do-endpointing={3}",
          cp.current_name, rest_app_key, Properties.Settings.Default.usConfidenceThreshold, Properties.Settings.Default.endpointing);


        HttpWebRequest httpWebRequest = (HttpWebRequest)WebRequest.Create(request_uri);
        httpWebRequest.Method = "POST";
        httpWebRequest.PreAuthenticate = false;
        httpWebRequest.AllowWriteStreamBuffering = false;
        httpWebRequest.SendChunked = true;
        httpWebRequest.Headers["Accept-Language"] = Properties.Settings.Default.Resource.ToString();
        httpWebRequest.Accept = "*/*";
        //st.Write(b, 0, b.Length);
        //st.Write(b, 0, b.Length);
        //...
        switch (main_window.parameters.stream_format)
        {
            case 0:
                httpWebRequest.ContentType = "audio/L16; rate=8000";
                break;
            case 1:
                httpWebRequest.ContentType = "audio/PCMU; rate=8000";
                break;
            case 2:
                httpWebRequest.ContentType = "audio/PCMA; rate=8000";
                break;

        }
        httpWebRequest.BeginGetRequestStream(new AsyncCallback(GetRequestStreamCallback), httpWebRequest);

        //httpWebRequest.BeginGetResponse(new AsyncCallback(GetResponseCallback), httpWebRequest); can't remove the comment on this line.
        allDone.WaitOne();

    }

    private void GetRequestStreamCallback(IAsyncResult asynchronousResult)
    {

        done_stream = false;
        HttpWebRequest request = (HttpWebRequest)asynchronousResult.AsyncState;
        // End the operation
        Stream postStream = request.GetRequestStream();
        request.BeginGetResponse(new AsyncCallback(GetResponseCallback), request);
        while (stream_data_event.WaitOne() && !done_stream)
        {
            stream_data_event.Reset();
            long write_position = main_window.stream_memory.Position;
            main_window.stream_memory.Seek(0, SeekOrigin.Begin);
            try
            {
                postStream.Write(main_window.stream_memory.GetBuffer(), 0, (int)write_position);
            }
            catch (Exception e)
            {
                main_window.AddToLog(e.ToString());
            }
            main_window.stream_memory.Position = 0;

        }
        postStream.Close();
        request.BeginGetResponse(new AsyncCallback(GetResponseCallback), request);
    }

    private void GetResponseCallback(IAsyncResult asynchronousResult)
    {
        HttpWebRequest request = (HttpWebRequest)asynchronousResult.AsyncState;

        // End the operation
        HttpWebResponse response = (HttpWebResponse)request.EndGetResponse(asynchronousResult);
        ////done_stream = true;
        main_window.StopRecord();
        Stream streamResponse = response.GetResponseStream();
        StreamReader streamRead = new StreamReader(streamResponse);
        string responseString = streamRead.ReadToEnd();
        Console.WriteLine(responseString);
        // Close the stream object
        streamResponse.Close();
        streamRead.Close();
        // Release the HttpWebResponse
        response.Close();
        allDone.Set();
    }

Кто-нибудь когда-нибудь пробовал что-то подобное?

...