NodeJS与TS前端SSE配置异常：事件批量延迟接收求助

你的问题核心是输出缓冲机制导致的：Node.js、中间件甚至反向代理都会默认缓冲小数据块，攒到一定大小才会发送给前端，因此出现批量接收的情况。以下是具体修正步骤：

一、服务器端核心修正 #

1. 配置正确的SSE响应头 #

必须确保响应头关闭缓存、启用长连接，并指定正确的内容类型：

// 以Express框架为例
app.get('/sse', (req, res) => {
  res.setHeader('Content-Type', 'text/event-stream');
  res.setHeader('Cache-Control', 'no-cache');
  res.setHeader('Connection', 'keep-alive');
  res.setHeader('Transfer-Encoding', 'chunked'); // 强制分块传输
  res.flushHeaders(); // 立即发送响应头，避免前端等待
});

2. 禁用压缩中间件 #

如果项目使用了compression这类压缩中间件，必须排除SSE路由——压缩会缓冲数据直到达到阈值，完全和SSE的实时性冲突：

// 仅给非SSE路由启用压缩
app.use(/^(?!\/sse).*/, compression());

3. 手动刷新响应缓冲区 #

每次发送事件后，强制Node.js立即输出缓冲区内容，不要等待系统自动触发：

let count = 0;
setInterval(() => {
  // 严格遵循SSE格式：数据行以data:开头，结尾必须加\n\n
  res.write(`data: ${JSON.stringify({ count: count++ })}\n\n`);
  // 关键操作：手动刷新缓冲区
  res.flush(); // Express 4.x+直接支持；原生HTTP可使用 res.socket?.write('') 触发刷新
}, 1000);

二、前端代码检查 #

确保前端EventSource实例配置正确，没有额外的缓冲设置：

const sse = new EventSource('/sse');
sse.onmessage = (e) => {
  console.log('实时接收:', JSON.parse(e.data));
};

// 监听错误，快速排查连接异常
sse.onerror = (err) => {
  console.error('SSE错误:', err);
  sse.close();
};

三、反向代理配置（如果使用） #

如果Node服务前部署了Nginx这类反向代理，必须禁用代理缓冲：

location /sse {
    proxy_pass http://localhost:3000; # 替换为你的Node服务地址
    proxy_buffering off; # 禁用代理缓冲
    proxy_cache off;
    proxy_set_header Connection ''; # 保持长连接
    chunked_transfer_encoding on;
}

总结 #

只要解决了各个环节的缓冲问题（Node.js自身输出缓冲、压缩中间件、反向代理缓冲），就能实现SSE事件的实时推送，不会再出现批量接收的情况。

内容的提问来源于stack exchange，提问作者Styler2go