MongoDB+Node.js+Socket.io：mongo-trigger回调事件推送异常问题

你的问题核心是把Socket.io的连接监听逻辑放错了位置，导致无法正确推送集合变化事件给客户端。我来拆解下问题，再给你正确的实现方式：

为什么当前代码不工作？ #

你把io.sockets.on('connection', ...)放在了watcher.watch()的回调里，这会导致：

1. 每次MongoDB集合有变化时，都会重复绑定一次连接事件，造成不必要的资源浪费甚至逻辑冲突
2. 只有在集合变化后新连接的客户端才能收到mongodata事件，而已经在线的客户端完全收不到推送——这显然和你想要的“实时推送所有在线客户端”的需求不符

正确的实现方式 #

我们需要把Socket.io的连接管理和MongoDB的变化监听分开处理，确保集合变化时能推送给所有当前在线的客户端。

步骤1：先初始化Socket.io的连接管理

先在全局层面监听客户端连接，维护已连接的socket实例（或者直接用Socket.io的全局广播功能）：

// 初始化Socket.io连接监听（放在代码的初始化部分，不要放在trigger回调里）
const connectedSockets = [];

io.sockets.on('connection', (socket) => {
  console.log(`客户端 ${socket.id} 已连接`);
  
  // 将新连接的socket加入列表
  connectedSockets.push(socket);
  
  // 处理客户端断开连接，清理无效socket，避免内存泄漏
  socket.on('disconnect', () => {
    console.log(`客户端 ${socket.id} 已断开`);
    connectedSockets = connectedSockets.filter(s => s.id !== socket.id);
  });
});

步骤2：单独监听MongoDB集合变化

在另一个地方设置mongo-trigger的监听，当集合有变化时，给所有已连接的客户端推送事件：

// 监听MongoDB集合变化
watcher.watch('test.students', (event) => {
  console.log('检测到集合变化:', event);
  
  // 方式1：给所有已连接的socket推送消息
  connectedSockets.forEach(socket => {
    socket.emit('mongodata', event);
  });
  
  // 方式2：用Socket.io的全局广播（更简洁，效果和方式1一致）
  // io.sockets.emit('mongodata', event);
});

额外注意事项 #

• 如果你的业务不需要针对单个客户端推送，直接用io.sockets.emit()会更简洁，不需要维护connectedSockets列表
• 一定要处理socket的disconnect事件，避免无效的socket实例占用内存
• 可以在推送前加个简单的判断，比如if (connectedSockets.length > 0)，避免空遍历

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