深入解析SSE技术从连接数限制到企业级解决方案实战在实际业务开发中实时消息推送是一个常见需求。SSEServer-Sent Events作为一种轻量级的服务器推送技术相比WebSocket具有更简单的实现方式和更好的浏览器兼容性。但在企业级应用中SSE面临着浏览器连接数限制、断线重连机制设计、消息去重等核心挑战。本文将围绕这些实际问题提供完整的解决方案和实战代码。本文适合有一定Web开发基础的读者特别是需要实现实时消息推送功能的后端开发者和全栈工程师。通过阅读本文你将掌握SSE的核心原理、连接数限制的破解方案、完整的断线重连机制设计以及生产环境中的最佳实践。1. SSE技术核心概念与应用场景1.1 什么是SSE技术SSEServer-Sent Events是一种允许服务器向客户端单向推送数据的技术规范。基于HTTP协议SSE使用简单的文本格式进行数据传输通过保持长连接实现实时消息推送。与WebSocket的双向通信不同SSE专注于服务器到客户端的单向数据流这在很多业务场景下更为适用。SSE的基本工作原理是客户端通过EventSource API建立与服务器的连接服务器通过保持HTTP连接开放持续发送数据流。每个消息以特定格式data:、event:、id:等前缀发送客户端自动解析这些消息并触发相应事件。1.2 SSE与WebSocket的技术对比在选择实时通信方案时开发者经常面临SSE与WebSocket的抉择。两者各有优劣适用于不同的业务场景。SSE的主要优势在于协议简单、自动重连、HTTP兼容性好。由于基于HTTP协议SSE可以轻松穿透大多数防火墙和代理服务器不需要特殊的协议升级处理。浏览器原生支持EventSource API开发复杂度较低。此外SSE内置了自动重连机制当连接异常断开时浏览器会自动尝试重新连接。WebSocket则提供真正的双向通信能力延迟更低适合需要频繁双向数据交换的场景如在线游戏、实时协作编辑等。但WebSocket协议相对复杂需要处理协议升级且在某些网络环境下可能遇到连接问题。1.3 SSE的典型应用场景SSE特别适合服务器主导的实时数据推送场景。常见的应用包括实时通知系统、股票行情推送、新闻资讯流、监控数据展示、聊天应用的消息接收端等。在这些场景中数据流向主要是从服务器到客户端SSE的轻量级特性能够提供良好的开发体验和性能表现。对于需要高频率更新的业务如实时监控仪表盘SSE能够以较小的开销维持长连接持续推送更新数据。在消息通知类应用中SSE的自动重连机制能够保证消息的可靠送达即使网络出现短暂波动也能恢复连接。2. SSE连接数限制问题深度分析2.1 浏览器连接数限制机制浏览器对同一域名的并发连接数存在限制这是HTTP/1.1协议的一个重要特性。现代浏览器通常允许6个并发连接指向同一域名超过这个数量的连接会被放入队列等待。对于SSE这种长连接技术每个连接都会占用一个并发名额这意味着如果页面中同时存在多个SSE连接很容易达到浏览器的连接数上限。这种限制源于HTTP/1.1的管线化pipelining设计旨在防止单个客户端占用过多服务器资源保证资源的公平分配。但在实时应用场景下这种限制成为了技术瓶颈。当连接数达到上限时新的SSE连接无法建立其他资源请求如图片、API调用也会被阻塞影响页面整体性能。2.2 连接数限制对业务的影响在实际业务中连接数限制会导致多种问题。最直接的影响是当需要建立多个实时数据流时部分连接无法正常建立导致数据丢失或延迟。例如一个监控仪表盘可能需要同时显示多个数据源的实时信息如果每个数据源都使用独立的SSE连接很容易触发连接数限制。此外连接数限制还会影响页面的其他网络请求。由于SSE连接是长连接它们会持续占用并发连接名额导致常规的AJAX请求、资源加载等操作被阻塞。这种阻塞效应在复杂的单页应用中尤为明显可能造成页面加载缓慢、交互响应延迟等问题。2.3 HTTP/2的解决方案HTTP/2协议通过多路复用Multiplexing技术从根本上解决了连接数限制问题。在HTTP/2中多个数据流可以共享同一个TCP连接每个流可以独立传输数据互不阻塞。这意味着浏览器对同一域名的连接数限制不再成为瓶颈多个SSE连接可以基于同一个TCP连接并行传输。HTTP/2的头部压缩HPACK和服务器推送Server Push等特性进一步优化了SSE的性能表现。头部压缩减少了每次通信的开销服务器推送允许服务器主动向客户端发送资源这些特性与SSE结合能够构建更高效的实时应用架构。3. 环境准备与版本说明3.1 后端技术栈选择本文将以Node.js为例演示SSE服务的实现同时提供其他常见技术栈的参考方案。Node.js的异步非阻塞特性非常适合处理大量并发连接是实现SSE服务的理想选择。基础环境要求包括Node.js 14.0及以上版本支持ES6语法特性。我们将使用Express框架构建HTTP服务器这是一个轻量级且广泛使用的Node.js Web框架。对于生产环境部署建议使用PM2等进程管理工具保证服务的稳定性。# 检查Node.js版本 node --version # 创建项目目录 mkdir sse-demo cd sse-demo # 初始化项目 npm init -y # 安装Express框架 npm install express3.2 前端开发环境前端部分使用原生JavaScript演示SSE客户端的实现确保最大的兼容性和可理解性。在实际项目中可以根据需要选择React、Vue等框架进行集成。开发环境需要现代浏览器的支持推荐Chrome 90、Firefox 88、Safari 14等版本这些浏览器对SSE和HTTP/2都有良好的支持。对于兼容性要求较高的项目需要提供降级方案或使用polyfill。3.3 测试工具准备为了全面测试SSE连接的各种场景需要准备相应的测试工具。Postman可以用于测试SSE接口的基本功能浏览器开发者工具用于监控网络连接状态Apache Bench或类似工具可以用于压力测试。对于HTTP/2的测试需要确保服务器和客户端都支持该协议。Nginx 1.9.5或Node.js 8.4.0版本都提供了HTTP/2支持。在开发过程中可以使用浏览器开发者工具的网络面板验证连接是否使用了HTTP/2协议。4. 基础SSE服务实现4.1 最简单的SSE服务器我们先从最基础的SSE服务器开始了解SSE协议的基本格式和实现原理。以下是一个使用Node.js和Express框架实现的最小SSE示例// server.js - 基础SSE服务器 const express require(express); const app express(); const port 3000; // 设置CORS头部允许跨域访问 app.use((req, res, next) { res.header(Access-Control-Allow-Origin, *); res.header(Access-Control-Allow-Headers, Origin, X-Requested-With, Content-Type, Accept); next(); }); // SSE路由端点 app.get(/events, (req, res) { // 设置SSE所需的响应头 res.writeHead(200, { Content-Type: text/event-stream, Cache-Control: no-cache, Connection: keep-alive, Access-Control-Allow-Origin: * }); // 发送初始连接成功消息 res.write(data: 连接成功\n\n); // 定期发送消息 let counter 0; const intervalId setInterval(() { counter; res.write(data: 服务器消息 ${counter} - ${new Date().toLocaleTimeString()}\n\n); // 模拟发送10条消息后停止 if (counter 10) { clearInterval(intervalId); res.write(data: 消息发送完成\n\n); res.end(); } }, 1000); // 客户端断开连接时清理资源 req.on(close, () { clearInterval(intervalId); console.log(客户端断开连接); }); }); app.listen(port, () { console.log(SSE服务器运行在 http://localhost:${port}); });4.2 SSE客户端实现客户端使用EventSource API连接SSE服务这是浏览器原生支持的SSE客户端接口!DOCTYPE html html head titleSSE客户端示例/title /head body h1SSE消息展示/h1 div idmessages/div script // 创建EventSource连接 const eventSource new EventSource(http://localhost:3000/events); const messagesContainer document.getElementById(messages); // 监听消息事件 eventSource.onmessage function(event) { const messageElement document.createElement(div); messageElement.textContent 收到消息: ${event.data}; messageElement.style.padding 5px; messageElement.style.borderBottom 1px solid #eee; messagesContainer.appendChild(messageElement); // 自动滚动到最新消息 messagesContainer.scrollTop messagesContainer.scrollHeight; }; // 监听连接打开事件 eventSource.onopen function(event) { console.log(连接已建立, event); }; // 监听错误事件 eventSource.onerror function(event) { console.error(连接错误, event); }; // 页面卸载时关闭连接 window.addEventListener(beforeunload, () { eventSource.close(); }); /script /body /html4.3 SSE消息格式详解SSE协议定义了特定的消息格式了解这些格式对于实现高级功能至关重要。每条SSE消息由多行文本组成每行以特定字段开头data:: 消息内容可以有多行data字段最终会合并为一个消息id:: 消息ID用于断线重连时的消息追踪event:: 事件类型默认是message可以自定义其他事件类型retry:: 重连时间间隔毫秒以下是一个包含多种字段的完整示例// 发送复杂SSE消息 app.get(/advanced-events, (req, res) { res.writeHead(200, { Content-Type: text/event-stream, Cache-Control: no-cache, Connection: keep-alive }); // 发送带ID的消息 res.write(id: 1001\n); res.write(data: 这是第一条消息\n); res.write(data: 这是消息的续行\n\n); // 发送自定义事件类型的消息 res.write(event: statusUpdate\n); res.write(data: {status: processing, progress: 50}\n\n); // 设置重连时间 res.write(retry: 3000\n\n); // 发送多行data字段的消息 res.write(id: 1002\n); res.write(event: userNotification\n); res.write(data: 重要通知系统将于今晚进行维护\n); res.write(data: 维护时间02:00-04:00\n\n); });5. HTTP/2多路复用解决连接数限制5.1 配置HTTP/2服务器要充分利用HTTP/2的多路复用特性需要配置支持HTTP/2的服务器。以下是使用Node.js原生HTTP/2模块的示例// http2-server.js - HTTP/2 SSE服务器 const http2 require(http2); const fs require(fs); // 读取SSL证书HTTP/2需要HTTPS const serverOptions { key: fs.readFileSync(localhost-privkey.pem), cert: fs.readFileSync(localhost-cert.pem) }; const server http2.createSecureServer(serverOptions); server.on(stream, (stream, headers) { const path headers[:path]; if (path /events) { // 设置SSE响应头 stream.respond({ content-type: text/event-stream, cache-control: no-cache, :status: 200 }); // 发送SSE消息 let messageCount 0; const interval setInterval(() { messageCount; stream.write(data: HTTP/2消息 ${messageCount}\n\n); if (messageCount 20) { clearInterval(interval); stream.end(); } }, 1000); stream.on(close, () { clearInterval(interval); }); } }); server.listen(8443, () { console.log(HTTP/2 SSE服务器运行在 https://localhost:8443); });5.2 Nginx HTTP/2配置对于生产环境通常使用Nginx作为反向代理来提供HTTP/2支持# nginx.conf - HTTP/2 SSE代理配置 server { listen 443 ssl http2; server_name your-domain.com; ssl_certificate /path/to/your-cert.pem; ssl_certificate_key /path/to/your-private-key.pem; # HTTP/2优化配置 http2_max_concurrent_streams 100; http2_streams_index_size 100; http2_recv_timeout 300s; location /events { proxy_pass http://backend-sse-server:3000; proxy_buffering off; proxy_cache off; # 保持长连接相关配置 proxy_set_header Connection ; proxy_http_version 1.1; chunked_transfer_encoding off; # 超时设置 proxy_read_timeout 86400s; proxy_send_timeout 86400s; } }5.3 多路复用连接测试建立HTTP/2连接后可以创建多个SSE连接测试多路复用效果// 测试多个SSE连接 function createMultipleSSEConnections() { const connections []; // 创建5个SSE连接 for (let i 0; i 5; i) { const eventSource new EventSource(https://localhost:8443/events); eventSource.onmessage function(event) { console.log(连接${i}:, event.data); }; connections.push(eventSource); } return connections; } // 验证HTTP/2连接 function checkHTTP2Support() { const protocol performance.getEntriesByType(navigation)[0].nextHopProtocol; console.log(使用的协议:, protocol); if (protocol h2) { console.log(HTTP/2连接已建立多路复用功能可用); } else { console.log(使用HTTP/1.1注意连接数限制); } }6. 断线重连机制设计与实现6.1 自动重连基础实现SSE协议内置了自动重连机制但默认实现较为简单。通过合理配置可以增强重连的可靠性// 增强型SSE客户端 class EnhancedEventSource { constructor(url, options {}) { this.url url; this.options options; this.reconnectAttempts 0; this.maxReconnectAttempts options.maxReconnectAttempts || 5; this.reconnectInterval options.reconnectInterval || 3000; this.eventSource null; this.isConnected false; this.connect(); } connect() { try { this.eventSource new EventSource(this.url); this.eventSource.onopen () { console.log(SSE连接已建立); this.isConnected true; this.reconnectAttempts 0; if (this.options.onOpen) { this.options.onOpen(); } }; this.eventSource.onmessage (event) { if (this.options.onMessage) { this.options.onMessage(event); } }; this.eventSource.onerror (event) { console.error(SSE连接错误, event); this.isConnected false; this.handleReconnection(); }; } catch (error) { console.error(创建EventSource失败:, error); this.handleReconnection(); } } handleReconnection() { if (this.reconnectAttempts this.maxReconnectAttempts) { console.error(重连尝试超过${this.maxReconnectAttempts}次停止重连); if (this.options.onMaxRetries) { this.options.onMaxRetries(); } return; } this.reconnectAttempts; console.log(第${this.reconnectAttempts}次重连尝试${this.reconnectInterval}ms后执行); setTimeout(() { if (this.eventSource) { this.eventSource.close(); } this.connect(); }, this.reconnectInterval); // 指数退避策略 this.reconnectInterval Math.min( this.reconnectInterval * 1.5, 30000 // 最大重连间隔30秒 ); } close() { if (this.eventSource) { this.eventSource.close(); this.eventSource null; } this.isConnected false; } } // 使用示例 const sseClient new EnhancedEventSource(/events, { maxReconnectAttempts: 10, reconnectInterval: 2000, onMessage: (event) { console.log(收到消息:, event.data); }, onOpen: () { console.log(连接成功建立); }, onMaxRetries: () { console.log(达到最大重连次数需要用户干预); } });6.2 基于Last-Event-ID的消息恢复SSE协议支持通过Last-Event-ID头部实现消息恢复确保断线期间的消息不丢失// 服务端支持Last-Event-ID的SSE实现 app.get(/resumable-events, (req, res) { const lastEventId req.headers[last-event-id] || 0; console.log(客户端最后收到的消息ID: ${lastEventId}); res.writeHead(200, { Content-Type: text/event-stream, Cache-Control: no-cache, Connection: keep-alive }); // 模拟消息存储生产环境使用数据库 const messageStore [ { id: 1, data: 消息1, timestamp: Date.now() - 5000 }, { id: 2, data: 消息2, timestamp: Date.now() - 4000 }, { id: 3, data: 消息3, timestamp: Date.now() - 3000 }, { id: 4, data: 消息4, timestamp: Date.now() - 2000 }, { id: 5, data: 消息5, timestamp: Date.now() - 1000 } ]; // 发送断线期间错过的消息 const lastIdNum parseInt(lastEventId); const missedMessages messageStore.filter(msg parseInt(msg.id) lastIdNum); missedMessages.forEach(msg { res.write(id: ${msg.id}\n); res.write(data: 补发消息: ${msg.data}\n\n); }); // 继续发送新消息 let currentId messageStore.length; const intervalId setInterval(() { currentId; const newMessage 实时消息 ${currentId}; res.write(id: ${currentId}\n); res.write(data: ${newMessage}\n\n); // 存储消息用于后续恢复 messageStore.push({ id: currentId.toString(), data: newMessage, timestamp: Date.now() }); // 清理旧消息保持最近100条 if (messageStore.length 100) { messageStore.splice(0, messageStore.length - 100); } }, 2000); req.on(close, () { clearInterval(intervalId); }); });6.3 心跳检测与连接健康监控为了确保连接的稳定性需要实现心跳检测机制// 带心跳检测的SSE服务 app.get(/heartbeat-events, (req, res) { res.writeHead(200, { Content-Type: text/event-stream, Cache-Control: no-cache, Connection: keep-alive }); let isConnected true; let lastActivity Date.now(); // 心跳检测 const heartbeatInterval setInterval(() { if (!isConnected) { clearInterval(heartbeatInterval); return; } const now Date.now(); // 如果30秒内没有活动发送心跳 if (now - lastActivity 30000) { res.write(event: heartbeat\n); res.write(data: JSON.stringify({ timestamp: now }) \n\n); } }, 5000); // 业务消息发送 const messageInterval setInterval(() { if (!isConnected) { clearInterval(messageInterval); return; } lastActivity Date.now(); res.write(data: 业务消息 ${new Date().toISOString()}\n\n); }, 10000); // 连接状态监控 req.on(close, () { isConnected false; clearInterval(heartbeatInterval); clearInterval(messageInterval); console.log(客户端断开连接); }); });7. 消息去重与顺序保证机制7.1 基于消息ID的去重方案在断线重连场景下消息去重是确保数据一致性的关键。以下实现基于消息ID的去重机制// 客户端消息去重管理器 class MessageDeduplication { constructor() { this.receivedMessageIds new Set(); this.maxStoredIds 1000; // 最大存储ID数量 this.windowSize 100; // 滑动窗口大小 } // 检查消息是否重复 isDuplicate(messageId) { if (!messageId) return false; if (this.receivedMessageIds.has(messageId)) { console.log(检测到重复消息: ${messageId}); return true; } this.addMessageId(messageId); return false; } // 添加消息ID addMessageId(messageId) { this.receivedMessageIds.add(messageId); // 维护滑动窗口防止内存无限增长 if (this.receivedMessageIds.size this.maxStoredIds) { const idsArray Array.from(this.receivedMessageIds); // 保留最新的windowSize个ID this.receivedMessageIds new Set( idsArray.slice(-this.windowSize) ); } } // 重置去重状态用于重新连接 reset() { this.receivedMessageIds.clear(); } } // 集成去重功能的SSE客户端 class DeduplicatedEventSource { constructor(url, options {}) { this.url url; this.options options; this.deduplicator new MessageDeduplication(); this.lastReceivedId null; this.eventSource null; this.setupEventSource(); } setupEventSource() { this.eventSource new EventSource(this.url); this.eventSource.onmessage (event) { const messageId event.lastEventId; // 去重检查 if (this.deduplicator.isDuplicate(messageId)) { return; // 跳过重复消息 } this.lastReceivedId messageId; if (this.options.onMessage) { this.options.onMessage(event); } }; this.eventSource.addEventListener(reconnect, (event) { // 重连时设置Last-Event-ID this.eventSource.close(); this.setupEventSourceWithLastId(); }); } setupEventSourceWithLastId() { // 创建带Last-Event-ID头部的自定义EventSource const xhr new XMLHttpRequest(); xhr.open(GET, this.url); xhr.setRequestHeader(Accept, text/event-stream); xhr.setRequestHeader(Cache-Control, no-cache); if (this.lastReceivedId) { xhr.setRequestHeader(Last-Event-ID, this.lastReceivedId); } // 模拟EventSource行为 // ... 简化实现实际项目需要完整模拟SSE协议 } }7.2 服务端消息序列化管理确保消息顺序的一致性需要服务端的配合// 服务端消息序列化管理器 class MessageSequencer { constructor() { this.sequenceNumbers new Map(); // clientId - lastSequence this.messageQueue new Map(); // clientId - message[] } // 为客户端生成序列号 getNextSequence(clientId) { let currentSeq this.sequenceNumbers.get(clientId) || 0; currentSeq; this.sequenceNumbers.set(clientId, currentSeq); return currentSeq; } // 添加消息到队列 queueMessage(clientId, message) { if (!this.messageQueue.has(clientId)) { this.messageQueue.set(clientId, []); } const sequence this.getNextSequence(clientId); const sequencedMessage { sequence, message, timestamp: Date.now() }; this.messageQueue.get(clientId).push(sequencedMessage); // 清理旧消息 this.cleanupOldMessages(clientId); return sequencedMessage; } // 获取从指定序列号开始的消息 getMessagesFromSequence(clientId, fromSequence) { const messages this.messageQueue.get(clientId) || []; return messages.filter(msg msg.sequence fromSequence); } // 清理过期消息 cleanupOldMessages(clientId, maxAge 300000) { // 5分钟 const messages this.messageQueue.get(clientId); if (!messages) return; const now Date.now(); const freshMessages messages.filter(msg now - msg.timestamp maxAge ); this.messageQueue.set(clientId, freshMessages); } } // 使用序列化管理的SSE服务 const sequencer new MessageSequencer(); app.get(/sequenced-events, (req, res) { const clientId req.query.clientId || req.ip; const lastSequence parseInt(req.headers[last-event-sequence]) || 0; res.writeHead(200, { Content-Type: text/event-stream, Cache-Control: no-cache, Connection: keep-alive }); // 发送错过的消息 const missedMessages sequencer.getMessagesFromSequence(clientId, lastSequence 1); missedMessages.forEach(msg { res.write(id: ${msg.sequence}\n); res.write(data: ${JSON.stringify(msg.message)}\n\n); }); // 定时发送新消息 const intervalId setInterval(() { const newMessage { content: 序列消息 ${Date.now()}, type: update }; const sequencedMessage sequencer.queueMessage(clientId, newMessage); res.write(id: ${sequencedMessage.sequence}\n); res.write(data: ${JSON.stringify(sequencedMessage.message)}\n\n); }, 5000); req.on(close, () { clearInterval(intervalId); }); });8. 生产环境最佳实践8.1 性能优化策略在生产环境中部署SSE服务需要考虑性能优化// 高性能SSE服务配置 const cluster require(cluster); const numCPUs require(os).cpus().length; if (cluster.isMaster) { // 主进程创建工作进程 for (let i 0; i numCPUs; i) { cluster.fork(); } cluster.on(exit, (worker, code, signal) { console.log(工作进程 ${worker.process.pid} 已退出); cluster.fork(); // 重新启动工作进程 }); } else { // 工作进程创建SSE服务 const express require(express); const app express(); // 连接管理 const connections new Set(); app.get(/scalable-events, (req, res) { // SSE头设置 res.writeHead(200, { Content-Type: text/event-stream, Cache-Control: no-cache, Connection: keep-alive, Content-Encoding: none // 禁用压缩避免缓冲延迟 }); // 添加连接到管理集合 connections.add(res); // 发送初始消息 res.write(data: 连接建立成功\n\n); // 连接关闭时清理 req.on(close, () { connections.delete(res); }); }); // 广播消息到所有连接 function broadcastMessage(message) { connections.forEach(connection { try { connection.write(data: ${JSON.stringify(message)}\n\n); } catch (error) { // 移除无效连接 connections.delete(connection); } }); } // 定期广播系统状态 setInterval(() { broadcastMessage({ type: system_status, connections: connections.size, memory: process.memoryUsage(), timestamp: Date.now() }); }, 30000); app.listen(3000, () { console.log(工作进程 ${process.pid} 已启动); }); }8.2 安全考虑与防护措施SSE服务的安全防护是生产环境的重要考量// 安全增强的SSE中间件 const rateLimit require(express-rate-limit); const helmet require(helmet); // 基础安全防护 app.use(helmet({ contentSecurityPolicy: { directives: { defaultSrc: [self], connectSrc: [self, https://your-domain.com] } } })); // SSE连接频率限制 const sseLimiter rateLimit({ windowMs: 1 * 60 * 1000, // 1分钟 max: 10, // 每分钟最多10个SSE连接 message: 连接频率过高请稍后重试, skipSuccessfulRequests: false }); app.use(/events, sseLimiter); // 认证中间件 function authenticateSSE(req, res, next) { const token req.headers[authorization]?.replace(Bearer , ); if (!token) { return res.status(401).send(需要认证); } // 验证token逻辑简化示例 try { const decoded verifyToken(token); // 自定义token验证 req.user decoded; next(); } catch (error) { res.status(401).send(认证失败); } } // 需要认证的SSE端点 app.get(/secure-events, authenticateSSE, (req, res) { const userId req.user.id; res.writeHead(200, { Content-Type: text/event-stream, Cache-Control: no-cache, Connection: keep-alive }); // 基于用户ID的个性化消息流 const userMessageInterval setInterval(() { res.write(data: 用户${userId}的专属消息 ${new Date().toISOString()}\n\n); }, 5000); req.on(close, () { clearInterval(userMessageInterval); }); });8.3 监控与日志记录完善的监控体系是保证服务稳定性的关键// SSE服务监控配置 const monitoring { connections: 0, messagesSent: 0, errors: 0, reconnections: 0 }; // 监控中间件 app.use((req, res, next) { if (req.path.includes(/events)) { monitoring.connections; console.log(新的SSE连接当前连接数: ${monitoring.connections}); } next(); }); // 健康检查端点 app.get(/health, (req, res) { res.json({ status: healthy, connections: monitoring.connections, messagesSent: monitoring.messagesSent, uptime: process.uptime(), memory: process.memoryUsage() }); }); // 监控数据导出 app.get(/metrics, (req, res) { res.set(Content-Type, text/plain); res.send( # HELP sse_connections Current SSE connections # TYPE sse_connections gauge sse_connections ${monitoring.connections} # HELP sse_messages_total Total messages sent # TYPE sse_messages_total counter sse_messages_total ${monitoring.messagesSent} # HELP sse_errors_total Total errors occurred # TYPE sse_errors_total counter sse_errors_total ${monitoring.errors} ); }); // 优雅关闭处理 process.on(SIGTERM, () { console.log(收到SIGTERM信号开始优雅关闭); // 通知客户端服务即将关闭 broadcastMessage({ type: system, message: 服务即将维护请保存当前状态 }); setTimeout(() { console.log(服务关闭完成); process.exit(0); }, 5000); });9. 常见问题与解决方案9.1 连接建立失败问题排查SSE连接建立失败的常见原因及解决方案问题现象可能原因解决方案无法建立连接CORS策略限制配置正确的CORS头部连接立即断开服务器响应格式错误检查Content-Type是否为text/event-stream部分消息丢失浏览器缓冲机制禁用缓冲或发送心跳包重连频繁触发网络不稳定调整重连策略增加超时时间// 连接问题诊断工具 function diagnoseSSEConnection(url) { const startTime Date.now(); const eventSource new EventSource(url); eventSource.onopen () { const connectTime Date.now() - startTime; console.log(连接建立成功耗时: ${connectTime}ms); }; eventSource.onerror (event) { console.error(连接错误详情:, { eventType: event.type, readyState: eventSource.readyState, url: url }); // 详细的错误分类 if (eventSource.readyState EventSource.CONNECTING) { console.log(连接正在建立中...); } else if (eventSource.readyState EventSource.CLOSED) { console.log(连接已关闭); } }; // 测试消息接收 eventSource.onmessage (event) { console.log(收到测试消息:, event.data); }; // 5秒