将 Socket.IO 与 Express 和 NodeJS 导出一起使用

Question

我正在尝试将我的 Express 和 Socket 连接连接在一起。我认为我的设置很巧妙，但不是在我想这样做的时候：

1. 用户创建了一个新房间。 POST 到后端 Express 服务器。
2. app.post() 然后将输入发送到导出，该导出处理所有数据库连接。
3. 当它保存在数据库中时，通过套接字向所有人广播已添加新房间。

这可以仅使用套接字来完成吗？是的。但我不是那种生活。

RoomRouter.js

exports.createRoom = (req, response) => {
    new Room(req.body).save((err, room) => {
        response.status(200).send(room);
    });
};

app.js

/*
 * Express setup is left out, because we don't need to focus on that.
 * "app" is const app = express();
 */
const RoomRouter = require("./RoomRouter");

app.post("/room/create", RoomRouter.createRoom);

io.on("connection", (socket) => {
    //I want to broadcast the room to everyone
    //io.emit("newRoom", room);
});

Express 部分工作正常，POST 工作正常。现在，如何将 Socket.IO 连接到它，以便向所有人广播已添加新房间？

Answer 1

我不确定你真正想要什么，但如果你想在你的路由中使用 socket io，我认为你必须像这样声明你的路由：

RoomRouter.js

exports.createRoom = (io) => {
   return (req, response) => {
      new Room(req.body).save((err, room) => {
         io.emit("newRoom", room);
         response.status(200).send(room);
      });
   };
};

在你的 app.js

app.post("/room/create", RoomRouter.createRoom(io));

希望对你有帮助。