不同客户端接收消息的SSE
创始人
2025-01-09 06:30:07
0

以下是一个使用Node.js和Express框架来实现SSE(Server-Sent Events)的示例代码:

const express = require('express');
const app = express();

// 用于存储连接的客户端
let clients = [];

// SSE路由
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('Access-Control-Allow-Origin', '*');

  // 发送初始数据给客户端
  res.write('data: Connected\n\n');

  // 添加客户端到数组
  clients.push(res);

  // 当客户端关闭连接时,从数组中移除
  req.on('close', () => {
    clients = clients.filter(client => client !== res);
  });
});

// 定期向所有客户端发送消息
setInterval(() => {
  const message = new Date().toLocaleTimeString();

  // 向所有客户端发送消息
  clients.forEach(client => {
    client.write(`data: ${message}\n\n`);
  });
}, 1000);

// 启动服务器
const port = 3000;
app.listen(port, () => {
  console.log(`Server started on port ${port}`);
});

这个示例代码创建了一个SSE路由/sse,客户端可以通过访问该路由来建立SSE连接。当一个客户端连接时,它会被添加到clients数组中,当客户端关闭连接时,它会从数组中移除。

服务器会每秒向所有客户端发送一个带有当前时间的消息。在setInterval函数中,可以根据自己的需求更改发送的消息内容和频率。

要运行这个示例代码,需要先安装Node.js和Express(使用npm install express命令)。然后,将代码保存到一个名为app.js的文件中,并使用node app.js命令来启动服务器。最后,通过访问http://localhost:3000/sse来与服务器建立SSE连接。

相关内容

热门资讯

透视智能ai!同城游微信游戏辅... >>您好:同城游微信游戏辅助确实是有挂的,很多玩家在这款同城游微信游戏辅助游戏中打牌都会发现很多用户...
透明工具!陕西三带辅助,wep... 透明工具!陕西三带辅助,wepoker黑侠辅助器正版下载(辅助挂)详细开挂辅助插件;无需打开直接搜索...
透明肯定!越乡游义乌透视下载,... 您好:这款wepoker私人局有透视吗游戏是可以开挂的,确实是有挂的,很多玩家在这款wepoker私...
透视美元局!来物局潮汕辅助,智... 透视美元局!来物局潮汕辅助,智星菠萝可以辅助吗(辅助挂)详细开挂辅助脚本;无需打开直接搜索加薇136...
透明教学!小闲川南破解器,wp... 您好:这款wpk俱乐部怎么作弊游戏是可以开挂的,确实是有挂的,很多玩家在这款wpk俱乐部怎么作弊游戏...
透视数据!wepoker怎么破... wepoker怎么破解游戏是一款可以让一直输的玩家,快速成为一个“必胜”的ai辅助神器,有需要的用户...
透视线上!雀友会辅助潮汕麻将脚... 雀友会辅助潮汕麻将脚本开挂教程视频分享装挂详细步骤在当今的网络游戏中,雀友会辅助潮汕麻将脚本作为一种...
透明神器!四川游戏家园破解,w... wepoker买脚本靠谱吗是一款专注玩家量身打造的游戏记牌类型软件,在wepoker买脚本靠谱吗这款...
透视存在!微信小程序自动透视免... 大家好,今天小编来为大家解答约局吧德州真的有透视挂吗这个问题咨询软件客服可以免费测试直接加微信(13...
透视好友!家乡大二辅助,we-... 透视好友!家乡大二辅助,we-poker靠谱吗(辅助挂)详细开挂辅助器;打开点击测试直接进入微信(1...