如何在节点应用程序中使用 Socket.io 向所有订阅者发送数据

Question

这是事后路线。当用户发布事件时，该事件应发送给其所有关注者！ 我为此维护了 Follower Array。

如何使用 Socket.io ????

 module.exports.postEvent = (req,res) => {
       Events.saveEvent(req.body , (err,saveEvent)=>{
          var response = {
              status : 500,
              message : err
          };
          var id = req.userId;
          if(err){
              res.status(response.status)
                  .json(response.message);
          }else {
              // find the data of user from token and
                user.getuserbyname(id ,(err,user)=>{
                    if(err){
                        res.status(response.status)
                            .json(response.message);
                    }else{

                        // send to all user subscribers via socket.io
                        async.each(user.followers ,(id , callback)=>{

                         what will be the code here???


                        })
                    }
              })
          }
      })
    };

Answer 1

在设置io 服务器时附加io instance to your app。

app.io = io;

然后可以通过请求对象获得

router.post('/event', function(req, res){
  req.app.io.emit('message', data)
})

默认房间

每个套接字连接都有一个由其Socket#id 标识的"Default Room"。

你可以在你的请求处理程序中发送到那个房间：

req.app.io.to(socket_id).emit('my message', msg)

或通过套接字 io 处理程序中的套接字：

socket.broadcast.to(socket_id).emit('my message', msg)

房间

SocketIO 还提供了Rooms 的概念。您可以将套接字join 和leave 设置为一个房间，然后发射到该房间，而不是自己管理订阅数组。

io.on('connection', function(socket){
  socket.join(`room:${user}`)
})

io.to(`room:${user}`).emit('my message', msg)