asp net server events example下载 - asp net server events example源代码下载

asp net server events example

其他类别

1.0.0

下载

服务器使用 ASP.Net Core 后端发送事件

在 ASP.Net core Web API 中使用 HTML 服务器发送事件的小示例。

远程柜台

应用程序的屏幕截图

该应用程序是一个每秒自动增加的计数器。用户可以暂停或恢复计数器，或将其设置为给定值。

计数器存储在服务器的内存中。浏览器会话中的更改将传播到所有其他打开的会话。

服务器发送事件

服务器发送事件是一个 Web API，允许您使用 HTTP 流将消息从服务器推送到 JavaScript。

这不是从服务器推送消息的唯一方法，但它确实是一种简单且非常优雅的方法。

使用服务器发送事件的 Javascript 代码位于文件stream.js 中，如下所示：

 function readStream()
{
    const evtSource = new EventSource('/Counter/Stream');
    evtSource.onmessage = function(event) {
        const el = document.getElementById('counter');
        const { value } = JSON.parse(event.data);
        
        el.textContent = value;
    }
}

ASP.Net Core 后端

该存储库包含一个小型独立的 Web 应用程序，可用作参考或样板代码，用于通过 ASP.Net Core 后端使用服务器发送的事件。

HTTP 流端点的实现可以在 CounterController.cs 中找到，如下所示。它改编自 StackOverflow 的答案。

 [HttpGet]
[Route("Stream")]
public async Task StreamCounter(CancellationToken cancellationToken)
{
    _logger.LogInformation("Start counter streaming.");

    Response.StatusCode = 200;
    Response.Headers.Add("Content-Type", "text/event-stream");

    _counter.CounterUpdated += StreamValue;

    while (!cancellationToken.IsCancellationRequested) {
        await Task.Delay(1000);
    }

    _counter.CounterUpdated -= StreamValue;
    _logger.LogInformation("Stop counter streaming.");

    async void StreamValue(object sender, int value)
    {
        var messageJson = JsonConvert.SerializeObject(_counter, _jsonSettings);
        await Response.WriteAsync($"data:{messageJson}nn");
        await Response.Body.FlushAsync();
    }
}

状态（计数器）存储在单例服务 PersistentCounter 中。

每次更新计数器值时，服务都会触发一个事件。控制器订阅此事件并在每次更改后将新值推送到客户端。