服务器发送事件（Server-Sent Events，简称 SSE）是一种允许服务器主动向Web页面推送信息的技术。它建立在HTTP协议之上，使得服务器能够实时发送更新到客户端，这在创建实时应用程序时非常有用，如显示实时消息、股票行情、或实时通知等。

在 Node.js 中使用服务器发送事件（Server-Sent Events, SSE）可以允许服务器主动向客户端发送更新。SSE 通常用于创建实时通知和更新，而不需要客户端周期性地轮询服务器。以下是如何在 Node.js 中使用来自 SSE 服务器的数据的步骤：

### 1. 创建 SSE 服务器端

首先，需要在 Node.js 中创建一个可以发送事件的服务器。通常，这是通过设置一个可以处理 HTTP 请求并保持连接打开以发送事件的端点实现的。这里使用 Express.js 创建 SSE 服务器的一个简单例子：

```javascript
const express = require('express');
const app = express();

app.get('/events', function(req, res) {
    // 设置响应头来建立 SSE 连接
    res.writeHead(200, {
        'Content-Type': 'text/event-stream',
        'Cache-Control': 'no-cache',
        'Connection': 'keep-alive'
    });

    // 发送一个简单的事件
    setInterval(() => {
        const date = new Date();
        res.write(`data: ${date.toISOString()}\n\n`);
    }, 1000);

    // 处理连接关闭
    req.on('close', () => {
        console.log('客户端关闭了连接');
    });
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
    console.log(`SSE 服务器运行在 http://localhost:${PORT}`);
});
```

### 2. 在客户端使用 SSE

在客户端，你可以使用浏览器的 `EventSource` 接口来连接到你刚才创建的 SSE endpoint。以下是如何在客户端连接 SSE 服务器并接收事件的 JavaScript 代码：

```javascript
const eventSource = new EventSource('/events');

eventSource.onmessage = function(event) {
    // 打印从服务器收到的数据
    console.log('来自服务器的数据:', event.data);
};

eventSource.onerror = function(error) {
    // 处理错误情况
    console.error('EventSource 遇到错误:', error);
};
```

### 3. 实现重连机制

`EventSource` 接口会在连接断开时自动尝试重新连接，不过你也可以实现自定义的逻辑来控制重连行为：

```javascript
eventSource.onopen = function() {
    console.log('连接已打开');
};

eventSource.onerror = function(error) {
    if (eventSource.readyState === EventSource.CLOSED) {
        console.log('连接被关闭');
    } else {
        console.log('发生错误，连接将尝试重新连接');
    }
};
```

### 4. 关闭连接

如果你想在不需要接收事件时关闭连接，可以调用 `close` 方法：

```javascript
eventSource.close();
```

这段代码只是 SSE 应用的一个简化示例，真实情况下你可能需要处理更多的边缘情况和优化点，比如确保服务器端能妥善处理大量的并发连接，以及在客户端处理不同类型的事件和更复杂的重连策略等。在生产环境中，你可能还需要考虑使用 HTTPS 加密连接，以及添加适当的身份验证和授权机制。

SSE相关问题

How to consume data from a sse server in Nodejs?