MongoDB与Socket.io是否提供无需setInterval轮询的实时同步方案

你当前使用的定时轮询方案会产生不必要的数据库查询开销，有两种官方支持的方案可以替代轮询，实现事件驱动的低延迟实时同步：

方案1：使用MongoDB Change Streams（官方原生支持） #

MongoDB 3.6及以上版本提供了Change Streams特性，可以实时监听集合、数据库甚至整个实例的变更事件，无需定期轮询数据库。当水下传感器上传的数据写入Zips集合产生变更时，你可以直接捕获到变更事件，触发数据推送逻辑。
参考实现代码：

const Zips = require("./dataSchema");

// 全局注册一次Zips集合的变更监听，不要放在connection回调中重复注册
const changeStream = Zips.watch();

io.on("connection", async (socket) => {
  // 新客户端连接时先推送一次全量初始数据
  const initialData = await Zips.find();
  socket.emit("output", initialData);

  // 集合发生变更时，主动向当前连接的客户端推送最新数据
  changeStream.on("change", async () => {
    const latestData = await Zips.find();
    socket.emit("output", latestData);
  });
});

注意事项：

• 该功能要求你的MongoDB部署为副本集或分片集群模式，单节点开发模式不支持Change Streams
• 可以根据业务需要只推送增量变更数据，进一步降低传输开销

方案2：写入数据时主动触发推送（性能最优） #

如果你的水下传感器数据写入逻辑是由当前NodeJS服务处理的，完全可以在数据写入MongoDB成功后，直接主动给所有已连接的Socket客户端推送最新数据，不需要依赖数据库的监听能力，资源消耗最低、延迟最小。
参考实现代码：

// 传感器数据写入接口示例
app.post("/uploadSensorData", async (req, res) => {
  // 写入新的传感器数据到数据库
  const newSensorData = new Zips(req.body);
  await newSensorData.save();
  // 写入成功后，主动向所有已连接的客户端推送全量最新数据
  const latestData = await Zips.find();
  io.emit("output", latestData);
  res.status(200).send("数据写入成功");
});

2022年11月8日编辑确认：以上两种方案均为官方文档明确支持的可行方案，可完全替代轮询实现实时同步需求。

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