当前位置: 首页 > news >正文

NodeJS搭建SSE接口服务

下面是一个基于Node.js的SSE(Server-Sent Events)接口服务的实现。这个示例使用Express框架搭建服务器,支持客户端订阅事件流并实时接收服务器推送的数据。

const express = require('express');
const cors = require('cors');
const { v4: uuidv4 } = require('uuid');const app = express();
const PORT = 3000;// 中间件
app.use(cors());
app.use(express.json());// 存储客户端连接
const clients = new Map();// SSE 接口
app.get('/sse', (req, res) => {// 设置 SSE 响应头res.setHeader('Content-Type', 'text/event-stream');res.setHeader('Cache-Control', 'no-cache');res.setHeader('Connection', 'keep-alive');res.flushHeaders();// 生成客户端ID并存储连接const clientId = uuidv4();const client = {id: clientId,res};clients.set(clientId, client);// 发送初始消息sendEvent(clientId, { type: 'connected', data: { clientId } });// 处理客户端断开连接req.on('close', () => {clients.delete(clientId);console.log(`Client ${clientId} disconnected`);});
});// 向特定客户端发送事件
function sendEvent(clientId, event) {const client = clients.get(clientId);if (client) {client.res.write(`data: ${JSON.stringify(event)}\n\n`);}
}// 向所有客户端广播事件
function broadcastEvent(event) {clients.forEach(client => {client.res.write(`data: ${JSON.stringify(event)}\n\n`);});
}// 模拟定时推送数据
setInterval(() => {broadcastEvent({type: 'update',data: {timestamp: new Date().toISOString(),message: '定时更新数据'}});
}, 5000);// 手动触发推送接口
app.post('/trigger', (req, res) => {const { message } = req.body;broadcastEvent({type: 'manual',data: {timestamp: new Date().toISOString(),message}});res.json({ success: true });
});// 启动服务器
app.listen(PORT, () => {console.log(`Server running on port ${PORT}`);
});

代码说明:

  1. 依赖安装

    npm install express cors uuid
    
  2. 核心功能

    • SSE连接管理:使用Map存储所有客户端连接,每个连接有唯一ID。
    • 事件发送
      • sendEvent(clientId, event):向特定客户端发送事件。
      • broadcastEvent(event):向所有客户端广播事件。
    • 响应头设置
      Content-Type: text/event-stream
      Cache-Control: no-cache
      Connection: keep-alive
      
  3. 接口说明

    • GET /sse:客户端订阅SSE流的入口。
    • POST /trigger:手动触发向所有客户端推送消息(需提供message字段)。
  4. 客户端示例

    const eventSource = new EventSource('http://localhost:3000/sse');eventSource.onmessage = (event) => {const data = JSON.parse(event.data);console.log('收到消息:', data);
    };eventSource.onerror = (error) => {console.error('SSE连接错误:', error);
    };
    

特性与扩展:

  • 心跳机制:可添加定期发送心跳消息以保持连接。
  • 错误处理:包含基本的连接断开处理。
  • 事件类型:支持不同类型的事件(connected, update, manual)。
  • 安全增强:可添加身份验证、权限控制等。

这个实现提供了SSE服务的基础框架,你可以根据具体需求扩展其功能,如添加用户认证、事件过滤、持久化存储等。

http://www.dtcms.com/a/297339.html

相关文章:

  • 深入解析Hadoop MapReduce中Reduce阶段排序的必要性
  • ⭐ Unity 编辑器扩展:简单自动合并多个 Mesh 并导出为 .asset
  • 通过kettle获取API数据
  • 虚拟机docker elasticsearch启动失败
  • JMeter每次压测前清除全部以确保异常率准确(以黑马点评为例、详细图解)
  • 如何提高微信小程序的应用速度
  • 数据赋能(332)——安全与合规——保密管理
  • RocketMQ5.3.1的安装
  • C 语言数组深度解析:从内存布局到安全实践的全维度指南
  • 二开---01
  • 什么是FCR,如何提升FCR?
  • Springboot3.0 集成 RocketMQ5
  • linux配置ntp时间同步
  • 告别虚函数性能焦虑:深入剖析C++多态的现代设计模式
  • Go 官方 Elasticsearch 客户端 v9 快速上手与进阶实践*
  • 银河麒麟安装软件商店方法
  • 《设计模式之禅》笔记摘录 - 10.装饰模式
  • vue项目入门
  • PostgreSQL对象权限管理
  • 全新轻量化PHP网盘搜索引擎系统源码
  • 常用设计模式系列(十三)—组合模式
  • Oracle 的单体安装
  • Android Room 持久化库:简化数据库操作
  • Kingbasepostgis 安装实践
  • GaussDB 逻辑备份实操
  • AR眼镜重塑外科手术导航:精准“透视”新突破
  • Elasticsearch-8.17.0 centos7安装
  • 《Angular+Spring Boot:ERP前端采购销售库存协同架构解析》
  • AR与AI融合:医疗诊断的智能新引擎
  • 解决angular与jetty websocket 每30s自动断连的问题