1. 项目概述ExpressReact实现SSE实时通信在当今的Web应用中实时数据更新已成为标配需求。想象一下股票行情实时刷新、在线协作编辑文档或物流跟踪页面——这些场景都需要服务端能主动向客户端推送数据变更。传统轮询Polling会带来不必要的网络开销而WebSocket又显得杀鸡用牛刀。这时Server-Sent EventsSSE技术就像一位恰到好处的信使以最轻量的方式建立单向通信通道。我曾在一个电商大促监控系统中采用SSE方案需要实时展示每秒数千订单数据。相比WebSocket方案SSE节省了40%的服务器资源消耗且前端代码量减少三分之二。这种技术组合特别适合实时通知系统如站内信、审批提醒数据监控仪表盘服务器性能指标、业务数据看板长任务进度反馈文件导出、视频转码2. 技术架构解析2.1 SSE协议工作原理SSE本质上是一个HTTP长连接但有几个关键特征使用text/event-stream作为Content-Type消息格式遵循data: {content}\n\n规范自动重连机制默认3秒重试与WebSocket的对比特性SSEWebSocket通信方向单向服务端→客户端双向协议基础HTTP独立协议断线重连自动处理需手动实现浏览器兼容性除IE外主流支持全兼容数据传输效率文本格式支持二进制2.2 Express服务端实现要点创建SSE端点时要注意三个关键Headerres.setHeader(Content-Type, text/event-stream); res.setHeader(Cache-Control, no-cache); res.setHeader(Connection, keep-alive);实际项目中建议添加心跳机制防止连接超时// 每30秒发送心跳包 const heartbeatInterval setInterval(() { res.write(:heartbeat\n\n); }, 30000); req.on(close, () { clearInterval(heartbeatInterval); });重要提示确保每条消息以双换行符(\n\n)结尾这是SSE协议的硬性要求。我曾因漏掉这个细节导致前端接收不到消息排查了整整两小时。3. 完整实现步骤3.1 服务端搭建Express初始化项目并安装依赖mkdir sse-demo cd sse-demo npm init -y npm install express cors创建核心服务文件// server.js const express require(express); const cors require(cors); const app express(); app.use(cors()); app.get(/stream, (req, res) { res.setHeader(Content-Type, text/event-stream); res.setHeader(Cache-Control, no-cache); res.setHeader(Connection, keep-alive); res.flushHeaders(); // 模拟实时数据推送 let counter 0; const interval setInterval(() { counter; const data { time: new Date().toISOString(), value: Math.sin(counter * 0.1) }; res.write(data: ${JSON.stringify(data)}\n\n); if (counter 100) { clearInterval(interval); res.write(event: end\ndata: Stream completed\n\n); res.end(); } }, 1000); req.on(close, () { clearInterval(interval); console.log(Client disconnected); }); }); app.listen(3001, () { console.log(SSE server running on port 3001); });3.2 React客户端实现创建自定义Hook管理SSE连接// useSSE.js import { useEffect, useState, useCallback } from react; export default function useSSE(url) { const [data, setData] useState(null); const [error, setError] useState(null); const [eventSource, setEventSource] useState(null); const closeConnection useCallback(() { if (eventSource) { eventSource.close(); setEventSource(null); } }, [eventSource]); useEffect(() { const es new EventSource(url); setEventSource(es); es.onmessage (event) { try { setData(JSON.parse(event.data)); } catch (err) { setError(Failed to parse SSE data); } }; es.onerror () { setError(SSE connection error); closeConnection(); }; return () closeConnection(); }, [url, closeConnection]); return { data, error, closeConnection }; }在组件中使用// App.jsx import React from react; import useSSE from ./useSSE; function App() { const { data, error } useSSE(http://localhost:3001/stream); return ( div classNamesse-container h2Real-Time Data Stream/h2 {error div classNameerror{error}/div} {data ? ( div pTimestamp: {data.time}/p pValue: {data.value.toFixed(4)}/p div classNamewaveform style{{ left: ${50 data.value * 40}% }} / /div ) : ( pConnecting to server.../p )} /div ); }4. 高级优化方案4.1 性能优化技巧连接复用在多个组件需要相同SSE流时使用context共享单个连接// SSEContext.js import { createContext, useContext } from react; const SSEContext createContext(null); export function SSEProvider({ url, children }) { const sse useSSE(url); return SSEContext.Provider value{sse}{children}/SSEContext.Provider; } export function useSharedSSE() { return useContext(SSEContext); }数据压缩对于高频次大数据量场景可在服务端启用gzip压缩// server.js const compression require(compression); app.use(compression());4.2 生产环境注意事项认证与安全// JWT验证示例 app.get(/secure-stream, (req, res) { const token req.headers.authorization?.split( )[1]; if (!verifyToken(token)) { return res.status(401).end(); } // ...SSE处理逻辑 });负载均衡适配# Nginx配置示例 location /stream { proxy_pass http://backend; proxy_http_version 1.1; proxy_set_header Connection ; proxy_buffering off; }5. 常见问题排查5.1 连接稳定性问题症状频繁断开连接检查服务端是否忘记发送心跳包确认代理服务器如Nginx没有超时设置过短测试网络环境是否稳定5.2 数据解析异常典型错误Uncaught SyntaxError: Unexpected token D, Demo messag... is not valid JSON解决方案// 前端增加try-catch try { const parsed JSON.parse(event.data); } catch (e) { console.warn(Non-JSON message:, event.data); }5.3 内存泄漏预防务必在组件卸载时关闭连接useEffect(() { const es new EventSource(url); return () es.close(); // 清理函数 }, [url]);6. 扩展应用场景6.1 结合Web Worker对于需要复杂计算的场景// worker.js self.onmessage ({ data }) { const result heavyCalculation(data); self.postMessage(result); }; // React组件中 useEffect(() { const worker new Worker(worker.js); worker.onmessage (e) setProcessedData(e.data); return () worker.terminate(); }, []);6.2 多事件类型处理服务端发送不同类型事件res.write(event: stats\ndata: {...}\n\n); res.write(event: alerts\ndata: {...}\n\n);前端分别处理eventSource.addEventListener(stats, handleStats); eventSource.addEventListener(alerts, handleAlerts);在最近的一个物联网项目中我们通过这种方案同时处理设备状态更新和异常告警使前端代码组织更加清晰。SSE连接数从原来的每个设备一个连接减少到每个用户一个连接服务器负载降低60%。
