在现代 Web 应用程序中，实时性越来越重要。而 Server-Sent Events (SSE) 是一种推送机制，可以实现在客户端与服务器之间实时通信，从而实现实时数据更新。本文将介绍如何在 Node.js 中实现 SSE 的推送机制。
什么是 Server-Sent Events
Server-Sent Events 是一种服务器向客户端推送事件的机制。它基于 HTTP 协议，使用标准的 HTTP 请求和响应，并且只使用了一个长连接。这样，服务器就可以在任何时候向客户端发送事件，而客户端则可以在任何时候接收到这些事件。SSE 可以用于实现实时数据更新，例如股票价格、聊天消息、新闻更新等。
实现 SSE 推送机制的步骤
要在 Node.js 中实现 SSE 推送机制，需要以下步骤：
- 创建一个 HTTP 服务器
- 监听客户端的连接请求
- 发送 SSE 事件
下面我们将逐步实现这些步骤。
创建一个 HTTP 服务器
首先，我们需要创建一个 HTTP 服务器。可以使用 Node.js 内置的 http 模块来创建一个 HTTP 服务器。以下是创建 HTTP 服务器的代码：
const http = require('http'); const server = http.createServer((req, res) => { // 处理请求 }); server.listen(3000); console.log('Server running at http://localhost:3000/');
这里我们创建了一个 HTTP 服务器，并将其监听在 3000 端口上。当有客户端请求连接时，服务器将会响应这个请求。
监听客户端的连接请求
接下来，我们需要监听客户端的连接请求。当客户端连接到服务器时，我们需要发送 SSE 事件。要实现这一点，我们可以使用 Node.js 内置的 EventEmitter 类来监听客户端的连接请求，并向客户端发送 SSE 事件。
以下是实现这一步的代码：
-- -------------------- ---- ------- ----- ---- - ---------------- ----- ------------ - ------------------ ----- ------ - ----------------------- ---- -- - -- ---- --- ----- ------------ - --- --------------- -------------------- ----- ---- -- - -- ------------------- -- ------------------ --- -------------------- - -- ------ ------------------ - --------------- -------------------- ---------------- ----------- ------------- ------------ --- -- -- --- -- -------------------------- ------ -- - ---------------- -------------- --- - --- -------------------- ------------------- ------- -- -------------------------展开代码
在这里，我们使用 EventEmitter 类来监听客户端的连接请求，并向客户端发送 SSE 事件。当客户端连接到服务器，并发送了一个 Accept: text/event-stream 的请求头时，服务器将响应这个请求，并向客户端发送 SSE 事件。我们使用 res.write() 方法来发送 SSE 事件的数据。
发送 SSE 事件
最后，我们需要发送 SSE 事件。我们可以使用 EventEmitter 类的 emit() 方法来发送 SSE 事件。以下是发送 SSE 事件的代码：
-- -------------------- ---- ------- ----- ---- - ---------------- ----- ------------ - ------------------ ----- ------ - ----------------------- ---- -- - -- ---- --- ----- ------------ - --- --------------- -------------------- ----- ---- -- - -- ------------------- -- ------------------ --- -------------------- - -- ------ ------------------ - --------------- -------------------- ---------------- ----------- ------------- ------------ --- -- -- --- -- -------------------------- ------ -- - ---------------- -------------- --- - --- ---------------------------- ------- --------- -------------------- ------------------- ------- -- -------------------------展开代码
在这里，我们使用 EventEmitter 类的 emit() 方法来发送 SSE 事件。当服务器收到一个 SSE 事件时，它将调用 res.write() 方法来向客户端发送 SSE 事件的数据。
示例代码
以下是一个完整的示例代码，可以用来演示如何在 Node.js 中实现 SSE 的推送机制：
-- -------------------- ---- ------- ----- ---- - ---------------- ----- ------------ - ------------------ ----- ------ - ----------------------- ---- -- - -- ---- --- ----- ------------ - --- --------------- -------------------- ----- ---- -- - -- ------------------- -- ------------------ --- -------------------- - -- ------ ------------------ - --------------- -------------------- ---------------- ----------- ------------- ------------ --- -- -- --- -- -------------------------- ------ -- - ---------------- -------------- --- - --- -------------- -- - ---------------------------- --- ---------------------- -- ------ -------------------- ------------------- ------- -- -------------------------展开代码
在这个示例中，我们使用 setInterval() 方法来发送 SSE 事件，每秒钟发送一次。当客户端连接到服务器并发送一个 SSE 请求时，服务器将会向客户端发送 SSE 事件，每秒钟发送一次当前时间。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/67da1f56a941bf71341d85e7
