在 Web 应用程序中，实时推送是一项非常重要的功能，它可以使用户在不刷新页面的情况下获取最新的数据。Node.js 是一个非常适合实现实时推送的平台，而 Server-Sent Events 则是一种非常适合实现实时推送的技术。
什么是 Server-Sent Events
Server-Sent Events（SSE）是一种基于 HTTP 的协议，它允许服务器向客户端发送事件流。SSE 的工作原理是，客户端向服务器发送一个 HTTP 请求，服务器在响应中使用特殊的 MIME 类型（text/event-stream）来发送事件流。客户端通过监听事件流来接收服务器推送的数据。
SSE 与 WebSocket 相比，具有以下优点：
- SSE 是基于 HTTP 的，因此不需要建立像 WebSocket 那样的全双工连接，可以使用现有的 Web 服务器和负载均衡器。
- SSE 可以使用浏览器内置的 EventSource API 来接收事件流，不需要使用 WebSocket API。
- SSE 支持自动重连机制，当连接断开时，浏览器会自动重新连接服务器。
如何在 Node.js 中使用 Server-Sent Events
在 Node.js 中使用 Server-Sent Events，需要使用一个名为 sse 的 npm 模块。可以使用以下命令安装该模块：
npm install sse
接下来，可以编写一个 Node.js 服务器端代码，用于向客户端发送事件流。以下是一个简单的示例代码：
// www.javascriptcn.com code example
const sse = require('sse');
const server = require('http').createServer();
const port = 3000;
server.listen(port, () => {
console.log(`Server listening on port ${port}`);
});
const clients = new Set();
server.on('request', (req, res) => {
if (req.url === '/events') {
res.setHeader('Content-Type', 'text/event-stream');
res.setHeader('Cache-Control', 'no-cache');
res.setHeader('Connection', 'keep-alive');
const client = new sse(req, res);
clients.add(client);
req.on('close', () => {
clients.delete(client);
});
} else {
res.statusCode = 404;
res.end();
}
});
setInterval(() => {
for (const client of clients) {
client.sendEvent({
data: 'Hello, world!'
});
}
}, 1000);以上代码创建了一个 HTTP 服务器，并监听 3000 端口。当客户端访问 /events 路径时，服务器会向客户端发送事件流。clients 变量存储了所有已连接的客户端，当客户端断开连接时，会从 clients 中删除相应的客户端。
代码中的 setInterval 函数会每秒向所有客户端发送一个事件，事件的数据为字符串 'Hello, world!'。
在客户端，可以使用以下代码来监听事件流：
const source = new EventSource('/events');
source.addEventListener('message', event => {
console.log(event.data);
});以上代码会创建一个 EventSource 对象，并向 /events 路径发送一个 HTTP 请求，以获取事件流。当收到事件流时，message 事件会被触发，事件的数据即为服务器发送的数据。
结语
本文介绍了 Server-Sent Events 在 Node.js 中的使用方法，以及如何实现实时推送功能。通过使用 Server-Sent Events，可以轻松地实现实时推送，提升 Web 应用程序的用户体验。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/67d387e0a941bf71346b95bb