前言
在现代 web 应用中，实时消息推送已经成为了常见的需求。而 SSE（Server-Sent Events）是一种实现实时消息推送的技术，相对于 WebSocket 而言，SSE 更加轻量级，易于部署和维护，同时也不需要额外的协议和握手过程。本文将介绍如何在.Net Core 应用中使用 SSE 实现消息实时推送。
SSE 原理
SSE 是基于 HTTP 协议的一种实现实时消息推送的技术。它通过建立一条持久的 HTTP 连接，将服务器端的消息以流的形式推送给客户端。SSE 的流程如下：
- 客户端向服务器端发起 SSE 连接请求。
- 服务器端响应 SSE 连接请求，并在响应头中设置 Content-Type 为 text/event-stream。
- 服务器端向客户端发送消息，每个消息以一行 \n 结尾。
- 客户端接收到消息后，通过 JavaScript 的 EventSource API 进行处理。
在.Net Core 中实现 SSE 推送
在.Net Core 中实现 SSE 推送，需要使用 ASP.NET Core 中自带的中间件 ServerSentEventsMiddleware。该中间件可以帮助我们创建 SSE 推送的连接，并在连接建立后向客户端发送消息。
下面是一个简单的 SSE 推送示例：
-- -------------------- ---- -------
------ ----- ------------- - ----------
-
------- -------- ----------------------- ------------
------ ------------------------------------- -----------
-
----------- - -----------
-
---------
------ ----- ------------------- -----
-
--- -------- - ---------------------
------------------------------------ ---------------------
----- ------------------------------------- ------- -------
------ --- --------------
-
-
------ ----- -----------------------
-
------- -------- ---------------- -----------------
------ ---------------------------------------- ----------------
-
---------------- - ----------------
-
------ ----- ---- --------------------- ---------- ------ -----
-
--- --- - ---------------------------------------------------------
----- ----------------------------- ------
-
-
------ --------- -----------------
-
---- --------------------- ---------- ------ ------
-
------ ----- -------------------------- - ------------ -----------------
-
------- -------- ------------ ---------- ------ ------ -------------- - --- ------------ ---------- ------ ---------
------- -------- ------------- ---------- - --- -----------------
------- -------- ----------------------------------- --------
------ -------------------------------------------------------------- -------
-
------- - -------
-
------ ----- ---- ----------------------- -------- --------------- -----
-
-- ---------------------------------- -- --------------------
-
--------------------------- ---------- --------------
--------------------------------------------- ------------
-------------------------------------------- ---------------------
------------------------------------------ --------------
----- ----------------------------------
----- -------------------------------
-
----
-
----- --------------
-
-
------ ----- ---- --------------------- ---------- ------ -----
-
----- -----------------------
------------------------------ -------
---------------------
-
------- ----- ---- ---------------------------- ---------
-
--- ---- - -- ----------
----- --------------------------
----- ---------------------------
-
------- ----- ---- ------------------------- ---------
-
--- ------ - --- --------------------------- - --------- - ---- --
----- ------
-
----- -----------------------
-- --------------------- - --
-
--- ----------- ----- - ------------------
---------------------------
--- ----------- - -------- ---------------
----- -------------------------------
------- ---- ---- -- -----------------
-
--- ---------- - ------- ----------
----- ------------------------------
-
----- ------------------------
-
---------------------
----- -----------------
-
-
-上述代码中，我们定义了一个 ServerSentEventsMiddleware 中间件，用于创建 SSE 连接。当客户端向服务端发起 SSE 连接请求时，该中间件将会被调用。在中间件处理过程中，我们会向客户端发送一个初始的数据 : ping\n\n，以保持连接的持久性。同时，我们还会在 _pendingEvents 队列中存储待发送的消息。在 SendEventAsync 方法中，我们将待发送的消息添加到 _pendingEvents 队列中。在 WaitForEvent 方法中，我们会循环等待 _pendingEvents 队列中是否有待发送的消息。如果有，则将消息发送给客户端。
在 SseController 控制器中，我们注入了 ServerSentEventsService 服务，并在 Get 方法中调用 SendEventAsync 方法向客户端发送消息。同时，我们还设置了响应头 Content-Type 为 text/event-stream。
总结
本文介绍了如何在.Net Core 应用中使用 SSE 实现消息实时推送。通过使用 ASP.NET Core 中自带的中间件 ServerSentEventsMiddleware，我们可以轻松地创建 SSE 连接，并向客户端推送实时消息。在实际应用中，我们可以根据业务需求，将 SSE 推送集成到我们的 web 应用中，以实现实时消息推送的功能。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/65cedb46add4f0e0ff834de6