首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >socket.io通过api调用向除“发件人”以外的所有人广播

socket.io通过api调用向除“发件人”以外的所有人广播
EN

Stack Overflow用户
提问于 2021-05-08 11:37:48
回答 1查看 101关注 0票数 0

我正在从客户端向服务器发出API调用,我也不想在websocket中发送消息。

当这种情况发生时,服务器向所有其他客户端广播的最佳方式是什么?

我在想,也许可以将客户机socketId附加到标头中,并在服务器上读取它,然后遍历所有连接的客户机并发送它们,类似于:

代码语言:javascript
运行
复制
Object.keys(io.sockets.sockets).forEach((socketId) => {
  if (socketId === socketIdFromHeader) return
  socket.broadcast.to(socketId).emit('message', 'my message');
});

我在这里看到了一些问题:

如果我有一个大规模的连接客户端,为每个客户端运行一个单独的函数将是很昂贵的。

你有什么想法吗?

谢谢!

PS。我是Socket.io和websockets的新手

EN

回答 1

Stack Overflow用户

发布于 2021-05-08 15:37:04

您需要知道您的API连接与您的web套接字连接完全不同。因此,如果您想向所有用户发送数据(发送方除外),您应该从usersId (您在socket.io连接和API中都可以访问的用户的任何标识)到用户套接字id存储一个映射。例如,将数据存储在redis中。要获得io连接中的用户,客户端可以发送查询字符串中的令牌,然后使用此令牌在数据库中找到用户,如果使用JWT,则对用户进行解码。

代码语言:javascript
运行
复制
io.on('connection', socket => {
    let user = await getUserUsingToken(socket.handshake.query.token);
    await redis.set(user._id, socket.id);
}

在api中,从Redis获取套接字id。

代码语言:javascript
运行
复制
let sid = await redis.get(user._id);
Object.keys(io.sockets.sockets).forEach((socketId) => {
  if (socketId === sid) return
  socket.broadcast.to(socketId).emit('message', 'my message');
});

您可以将此映射存储在任何您喜欢的地方。我刚才给你看了Redis的例子。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/67447104

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档