如何使用Mongoose将Socket.IO连接到现有MongoDB连接

你的代码核心问题是MongoDB连接成功后启动的是未挂载Socket.IO的Express实例，而非绑定了Socket.IO的http服务实例，导致Socket.IO服务未正常运行，且无需为Socket.IO单独配置MongoDB连接，Mongoose会全局复用已建立的连接池。

第一步：修正服务启动逻辑 #

你当前将Socket.IO绑定到了chatServer这个http服务实例上，但连接MongoDB后启动的是app（Express实例），需要把启动逻辑改成启动chatServer，修改server.js中MongoDB连接后的代码：

// 现有MongoDB数据库连接逻辑
connect
  .then(() => {
    // 替换原来的app.listen为chatServer.listen
    chatServer.listen(PORT, () =>
      console.log(`Server Running on Port: http://localhost:${PORT}`)
    );
  })
  .catch((error) => console.log(`${error} did not connect`));

第二步：（可选）配置Socket.IO跨域 #

Express的CORS中间件不会作用于Socket.IO，若前端连接Socket.IO出现跨域报错，需要在初始化Socket.IO时单独配置CORS：

const socket = new Server(chatServer, {
  cors: {
    origin: "http://你的前端地址", // 生产环境不要用*，填实际前端域名更安全
    methods: ["GET", "POST"]
  }
});

第三步：在Socket.IO逻辑中直接使用MongoDB #

Mongoose的连接是全局单例的，只要dbconnect.js的连接逻辑执行成功，你可以在Socket.IO的任意回调中直接引入你定义的Mongoose模型操作数据库，示例如下：

// 先引入你定义的消息模型
import Message from './models/MessageModel.js';

socket.on('connection', (socket) => {
  console.log('a user connected');
  // 监听前端发送消息的事件，直接存入MongoDB
  socket.on('sendMessage', async (msgData) => {
    try {
      const savedMsg = await Message.create(msgData);
      // 广播给其他在线用户
      socket.broadcast.emit('newMessage', savedMsg);
    } catch (err) {
      console.error('消息存储失败：', err);
    }
  });
});

内容的提问来源于stack exchange，提问作者rjc30