希望有人能为我解答以下问题。
我有一个客户端,将向控制器端点发送请求(没有视图,从c#到c#,甚至是C++)。控制器将必须异步获取响应并以json格式发送它们(向客户端发送json1,然后是json2,json3等,直到关闭连接或发送类似的空终止文本)。目的是将结果流式传输回客户端,以便在服务器仍在工作时可以开始处理。
我的控制器端点如下所示:
我有一个客户端,将向控制器端点发送请求(没有视图,从c#到c#,甚至是C++)。控制器将必须异步获取响应并以json格式发送它们(向客户端发送json1,然后是json2,json3等,直到关闭连接或发送类似的空终止文本)。目的是将结果流式传输回客户端,以便在服务器仍在工作时可以开始处理。
我的控制器端点如下所示:
[HttpGet("testStream")]
public async Task testStream()
{
var response = HttpContext.Response;
response.Headers[HeaderNames.TransferEncoding] = "chunked";
for (var i = 0; i < 10; ++i)
{
await response.WriteAsync($"6\r\ntest {i}\r\n");
await response.Body.FlushAsync();
await Task.Delay(1 * 1000);
}
await response.WriteAsync("0\r\n\r\n");
await response.Body.FlushAsync();
}
我的测试看起来像这样:
static async void DownloadPageAsync()
{
// ... Target page.
string page = "http://localhost:8080/api/Stream/testStream";
Console.WriteLine("test");
while (!Debugger.IsAttached) Thread.Sleep(500);
// ... Use HttpClient.
using (HttpClient client = new HttpClient())
using (var response = await client.GetAsync(page, HttpCompletionOption.ResponseHeadersRead))
using (HttpContent content = response.Content)
{
string result = await content.ReadAsStringAsync();
do
{
Console.WriteLine(result);
result = await content.ReadAsStringAsync();
}
while (result != "null");
}
Console.WriteLine("END");
}
[Fact]
public void Test1()
{
TestSurvey.DownloadPageAsync();
}
当我调用content.ReadAsStringAsync();
时,我遇到了异常。
System.Net.Http.HttpRequestException : Error while copying content to a stream.
[xUnit.net 00:01:14.5836121] ---- System.IO.IOException : The read operation failed, see inner exception.
[xUnit.net 00:01:14.5836496] -------- System.Net.Http.CurlException : Failure when receiving data from the peer
[xUnit.net 00:01:14.5846837] Stack Trace:
[xUnit.net 00:01:14.5857807] at System.Net.Http.HttpContent.<LoadIntoBufferAsyncCore>d__48.MoveNext()
编辑:异常是因为未发送块的大小
await response.WriteAsync($"6\r\ntest {i}\r\n");
但是现在在测试/客户端方面,我一次性收到了所有块...
await Task.Delay(1 * 1000);
。 - Liam