在UWP中接收服务器发送事件（SSE）

Question

我有一个ASP。net core 3.1服务器项目，它有一个非常简单的API发送单向服务器发送事件（SSE），如下所示：

[HttpGet]
public async Task Get()
{
    var response = Response;
    response.Headers.Add("Content-Type", "text/event-stream");
    response.Headers.Add("Cache-Control", "no-cache");
    response.Headers.Add("Connection", "keep-alive");

    for (var i = 0; true; ++i)
    {
        await response.WriteAsync($"id: unique{i}\n");
        await response.WriteAsync("event: add\n");
        //await response.WriteAsync("retry: 10000\n");
        await response.WriteAsync($"data: Controller {i} at {DateTime.Now}\n\n");

        response.Body.Flush();
        await Task.Delay(5 * 1000);
    }
}

现在，我想通过C#UWP客户端接收这些事件。很遗憾，我只收到第一个事件：

using (var client = new HttpClient())
{
    using (var stream = await client.GetStreamAsync("http://localhost:5000/api/subscription"))
    {
        using (var reader = new StreamReader(stream))
        {
            while (true)
            {
                Console.WriteLine(reader.ReadLine());
            }
        }
    }
}

如何在UWP中创建行为以始终监听该连接并接收我可以进一步处理的事件？

Answer 1

我在这里找到了一个解决方案https://techblog.dorogin.com/server-sent-event-aspnet-core-a42dc9b9ffa9.诀窍是不要像问题中那样设置连续返回数据的WebAPI调用，而是使用MIME类型的text/event-stream创建一个data-stream。

然后，在UWP客户端，您可以像这样读取流：

var stream = httpClient.GetStreamAsync(requestUri).Result;

using (var reader = new StreamReader(stream))
{
    while (!reader.EndOfStream)
    {
        Debug.WriteLine(reader.ReadLine());
    }
}

Answer 2

HttpClient以启动请求开始，在收到服务器返回的数据时结束。

这相当于只提出一个请求。如果要在应用程序和服务器之间构建连续的数据传输通道，请尝试使用WebSocket

下面是一个使用WebSocket作为参考的代码示例：WebSocket示例

此外，在使用Visual Studio进行调试时，您可以访问localhost，但在发布应用程序时，由于本地网络环回，UWP将无法访问localhost

谢谢