node.js - 如何使用 socket.io 从 Controller 而不是建立连接的文件发出一些数据

Question

在我的 nodejs 服务器中，我连接了 socket.io 和 mongodb 并且前面是在 rectjs 中。我已经连接了 socket.io 并发出或监听更改，但我想监听添加到数据库中的每个新用户，然后发出所有关于发生的事情。我已经制作了用户登录的 API，我希望每当新用户在该 Controller 中登录，socket.io 应该监听然后发出有关用户的信息。

我在 app.js 中连接了 socket.io，在 userController.js 中连接了监听逻辑

这是我在 app.js 中的套接字连接

io.on("connection", socket => {
  console.log(`connected ${socket.id}`);
  //creating user as soon as new client connected

  //sending all user but not working
  User.find()
    .then(result => {
      socket.emit("Users", result);
    })
    .catch(err => console.error(err));

  //sending the same id which connected now
  socket.emit("YOUR_ID", socket.id);


  socket.on("disconnection", () => {
    console.log(`disconnected ${socket.id}`);
  });
});

这是我的 userController.js

exports.signin = (req, res) => {
    User.findOne({
            email: req.body.email
        })
        .then(user => {
            console.log(user);

            if (!user) {
                console.log('no user');

                return res.json({
                    msg: 'no user'
                })
            } else {
                //here i want to listen 
                return res.json({

                    msg: 'User exists'
                });

            }
        })
}

我只想监听新用户登录然后发出，但问题是我无法执行该逻辑。

如果我需要添加 socket.io 作为 express 中间件或其他任何东西也可以。

感谢您的帮助。

Answer 1

const socketConnection=io.on("connection", socket => {
  console.log(`connected ${socket.id}`);
  //creating user as soon as new client connected

  //sending all user but not working
  User.find()
    .then(result => {
      socket.emit("Users", result);
    })
    .catch(err => console.error(err));

  //sending the same id which connected now
  socket.emit("YOUR_ID", socket.id);


  socket.on("disconnection", () => {
    console.log(`disconnected ${socket.id}`);
  });
});

然后用 express 设置变量

express.set('socketConnection',socketConnection);

获取并使用

const connection= app.get('socketConnection')