HttpWebRequest по частям/асинхронный POST

Я нашел свою проблему.

Порядок моего кода вызвал проблему.

Решение состоит в том, чтобы вызвать его в следующем порядке:

• GetRequestStream (асинхронная запись в поток) (запрос отправляется на сервер после первой записи), затем:
• GetResponseAsync()
• ПолучитьПотокОтвета()

Насколько я понимаю, «GetResponseAsync» запускает клиент для отправки запроса (пока только заголовки), но я обнаружил, что это ненужный шаг, потому что запрос уже был отправлен после того, как первые несколько битов были записаны в поток.

Вторая причина моих проблем — Fiddler, но Fiddler поддерживает только потоковую передачу ответов, а не запросов.

Полученный код ссылается на класс HttpWebRequest:

HttpWebRequest httpWebRequest = HttpWebRequest.Create("http://xxx") as HttpWebRequest;
httpWebRequest.Method = "POST";
httpWebRequest.Headers["Authorization"] = "Basic " + Convert.ToBase64String(Encoding.ASCII.GetBytes("user:pw"));
httpWebRequest.PreAuthenticate = true;    
httpWebRequest.SendChunked = true;
httpWebRequest.AllowWriteStreamBuffering = false;
httpWebRequest.AllowReadStreamBuffering = false;    
httpWebRequest.ContentType = "application/octet-stream";

Stream st = httpWebRequest.GetRequestStream();

Console.WriteLine("Go");

try
{
    st.Write(buffer, 0, buffer.Length); //with the first write, the request will be send.
    st.Write(buffer, 0, buffer.Length);
    st.Write(buffer, 0, buffer.Length);

    for (int i = 1; i <= 10; i++)
    {        
        st.Write(buffer, 0, buffer.Length); //still writing while I can read on the stream at my ASP.NET web api

    }

}
catch (WebException ex)
{
    var y = ex.Response;

}
finally
{
    st.Close();

}

// Now we can read the response from the server in chunks

Task<WebResponse> response = httpWebRequest.GetResponseAsync();

Stream resultStream = response.Result.GetResponseStream();

byte[] data = new byte[1028];

int bytesRead;

while ((bytesRead = resultStream.Read(data, 0, data.Length)) > 0)
{
    string output = System.Text.Encoding.UTF8.GetString(data, 0, bytesRead);

    Console.WriteLine(output);

}

Полученный код ссылается на класс HttpClient:

HttpClientHandler ch = new HttpClientHandler();

HttpClient c = new HttpClient(ch);    
c.DefaultRequestHeaders.TransferEncodingChunked = true;    
c.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Basic", Convert.ToBase64String(Encoding.ASCII.GetBytes("user:pw")));

Stream stream = new MemoryStream();

AsyncStream asyncStream = new AsyncStream(); // Custom implementation of the PushStreamContent with the method, "WriteToStream()".

PushStreamContent streamContent = new PushStreamContent(asyncStream.WriteToStream);

HttpRequestMessage requestMessage = new HttpRequestMessage(new HttpMethod("POST"), "http://XXX") { Content = streamContent };

requestMessage.Headers.TransferEncodingChunked = true;

HttpResponseMessage response = await c.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead);

// The request has been sent, since the first write in the "WriteToStream()" method.

response.EnsureSuccessStatusCode();

Task<Stream> result = response.Content.ReadAsStreamAsync();

byte[] data = new byte[1028];

int bytesRead;

while ((bytesRead = await result.Result.ReadAsync(data, 0, data.Length)) > 0)
{
    string output = System.Text.Encoding.UTF8.GetString(data, 0, bytesRead);

    Console.WriteLine(output);

}

Console.ReadKey();

Вы используете объекты HttpWebRequest одновременно в нескольких потоках. response — это задача, которая выполняется одновременно с вашими операциями записи. Это явно небезопасно для потоков.

Кроме того, я не вижу, чего вы хотите добиться. HTTP использует модель «запрос-ответ». Сервер не может (обычно) отправить один байт ответа до получения всего запроса. Теоретически это возможно. Но это очень необычно и, скорее всего, не поддерживается .NET BCL. Это будет поддерживаться только вашим (очень необычным) настраиваемым HTTP-сервером.