socket.emit 没有在 post 请求中触发

Question

我将io.on('connection', function (socket) { 包裹在一个帖子请求中。然后我在帖子请求中调用socket.emit('news', 'username taken');。出于某种原因，当我进行此调用时，它不会向客户端发送任何内容。当我将发射更改为io.emit('connection', function (socket)) 它工作并将数据发送到客户端。我对该解决方案的问题是使用 io.emit 会将数据发送到所有连接的套接字。我的问题是如何在这个帖子请求中使用 socket.emit。

io.on('connection', onConnection);

function onConnection(sock) {
 sock.emit('news', 'username is taken');
}

app.post('/signup', function(req, res) {

    var userDetails = User({
        firstname: req.body.firstname,
        username: req.body.username,
        email: req.body.email,
        password: bcrypt.hashSync(req.body.password1, bcrypt.genSaltSync(10))
    });

    User.findOne({
        $or: [ { 'username': req.body.username}, {'email': req.body.email}]
    }, function(err, user) {
        if (user) {
              if(user.username === req.body.username){
              onConnection();
              console.log('username is taken');
            } else {
            }
            if(user.email === req.body.email){
              console.log('email is taken')
            } else {
            }
        } else {
          userDetails.save(function(err) {
            if (err) throw err;
          });
          res.redirect('/');
          console.log('change to login')
        }
        if (err) {
            return done(err);
        }
    });

   });

});

Answer 1

解决此问题的常用方法是使用会话中间件，该中间件会在加载网站的第一页时建立用户会话。然后，当用户连接到 socket.io 时，您会将 socket.id 放入该用户的会话中。然后，当您获得app.post() 并且想要发送到他们的socket.io 连接时，您将在会话中查找该用户，获取该用户的socket.id，然后使用它查找套接字。获得套接字后，您可以向他们发送消息。

您使用会话连接 socket.io 连接和app.post()。没有在另一个事件处理程序中设置事件处理程序。

Answer 2

我刚刚解决了我的问题。我所做的是创建一个名为 socket1 的变量。然后我在 io.on 匿名函数中将 socket 参数分配给 socket1。然后，我将套接字作为通用变量，我可以在代码中的任何位置调用它。我不确定这在编程上是否正确，但它有效。

var SOCKET_LIST = {};

var socket1;

io.on('connection', function (socket) {
    SOCKET_LIST[socket.id] = socket;
    socket1 = socket;
    socket.emit('news', 'username taken');
});

app.post('/signup', function(req, res) {

var userDetails = User({
    firstname: req.body.firstname,
    username: req.body.username,
    email: req.body.email,
    password: bcrypt.hashSync(req.body.password1, bcrypt.genSaltSync(10))
});

User.findOne({
    $or: [ { 'username': req.body.username}, {'email': req.body.email}]
}, function(err, user) {
    if (user) {
        if(user.username === req.body.username){
          socket1.emit('news', 'username taken');
          console.log('username is taken');
        } else {
        }
        if(user.email === req.body.email){
          io.emit('news', 'email taken');
          console.log('email is taken')
        } else {
        }
    } else {
      userDetails.save(function(err) {
        if (err) throw err;
      });
      res.redirect('/');
      console.log('change to login')
    }
    if (err) {
        return done(err);
    }
});

});