JavaScriptSSE实战：服务器推送教程详解

本文深入浅出地讲解了JavaScript中服务器推送事件（SSE）的实战应用，从原理出发，清晰对比其与WebSocket的差异，突出SSE轻量、单向、基于HTTP、兼容性好等优势；手把手演示前端如何用EventSource监听默认消息与自定义事件，后端如何在Node.js/Express中构建流式响应接口，并覆盖Nginx配置、心跳保活、断线重连、消息ID恢复等关键生产实践要点，助你快速搭建稳定高效的实时日志、通知或行情推送系统。

服务器推送事件（Server-Sent Events，简称 SSE）是一种让服务器通过 HTTP 连接持续向浏览器推送数据的技术。相比 WebSocket，SSE 更轻量、使用简单，适用于日志实时更新、通知推送、股票行情等场景。本文带你实战 JavaScript 中的 SSE 技术，掌握其核心用法与常见问题处理。

什么是 SSE？

SSE 基于 HTTP 协议，允许服务器单向向客户端发送文本数据流。客户端使用 EventSource API 接收消息，连接自动重连，支持事件类型区分，适合服务端主动推送更新的场景。

与 WebSocket 不同，SSE 是单向通信（仅服务端 → 客户端），但胜在简单、兼容性好、可利用现有 HTTP 机制（如认证、CORS）。

前端：使用 EventSource 接收推送

JavaScript 提供了原生的 EventSource 接口，使用非常直观：

const eventSource = new EventSource('/api/stream');

eventSource.onmessage = function(event) {
  console.log('收到消息:', event.data);
};

eventSource.addEventListener('notification', function(event) {
  console.log('通知:', event.data);
});

eventSource.onerror = function(err) {
  console.error('SSE 连接出错', err);
};

说明：

• onmessage：监听默认消息（无指定事件类型）
• addEventListener：监听自定义事件类型，如 'notification'
• onerror：错误处理，连接断开会自动尝试重连

后端：Node.js 实现 SSE 接口

以 Express 为例，实现一个简单的 SSE 接口：

app.get('/api/stream', (req, res) => {
  // 设置响应头
  res.writeHead(200, {
    'Content-Type': 'text/event-stream',
    'Cache-Control': 'no-cache',
    'Connection': 'keep-alive',
    'Access-Control-Allow-Origin': '*'
  });

  // 发送一条普通消息
  res.write('data: 欢迎连接到 SSE 服务\n\n');

  // 定时推送时间
  const interval = setInterval(() => {
    res.write(`data: ${new Date().toLocaleTimeString()}\n\n`);
  }, 1000);

  // 自定义事件推送
  setInterval(() => {
    res.write('event: notification\n');
    res.write('data: 系统有新消息提醒\n\n');
  }, 5000);

  // 客户端断开时清理
  req.on('close', () => {
    clearInterval(interval);
    res.end();
  });
});

关键点：

• 必须设置 Content-Type: text/event-stream
• 每条消息以 \n\n 结束
• 可用 event: 指定事件名，data: 发送内容
• 保持连接不关闭，直到客户端断开

实际应用中的注意事项

SSE 虽然简单，但在生产中需要注意以下几点：

• 反向代理配置：Nginx 需关闭缓冲并设置 proxy_buffering off;，否则消息延迟
• 连接超时：合理设置心跳或服务端定时发送注释消息（:ping\n\n）防止超时
• 客户端重连控制：EventSource 默认自动重连，可通过 onerror 判断是否需要手动终止
• 消息顺序与标识：可通过 id: 字段标记消息 ID，浏览器会记录最后接收的 ID，重连时通过 Last-Event-ID 请求头恢复

基本上就这些。SSE 技术门槛低、调试方便，特别适合不需要双向通信的实时场景。只要前后端配合好协议格式和连接管理，就能快速实现稳定的消息推送功能。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于文章的相关知识，也可关注golang学习网公众号。