JavaScript异步流背压核心是平衡生产与消费速度，通过ReadableStream的pull模型、highWaterMark缓冲策略、RxJS操作符（如concatMap）、自定义AsyncIterator及Node.js的_read()节流实现。
JavaScript中处理异步流的背压（Backpressure）问题，核心是控制数据生产速度与消费速度之间的平衡，避免内存溢出或任务堆积。浏览器和Node.js的ReadableStream、TransformStream以及第三方库（如RxJS、most.js）都提供了原生或可配置的背压支持，关键在于理解“拉取模型”与“缓冲策略”的配合使用。
使用ReadableStream的内置背压机制
现代Web平台的ReadableStream默认采用“pull-based”模型：消费者调用reader.read()才触发生产者生成下一个chunk。这天然具备背压能力——只要不主动读取，流就不会继续推送数据。
- 构造流时通过
strategy选项显式设置缓冲区大小（highWaterMark），例如{ highWaterMark: 1 }表示最多缓存1个chunk；超出时controller.enqueue()会阻塞或返回Promise等待消费 - 在
pull回调中，应检查controller.desiredSize > 0再决定是否继续推入新数据，避免盲目填充缓冲区 - 若使用
pipeTo()或pipeThrough()，目标流的highWaterMark和内部处理延迟也会影响整体背压传递，需一并考虑
RxJS中用buffer、throttle和concatMap控流
RxJS本身不强制背压，但提供多种操作符模拟可控消费节奏。重点不是“丢弃数据”，而是让上游按下游能力节拍工作。
-
bufferTime(100)或bufferCount(10)将事件聚合成批次，降低下游调用频次，适合批量处理场景 -
concatMap(fn, concurrent: 1)确保每次只执行一个异步任务，前一个完成后再启动下一个，天然形成串行背压链 -
exhaustMap适用于忽略中间请求（如搜索自动补全），switchMap适用于只响应最新请求，二者都通过取消旧订阅缓解过载
自定义可背压的异步迭代器（AsyncIterator）
当标准流或RxJS不适用时，可手动实现符合Symbol.asyncIterator协议的对象，把控制权交还给for-await-of循环。
立即学习“Java免费学习笔记（深入）”；
- 每次
next()调用返回Promise<{ value, done }>，且该Promise可延迟resolve，直到资源就绪（如数据库连接空闲、上一批HTTP响应处理完） - 内部维护一个待处理队列和当前活跃任务数，
next()仅在active < maxConcurrency时真正发起异步操作，否则先await一个释放信号 - 配合
AbortSignal支持取消，防止因背压等待过久导致的资源泄漏
Node.js中的stream.Readable与_read()节流
在Node.js传统流中，背压依赖_read(size)方法的调用时机和push(chunk)的返回值。
- 当
push()返回false，表示内部缓冲区已满（达到highWaterMark），此时应暂停数据生成，等待'drain'事件再恢复 - 不要在
_read()里无条件读取大量数据；应根据this.readableHighWaterMark和当前this.buffer.length估算还能安全推多少 - 使用
pipeline()替代.pipe()链式调用，它自动监听'error'和'drain'，并在任一环节出错时销毁全部流，提升背压健壮性
