如何正确处理Nano的Changes Feed(Follow)？停止Feed避免异常

我来帮你搞定这个停止Feed时触发异常的问题～结合你给出的代码片段，大概率是资源未清理或者错误未捕获导致的，下面是具体的排查和修复方案：

常见原因分析 #

• 停止Feed前没清理定时任务（比如你代码里的setInterval），定时器还在尝试插入文档，此时Feed已关闭，引发请求错误
• 没有监听Feed的error事件，停止时的错误直接变成未捕获异常抛出
• 调用feed.stop()后没处理流关闭的后续逻辑

修正后的完整代码示例 #

const nano = require("nano")("http://localhost:5984");
const name = "test";

nano.db.destroy(name, () => {
  nano.db.create(name, () => {
    const db = nano.use(name);
    const feed = db.follow({ since: "now" });
    let insertTimer;

    // 监听Feed的变更通知
    feed.on("change", (change) => {
      console.log("捕获到数据库变更:", change);
    });

    // 关键：必须监听Feed的错误事件，避免未捕获异常导致程序崩溃
    feed.on("error", (err) => {
      console.error("Feed运行出错:", err);
      // 出错时自动清理资源
      if (insertTimer) clearInterval(insertTimer);
    });

    // 启动Feed监听
    feed.follow();

    // 每秒插入一个测试文档
    insertTimer = setInterval(() => {
      db.insert({}, (err, body) => {
        if (err) {
          console.error("插入文档失败:", err);
          // 插入失败时主动停止定时器和Feed
          clearInterval(insertTimer);
          feed.stop();
        } else {
          console.log("插入文档成功，ID:", body.id);
        }
      });
    }, 1000);

    // 示例：5秒后主动停止Feed和定时器
    setTimeout(() => {
      console.log("准备停止Feed...");
      // 先清理定时器，避免后续插入请求触发无效连接错误
      clearInterval(insertTimer);
      // 调用stop并传入回调，确认Feed完全停止
      feed.stop(() => {
        console.log("Feed已成功停止");
      });
    }, 5000);
  });
});

核心修复点 #

• 绑定error事件处理：给Feed加上error监听，所有错误（包括停止时的流关闭错误）都会被捕获，不会直接抛出崩溃程序
• 先停定时器再关Feed：停止Feed前先清理setInterval，确保没有新的插入请求发送到已关闭的连接上
• 使用feed.stop()的回调：通过回调确认Feed完全停止，方便后续做资源回收或日志记录

额外提示 #

如果你的异常是ECONNRESET这类连接错误，上面的修复应该能直接解决。要是还有问题，可以把具体的异常信息贴出来，我再帮你进一步排查～

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