ASP.NET Core 10 中的 Server-Sent Events 支持解析
Server-Sent Events (SSE) 是一种允许服务器向客户端推送更新的技术,它在需要实时单向数据流的场景中非常有用。ASP.NET Core 10 Preview 3 版本为 Minimal APIs 引入了对 SSE 的原生支持,这为开发者提供了更简洁高效的方式来构建实时应用。
什么是 Server-Sent Events
Server-Sent Events 是基于 HTTP 的轻量级协议,它允许服务器通过持久连接向客户端推送数据。与 WebSocket 不同,SSE 是单向的(仅服务器到客户端),但实现更简单,自动处理重连机制,并且可以直接使用 HTTP 协议而不需要额外升级。
典型的 SSE 应用场景包括:
- 实时通知系统
- 股票行情推送
- 新闻订阅
- 进度更新反馈
ASP.NET Core 10 中的 SSE 实现
在 ASP.NET Core 10 中,Minimal APIs 通过新的结果类型简化了 SSE 的实现。开发者现在可以使用专门的 SseResult
类型来创建 SSE 端点,而不需要手动处理底层响应流。
基本用法示例
app.MapGet("/sse", async () =>
{
async IAsyncEnumerable<string> GetEvents()
{
while (true)
{
yield return $"当前时间: {DateTime.Now}";
await Task.Delay(1000);
}
}
return new SseResult(GetEvents());
});
这个简单的示例每秒向客户端发送一次当前时间。SseResult
包装了一个异步可枚举对象,自动处理了 SSE 协议要求的格式化和流传输。
高级特性
事件类型和重试控制
SSE 协议支持定义事件类型和重试间隔:
app.MapGet("/advanced-sse", async () =>
{
async IAsyncEnumerable<SseEvent> GetEvents()
{
var retryMs = 1000;
while (true)
{
yield return new SseEvent(
data: $"服务器时间: {DateTime.Now}",
type: "timeUpdate",
retry: retryMs);
await Task.Delay(5000);
retryMs += 1000; // 每次重试间隔增加1秒
}
}
return new SseResult(GetEvents());
});
错误处理和连接管理
SSE 连接会自动处理客户端断开和重连。服务器端可以通过捕获异常来监控连接状态:
app.MapGet("/monitored-sse", async (HttpContext context) =>
{
try
{
async IAsyncEnumerable<string> GetEvents()
{
while (!context.RequestAborted.IsCancellationRequested)
{
yield return $"心跳: {DateTime.Now}";
await Task.Delay(1000);
}
}
return new SseResult(GetEvents());
}
catch (Exception ex)
{
logger.LogError(ex, "SSE连接异常");
return Results.StatusCode(500);
}
});
性能考量
使用 SSE 时应注意以下几点:
- 每个 SSE 连接都会保持一个开放的 HTTP 连接,服务器资源消耗会随客户端数量线性增长
- 对于高并发场景,考虑使用连接池或负载均衡
- 消息频率不宜过高,避免网络拥塞
- 适当设置客户端重试策略,减轻服务器压力
与传统实现的对比
在 ASP.NET Core 10 之前,实现 SSE 需要手动处理响应流:
app.MapGet("/legacy-sse", async (HttpContext context) =>
{
context.Response.ContentType = "text/event-stream";
try
{
while (true)
{
await context.Response.WriteAsync($"data: {DateTime.Now}\n\n");
await context.Response.Body.FlushAsync();
await Task.Delay(1000);
}
}
catch (Exception)
{
// 处理断开连接
}
});
新的 SseResult
方式不仅代码更简洁,而且自动处理了协议细节,如正确的事件流格式、连接管理和错误处理。
适用场景建议
SSE 最适合以下场景:
- 需要服务器向客户端推送更新
- 数据更新频率适中(每秒几次到每分钟几次)
- 不需要客户端向服务器发送大量数据
- 需要兼容性较好的实时解决方案(SSE 在所有现代浏览器中都支持)
对于需要双向通信或高频更新的场景,WebSocket 可能是更好的选择。
总结
ASP.NET Core 10 对 Server-Sent Events 的原生支持显著简化了实时功能的开发。新的 SseResult
类型让开发者能够专注于业务逻辑而不是协议细节,同时提供了足够的灵活性来处理各种实时数据推送场景。这一改进使得 ASP.NET Core 在构建现代实时 Web 应用方面更加全面和强大。
- DDeepSeek-R1-0528DeepSeek-R1-0528 是 DeepSeek R1 系列的小版本升级,通过增加计算资源和后训练算法优化,显著提升推理深度与推理能力,整体性能接近行业领先模型(如 O3、Gemini 2.5 Pro)Python00
cherry-studio
🍒 Cherry Studio 是一款支持多个 LLM 提供商的桌面客户端TSX028unibest
unibest - 最好用的 uniapp 开发框架。unibest 是由 uniapp + Vue3 + Ts + Vite5 + UnoCss + WotUI 驱动的跨端快速启动模板,使用 VS Code 开发,具有代码提示、自动格式化、统一配置、代码片段等功能,同时内置了大量平时开发常用的基本组件,开箱即用,让你编写 uniapp 拥有 best 体验。TypeScript00
热门内容推荐
最新内容推荐
项目优选









