为何Node.js Stream API的.write()方法需要回调函数？

我刚在做stream-adventure的练习时也遇到过完全一样的问题！当时没加next()回调，结果只有第一块数据能输出，后面全断了，后来啃了Node.js流的底层逻辑才搞明白，给你拆解一下：

1. 背压（Backpressure）机制是核心原因 #

Node.js的流是靠背压机制来平衡数据生产和消费速度的——防止生产者（比如process.stdin）疯狂输出数据，而消费者（你的自定义Writable流）处理不过来，导致内存爆掉。

你写的write方法的回调函数，本质就是给流发一个"处理完成"的信号：我这块数据搞定了，你可以发下一块了。如果不调用这个回调，流会默认认为你还在忙当前的chunk，直接暂停接收新数据，后续内容自然就断了。

2. 为什么API说回调是可选，但实际不能省？ #

虽然文档里标注编码和回调是可选参数，但这只是语法层面的宽松——哪怕你的数据处理是同步的，也必须调用回调来通知流状态。

你第一次的代码里，write只接收了chunk，没有回调，Node.js底层会默认把这个write当成异步操作，但你从来没告诉它"我处理完了"，所以流会一直卡在"等待处理完成"的状态，上游的可读流也就暂停推送数据了。

3. 调用next()到底触发了什么？ #

这个回调函数（你命名为next）其实是在触发Writable流内部的几个关键动作：

• 标记当前chunk的处理任务已完成
• 检查流的内部缓冲区，如果还有待处理的数据，立刻触发下一次write
• 通知上游的可读流（比如process.stdin）："我有空了，继续发数据过来"

说白了，这个回调就是背压机制里的"放行开关"，没它的话，数据流动到第一块就卡死了。

再对照你的代码看差异 #

第一次的代码（无回调）：

const {Writable} = require('stream');
const writer = new Writable({
  write(chunk){
    console.log('writing: ' + chunk);
  }
})
process.stdin.pipe(writer);

处理完第一个chunk后，流一直等你发"完成信号"，上游process.stdin就暂停推送，所以只有第一条输出。

加了回调后的代码：

const { stdin } = require('process');
const {Writable} = require('stream');
const writer = new Writable({
  write(chunk, encoding, next){
    console.log('writing: ' + chunk);
    next();
  }
})
process.stdin.pipe(writer);

每次处理完chunk就调用next()，给流发"放行"信号，数据就能持续流动，所有内容都能正常输出。

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