Node.js背压与drain事件：内存泄漏问题及正确处理器写法咨询

哥们，我一眼就看出你代码里的问题了——你每次触发data事件时，如果可写流缓冲区满了，就给它绑定一个新的drain监听，但这些监听会不断积累，直到超过Node.js默认的事件监听器上限，就出现了那个内存泄漏警告。

问题根源 #

你的代码里，当ws.write(data)返回false时，调用ws.once("drain", handler)，这相当于每次缓冲区满的时候，都给可写流新增一个drain事件的回调（也就是你的data事件处理器）。但如果在drain触发前，又有新的data事件进来，就会重复绑定，导致监听器数量越来越多，最终触发警告。

正确的写法：通过暂停/恢复可读流控制数据流动 #

处理背压的核心是当可写流忙的时候，暂停可读流的读取；等可写流空闲了，再恢复读取，而不是重复绑定事件回调。这样就能避免多余的监听器积累。

修正后的代码如下：

"use strict";
const rs = getReadableStreamSomehow();
const ws = getWritableStreamSomehow();

rs.on("data", (data) => {
  // 尝试写入数据
  const canContinueWriting = ws.write(data);
  if (!canContinueWriting) {
    // 缓冲区满了，暂停可读流，停止触发data事件
    rs.pause();
    // 只绑定一次drain事件，等缓冲区排空后恢复读取
    ws.once("drain", () => {
      rs.resume();
    });
  }
});

// 补充健壮性处理：处理流的结束和错误
rs.on("end", () => {
  // 可读流结束时，告诉可写流没有更多数据了
  ws.end();
});

rs.on("error", (err) => {
  console.error("可读流发生错误:", err);
  // 出错时销毁可写流，避免资源泄漏
  ws.destroy(err);
});

ws.on("error", (err) => {
  console.error("可写流发生错误:", err);
  // 出错时销毁可读流，避免资源泄漏
  rs.destroy(err);
});

为什么这样写是对的？ #

• 当可写流缓冲区满时，调用rs.pause()，可读流会停止触发data事件，这样就不会重复进入回调、重复绑定drain监听。
• 只通过once绑定一次drain事件，确保缓冲区排空后只会恢复一次可读流，不会有多余的监听器。
• 加上end和error事件的处理，能保证流在正常结束或出错时都能正确清理资源，避免潜在的泄漏。

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