如何利用 Event Loop 中的 write 准备事件实现反代模式下的流式数据无缓冲转发-Nginx-PHP中文网

Event Loop 中的 write 准备事件不可主动利用实现无缓冲转发，真正起作用的是流式组织、背压控制及 Nginx 关闭缓冲；需禁用 proxy_buffering、使用 pipeline 直连、设置正确响应头并验证实时性。

如何利用 event loop 中的 write 准备事件实现反代模式下的流式数据无缓冲转发

直接说结论：Event Loop 里的 write 准备事件本身不能被主动“利用”来实现无缓冲转发。它不是开发者可调度的钩子，而是 Node.js 内部 I/O 层（通过 libuv）在底层 socket 可写时自动触发的机制。真正起作用的是你如何组织流、控制背压、以及配合反向代理中间件（尤其是 Nginx）关闭缓冲行为。

关键不在 await，而在流的自然节流与底层可写性

很多人误以为 await Promise.resolve() 能“让出”事件循环、缓解卡顿，其实它只是把当前微任务推到队列末尾，对 TCP 发送速率、内核 socket 缓冲区、Nginx 缓存层完全没影响。真正决定数据是否“立刻发出去”的，是：

Node.js 的 Writable 流是否处于 writable 状态（即底层 socket 是否就绪可写）
调用 res.write() 后是否立即返回 true（表示未积压），还是返回 false（触发 drain 事件）
上游 chunk 到达速率是否远高于下游网络吞吐能力——这时背压会自动生效，暂停上游读取

Nginx 必须禁用缓冲，否则一切流式都白搭

即使 Node.js 每次 res.write() 都成功，如果 Nginx 默认开启 proxy_buffering on，它就会攒够 4KB 或等超时才转发给客户端。这是生产环境最常被忽略的瓶颈。必须显式关闭：

proxy_buffering off;
proxy_cache off;
proxy_buffer_size 128k;（可选，但避免小 buffer 导致频繁 flush）
proxy_read_timeout 86400;（防止长连接被断）

这些配置要放在对应 SSE 路径的 location 块里，比如 /youtube/sse，而不是全局。

Node.js 服务端转发代码应保持“零加工”流式管道

如果你做的是纯代理（不修改内容），最佳实践是用 pipeline 直接桥接，避免手动 for await + res.write 引入额外延迟：

用 fetch(..., { duplex: 'half' }) 获取上游 ReadableStream
设置响应头：res.setHeader('Content-Type', 'text/event-stream')、res.setHeader('Cache-Control', 'no-cache')、res.setHeader('Connection', 'keep-alive')
用 pipeline(upstreamReadable, res, () => {}) 连接，由 Node.js 自动处理背压和错误
不要加任何 await Promise.resolve()、setTimeout(0) 或人工 sleep